使用Spring Data和Hibernate时如何正确执行后台线程？

Question

我正在构建一个使用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中进行配置：

<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 Request线程创建新会话。

• 有没有办法从会话中手动启动新会话？
• 还是一种告诉线程池为我做的方法？
• 进行此类工作的标准做法是什么？

通过从@Transactional方法内部做所有事情，我已经能够解决该问题，但是我很快就知道这不是一个很好的解决方案，因为这不能让我使用对Web请求来说效果很好的方法。

谢谢。

Answer 1

使用Spring，您不需要自己的执行程序。一个简单的注释@Async将为您完成工作。只需heavyMethod在您的服务中为其添加注释并返回void或Future对象，您将获得一个后台线程。我会避免在控制器级别使用异步注释，因为这将在请求池执行程序中创建一个异步线程，并且您可能会用完“请求接受器”。

延迟异常的问题来自怀疑没有会话的新线程。为避免此问题，您的异步方法应处理全部工作。不要提供先前加载的实体作为参数。该服务可以使用EntityManager，也可以是事务性的。

我自己不会合并@Async，@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
    }
}