我正在构建一个使用Spring Data和Hibernate的简单Tomcat Web应用程序。有一个端点要做很多工作,因此我想将工作卸载到后台线程,以便在完成工作时Web请求不会挂起10分钟以上。因此,我在组件扫描的程序包中编写了新服务:
@Service public class BackgroundJobService { @Autowired private ThreadPoolTaskExecutor threadPoolTaskExecutor; public void startJob(Runnable runnable) { threadPoolTaskExecutor.execute(runnable); } }
然后ThreadPoolTaskExecutor在Spring中进行配置:
ThreadPoolTaskExecutor
<bean id="threadPoolTaskExecutor" class="org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor"> <property name="corePoolSize" value="5" /> <property name="maxPoolSize" value="10" /> <property name="queueCapacity" value="25" /> </bean>
这一切都很好。但是,问题来自于hibernate。在我的可运行内部,查询仅完成一半。我可以:
MyObject myObject = myObjectRepository.findOne() myObject.setSomething("something"); myObjectRepository.save(myObject);
但是,如果我有延迟加载的字段,它将失败:
MyObject myObject = myObjectRepository.findOne() List<Lazy> lazies = myObject.getLazies(); for(Lazy lazy : lazies) { // Exception ... }
我收到以下错误:
org.hibernate.LazyInitializationException: failed to lazily initialize a collection of role: com.stackoverflow.MyObject.lazies, could not initialize proxy - no Session
因此,对我来说(hibernate新手),新线程在这些自制线程上没有会话,但是Spring Data会自动为HTTP请求线程创建新会话。
使用Spring,你不需要自己的执行程序。一个简单的注释@Async将为你完成工作。只需heavyMethod在你的服务中为其添加注释并返回void或Future对象,你将获得一个后台线程。我会避免在控制器级别使用异步注释,因为这将在请求池执行程序中创建一个异步线程,并且你可能会用完“请求接受器”。
@Async
heavyMethod
Future
延迟异常的问题来自你怀疑来自没有会话的新线程。为避免此问题,你的异步方法应处理完整的工作。不要提供先前加载的实体作为参数。该服务可以使用EntityManager,也可以是事务性的。
我自己不会合并@Async,@Transactional因此我可以以任何一种方式运行该服务。我只是围绕服务创建一个异步包装器,并在需要时使用该包装器。(例如,这简化了测试)
@Asyn
@Transactional
@Service public class AsyncService { @Autowired private Service service; @Async public void doAsync(int entityId) { service.doHeavy(entityId); } } @Service public class Service { @PersistenceContext private EntityManager em; @Transactional public void doHeavy(int entityId) { // some long running work } }