我正在为我的RESTapi使用一个Open Session In View事务模型,如下所示:
@Override
public void doFilter(ServletRequest request, ServletResponse response, FilterChain chain)
sessionFactory.getCurrentSession().beginTransaction();
chain.doFilter(request, response);
sessionFactory.getCurrentSession().getTransaction().commit();
}
这项工作很好。我想添加异步功能。所以我创建了:
@Configuration
@EnableAsync
public class AsyncConfig implements AsyncConfigurer {
@Override
@Bean(destroyMethod="shutdown")
public Executor getAsyncExecutor() {
ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor();
executor.setCorePoolSize(18);
executor.setMaxPoolSize(18);
executor.initialize();
executor.setDaemon(true);
executor.setWaitForTasksToCompleteOnShutdown(false);
return executor;
}
@Override
public AsyncUncaughtExceptionHandler getAsyncUncaughtExceptionHandler() {
return new SimpleAsyncUncaughtExceptionHandler();
}
}
和:
@Component
public class AsyncMarketCaller {
@Inject
MarketManagerFactory marketManagerFactory;
@Async
public Future<List<Product>> getProducts(){
MarketManager productManager = marketManagerFactory.obtainMarketManager(market);
result = productManager.getProducts();
....
}
}
产品经理打电话给另一个@Service
@Service
public class DefaultIdentifierManager implements IdentifierManager{
@Inject
UpcEanDAO upcEanDAO;
@Override
public String getTitleForIdentifier(String identifier){
UpcEan upcEan = upcEanDAO.find(identifier);
}
}
然而,对于upcEanDAO.find(identifier)
,我得到了一个例外:
Caused by: org.hibernate.HibernateException: get is not valid without active transaction
在我添加@Async
对getProducts()
进行异步调用之前,它运行得很好,所以我假设@Async
会杀死我用Hibernate打开的事务。
我尝试在这里的另一个答案@Transactional
的基础上添加到用@Async
注释的方法中,但没有帮助。
知道吗?
已编辑
我编辑了代码,所以
@Component
public class AsyncMarketCaller {
@Inject
AsyncMarketService asyncMarketService;
@Async
public Future<List<Product>> getProducts(){
asyncMarketService.getProducts();
}
}
和
@Service
public class AsyncMarketService {
@Inject
MarketManagerFactory marketManagerFactory;
@Transactional
public Future<List<Product>> getProducts()
....
}
}
我在日志中看到
50689 DEBUG [localhost-startStop-1] org.springframework.transaction.annotation.AnnotationTransactionAttributeSource - Adding transactional method 'AsyncMarketService.getProducts' with attribute: PROPAGATION_REQUIRED,ISOLATION_DEFAULT; ''
但这无济于事。请注意,我的方法AsyncMarketService.getProducts不会直接调用DB,它会调用其他方法,并且只有其中一个方法会进行调用。
我还在上面添加了一个实际调用DB的:@Transactional
49992 DEBUG [localhost-startStop-1] org.springframework.transaction.annotation.AnnotationTransactionAttributeSource - Adding transactional method 'DefaultIdentifierManager.getTitleForIdentifier' with attribute: PROPAGATION_REQUIRED,ISOLATION_DEFAULT; '
’
Hibernate事务在ThreadLocal
的基础上工作。
当您使用另一个带有@Async
的线程时,将不会有任何事务处于活动状态。
您可以通过让异步方法调用另一个由@Transactional
注释的bean来实现此功能。
在这里,我对这种方法进行了更多的解释:使用SpringData和Hibernate时,如何正确地执行后台线程?