【发布时间】:2017-02-23 04:10:48
【问题描述】:
我有一个在启动时运行异步任务的服务,它以递归方式运行:
@Service
public class TaskService {
private final TaskRepository taskRepository;
@Inject
public TaskService(TaskRepository taskRepository) {
this.taskRepository= taskRepository;
}
private final int currentTaskId = -1;
@Transactional
@PostConstruct
private void init() {
taskRepository.findByClosedDateIsNull().forEach(taskRepository::delete);
runTask();
}
@Async
@Transactional
private void runTask() {
if (!getCurrent().isPresent()) {
Task task = new Task();
//set props
currentTaskId = taskRepository.save(task).getId();
}
Util.sleep(5000); //wrapper for simple Thread.sleep(long l).
Task task = getCurrent().get();
if (task.getEvents().size > 0) {
//bussiness logic
Util.sleep(1000);
}
runTask();
}
@Transactional(readOnly = true)
private Optional<Task> getCurrent() {
return taskRepository.findOneById(currentTaskId).map(task -> {
task.getEvents().size(); //throws the error here
return task;
});
}
}
堆栈跟踪:
原因:org.hibernate.LazyInitializationException:未能延迟初始化角色集合:com.test.domain.Task.events,无法初始化代理 - 没有会话 在 org.hibernate.collection.internal.AbstractPersistentCollection.throwLazyInitializationException(AbstractPersistentCollection.java:576) 在 org.hibernate.collection.internal.AbstractPersistentCollection.withTemporarySessionIfNeeded(AbstractPersistentCollection.java:215) 在 org.hibernate.collection.internal.AbstractPersistentCollection.readSize(AbstractPersistentCollection.java:156) 在 org.hibernate.collection.internal.PersistentSet.size(PersistentSet.java:160) 在 com.test.service.TaskService.lambda$getCurrent$5(TaskService.java:135) 在 java.util.Optional.map(Optional.java:215) 在 com.test.service.TaskService.getCurrent(TaskService.java:134) 在 com.test.service.TaskService.runTask(TaskService.java:163) 在 com.test.service.TaskService.init(TaskService.java:66) 在 sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method) 在 sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62) 在 sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) 在 java.lang.reflect.Method.invoke(Method.java:498) 在 org.springframework.beans.factory.annotation.InitDestroyAnnotationBeanPostProcessor$LifecycleElement.invoke(InitDestroyAnnotationBeanPostProcessor.java:365) 在 org.springframework.beans.factory.annotation.InitDestroyAnnotationBeanPostProcessor$LifecycleMetadata.invokeInitMethods(InitDestroyAnnotationBeanPostProcessor.java:310) 在 org.springframework.beans.factory.annotation.InitDestroyAnnotationBeanPostProcessor.postProcessBeforeInitialization(InitDestroyAnnotationBeanPostProcessor.java:133) ...省略了21个常用框架
我也尝试过 Hibernate.initialize(Object proxy);。 OpenViewSessionFilter 不是我的解决方案。我不想设置这个集合 EAGER。
【问题讨论】:
-
为什么
OpenViewSessionFilter不是解决方案?您可以使用获取计划并使其急于执行此查询吗? -
OpenViewSessionFilter会降低性能。 + 其他服务中的大多数方法(如getCurrent())都有效。我认为问题在@Async,很多@Transactional还是递归的。因为我使用 JpaRepository,所以我不能急于求成。如果它是惰性的,它就不能返回急切的集合。我正在尝试在getCurrent()方法中获取集合。 -
您正在处理程序中执行显式
sleep。过滤器的开销不相关。 -
这是
sleep方法(也许是Spring-way)使其工作的一种方式吗?不睡觉怎么办? -
First Spring 使用代理来处理事务和异步行为。所以基本上你在私有方法上的
@ASync和@Transactional是没用的(方法调用不通过代理)。其次,没有保证init方法上的@Transactional已经应用(它可能会或可能不会)。基本上在@PostConstruct方法中做这样的事情并不是正确的做法。除此之外,您最终还将遇到与您现在设置代码的方式有关的堆栈溢出。从runTask调用runTask最终会中断。
标签: java spring hibernate spring-data spring-transactions