我有一个基于 Spring 的应用程序，它有一个在单独的线程中运行的后台轮询服务，以更新数据库中数据的状态 (EmployeeStatusPollService)。我使用 JPA(Hibernate 供应商)作为存储库。我用两种解决方案实现了这项服务，但只有一种解决方案有效。以下是两种解决方案。
解决方案 1:其他服务类中的事务性方法 checkAndUpdateStatus 和轮询服务调用它
@Service
public class EmployeeStatusPollService implements Runnable {
@Inject
private EmployeeService employeeService;
private static final int DEFAULT_PAGE_SIZE = 300;
private boolean flag = true;
public EmployeeStatusPollService() {
}
@PostConstruct
public void start() {
SimpleAsyncTaskExecutor executor = new SimpleAsyncTaskExecutor();
executor.setConcurrencyLimit(SimpleAsyncTaskExecutor.NO_CONCURRENCY);
executor.execute(this);
}
public void run() {
while(flag) {
try {
int pagenum = 1;
List<Employee> items = null;
do {
items = employeeService.checkAndUpdateStatus(pagenum, DEFAULT_PAGE_SIZE);
} while(items != null && items.size() == DEFAULT_PAGE_SIZE);
} catch(Exception ex) {
}
}
}
}
@Service
public class EmployeeServiceImpl implements EmployeeService {
private static final Logger LOG = LoggerFactory.getLogger(EmployeeServiceImpl.class);
@Inject
private EmployeeRepository employeeRepository;
@Transactional
public List<Employee> checkAndUpdateStatus(int pagenum, int pagesize) throws Exception {
// ....
}
}
解决方案 2:事务性方法 checkAndUpdateStatus 在轮询服务类中
@Service
public class EmployeeStatusPollService implements Runnable {
@Inject
private EmployeeRepository employeeRepository;
private static final int DEFAULT_PAGE_SIZE = 300;
private boolean flag = true;
public EmployeeStatusPollService() {
}
@PostConstruct
public void start() {
SimpleAsyncTaskExecutor executor = new SimpleAsyncTaskExecutor();
executor.setConcurrencyLimit(SimpleAsyncTaskExecutor.NO_CONCURRENCY);
executor.execute(this);
}
public void run() {
while(flag) {
try {
int pagenum = 1;
List<Employee> items = null;
do {
items = checkAndUpdateStatus(pagenum, DEFAULT_PAGE_SIZE);
} while(items != null && items.size() == DEFAULT_PAGE_SIZE);
} catch(Exception ex) {
}
}
}
@Transactional
public List<Employee> checkAndUpdateStatus(int pagenum, int pagesize) throws Exception {
// ....
}
}
方法checkAndUpdateStatus的详细信息
@Transactional
public List<Employee> checkAndUpdateStatus(int pagenum, int pagesize) throws Exception {
PageRequest page = new PageRequest(pagenum, pagesize);
Page<Employee> pagedItems = employeeRepository.findByStatus(EmployeeStatus.PENDING, page); // Line 1: Query employees
List<Employee> emps = pagedItems.getContent();
List<Long> updatedItems = new ArrayList<>();
int i = 0;
for(Employee emp:emps) {
try {
// ...
emp.setStatus(status); // Line 2: Update employee's status
employeeRepository.save(emp); // Line 3: Save/Update employee
updatedItems.add(emp.getId());
i++;
if(i % 50 == 0) {
employeeRepository.flush(); // Line 4: flush for every 50 employees
}
//....
} catch (Exception ex) {
// handle exception here....
}
}
return emps;
}
配置
<bean id="transactionManager" class="org.springframework.orm.jpa.JpaTransactionManager">
<property name="entityManagerFactory" ref="entityManagerFactory" />
</bean>
<tx:annotation-driven transaction-manager="transactionManager" />
<bean id="dataSource" class="org.apache.commons.dbcp2.BasicDataSource">
<property name="driverClassName" value="${jdbc.driver}" />
<property name="url" value="${jdbc.url}" />
<property name="username" value="${jdbc.username}" />
<property name="password" value="${jdbc.password}" />
<property name="defaultAutoCommit" value="false" />
</bean>
<bean id="entityManager" class="org.springframework.orm.jpa.support.SharedEntityManagerBean">
<property name="entityManagerFactory" ref="entityManagerFactory"/>
</bean>
<bean id="entityManagerFactory" class="org.springframework.orm.jpa.LocalContainerEntityManagerFactoryBean">
<property name="dataSource" ref="dataSource"></property>
<property name="jpaDialect" ref="jpaDialect"></property>
<property name="jpaVendorAdapter" ref="jpaVendorAdapter"></property>
<property name="packagesToScan" value="${jpa.packagesToScan}" />
<property name="jpaProperties">
<props>
<prop key="hibernate.dialect">${hibernate.dialect}</prop>
<prop key="hibernate.show_sql">${hibernate.show_sql}</prop>
<prop key="hibernate.format_sql">${hibernate.format_sql}</prop>
<prop key="hibernate.connection.autocommit">${hibernate.connection.autocommit}</prop>
<prop key="hibernate.connection.defaultAutoCommit">${hibernate.connection.defaultAutoCommit}</prop>
</props>
</property>
</bean>
<bean id="jpaDialect" class="org.springframework.orm.jpa.vendor.HibernateJpaDialect"></bean>
<bean id="jpaVendorAdapter" class="org.springframework.orm.jpa.vendor.HibernateJpaVendorAdapter"></bean>
解决方案 2 不起作用，当它在方法 checkAndUpdateStatus 的第 3 行将实体更新/保存到数据库时，我收到错误“持久实体已分离...”。
IMO，解决方案 2 不起作用，因为方法 checkAndUpdateStatus 没有被放入事务上下文中，尽管它被标记为 @Transactional。即使我设置了 REQUIRES_NEW 它仍然不起作用。任何人都可以向我解释为什么会发生此错误或向我发送一些有关此的引用文档吗？
最佳答案
事务注解通过在原始类上创建代理来工作，并且对类中方法的本地或内部调用不会导致调用代理方法。换句话说，从一个类中的方法调用同一个类中的另一个方法不会被代理拦截。
具体针对您的情况进行解释:
为了使事务注释起作用，spring 围绕 EmployeeStatusPollService 类创建了一个代理，它将包装您的 EmployeeStatusPollService 类实例以拦截对具有事务注释的 checkAndUpdateStatus 方法的调用。
checkAndUpdateStatus 方法的代理版本添加了所需的事务行为，然后调用原始的 checkAndUpdateStatus 方法。然而，这具有这样的效果，即从您的类实例中对 checkAndUpdateStatus 方法的任何调用都会直接在该实例上调用，并且不会被包装代理拦截。
因此，在第二个示例中，当从 EmployeeStatusPollService 的另一个方法内部调用“checkAndUpdateStatus”时，它不会在具有事务能力的 EmployeeStatusPollService 的代理版本上调用，而是在普通版本上调用。
第一个示例之所以有效，是因为 checkAndUpdateStatus 位于不同的类中，因此外部调用被代理拦截。
您可以在此处阅读有关事务处理与代理创建相关的更多信息: https://spring.io/blog/2012/05/23/transactions-caching-and-aop-understanding-proxy-usage-in-spring
您可以在此处阅读有关代理过程如何工作的信息: http://docs.spring.io/spring/docs/current/spring-framework-reference/html/aop.html#aop-understanding-aop-proxies
关于java - Spring Transactional 方法不适用于单独的线程，我们在Stack Overflow上找到一个类似的问题： https://stackoverflow.com/questions/27182157/