java - 将声明式和编程式事务与 Spring 和 JPA 监听器混合

Question

我正在使用 JPA EntityListener 做一些额外的审计工作，并使用 @Configurable 将 Spring 管理的 AuditService 注入(inject)我的 AuditEntryListener。 AuditService 生成 AuditEntry 对象的集合。 AuditService 本身是一个 Singleton 范围的 bean，我想将所有 AuditEntry 对象收集在一个公共(public) key 下，然后可以由最外层的服务层(调用持久调用的层调用，进而触发 EntityListener)访问。

我正在考虑使用 Spring 的 TransactionSynchronizationManager 在事务开始时设置一个特定的事务名称(使用 UID() 或其他一些独特的策略)，然后使用该名称作为 AuditService 中的键，这将允许我对在该事务中创建的所有 AuditEntry 对象进行分组。

混合声明式和程序化事务管理是否有潜在的麻烦？ (虽然我只是设置交易名称)。有没有更好的方法将生成的 AuditEntry 对象与当前事务相关联？此解决方案确实适用于我，但考虑到 TransactionSynchronizationManager 不是为应用程序使用而设计的，我想确保我对它的使用不会导致一些不可预见的问题。

相关问题

最后，一个相关但不是直接相关的问题:我知道 JPA EntityListeners 的文档警告不要使用当前的 EntityManager，但是如果我确实想用它来区分一个对象和它的持久化自身，我会安全吗在我的 preUpdate() 方法周围使用 @Transactional(propagation=REQUIRES_NEW) 注释？

原型(prototype)代码:

服务等级

@Transactional
public void create(MyEntity e) {

    TransactionSynchronizationManager.setCurrentTransactionName(new UID().toString());
    this.em.persist(e);
    TransactionSynchronizationManager.registerSynchronization(new TransactionSynchronizationAdapter() {
        @Override
        public void afterCommit() {
            Set<AuditEntry> entries = auditService.getAuditEntries(TransactionSynchronizationManager.getCurrentTransactionName());
            if(entries != null) {
                for(AuditEntry entry : entries) {
                   //do some stuff....
                   LOG.info(entry.toString());
                }
            }
        }
    });
}

JPA 实体监听器

@Configurable
public class AuditEntryListener {

@Autowired
private AuditService service;

@PreUpdate
public void preUpdate(Object entity) {
    service.auditUpdate(TransactionSynchronizationManager.getCurrentTransactionName(), entity);
}

public void setService(AuditService service) {
    this.service = service;
}

public AuditService getService() {
    return service;
}

审计服务

@Service
public class AuditService {
private Map<String, Set<AuditEntry>> auditEntryMap = new HashMap<String, Set<AuditEntry>>();

public void auditUpdate(String key, Object entity) {
    // do some audit work
    // add audit entries to map
    this.auditEntryMap.get(key).add(ae);
}

}

Answer 1

@菲利普

据我了解，您的要求是:

1. 在每笔交易中生成一个唯一的 token (数据库当然是交易)
2. 让这个独特的 token 在所有层都易于访问

因此，您很自然地会考虑将 Spring 提供的 TransactionSynchronizationManager 作为存储唯一 token (在本例中为 UID)的工具

使用这种方法要非常小心，TransactionSynchronizationManager 是管理 Spring 所有@Transactional 处理的主要存储助手。在@Transactional 引擎盖下，Spring 正在创建一个适当的 EntityManager，一个适当的同步对象，并使用 TransactionSynchronizationManager 将它们附加到本地线程。

在您的服务类代码中，在您篡改同步对象的 @Transactional 方法中，它最终可能会出现不良行为。

我在这里对@Transactional 的工作原理做了深入的分析，看看:http://doanduyhai.wordpress.com/2011/11/20/spring-transactional-explained/

现在回到您的需求。你可以做的是:

1. 在 AuditService 中添加一个本地线程，在进入 @Transactional 方法时包含唯一 token ，并在退出该方法时销毁它。在此方法调用中，您可以访问任何层中的唯一 token 。可以在此处找到有关 ThreadLocal 用法的说明:http://doanduyhai.wordpress.com/2011/12/04/threadlocal-explained/

2. 创建一个新注解，比如@Auditable(uid="AuditScenario1") 来注解需要审计的方法，并使用 Spring AOP 拦截这些方法调用并为您管理 Thread 本地处理

   示例:

修改后的审计服务

@Service
public class AuditService {

public uidThreadLocal = new ThreadLocal<String>();
...
...
}

可审计注释

@Retention(RetentionPolicy.RUNTIME)
@Target(ElementType.METHOD)
@Documented
public @interface Auditable 
{
    String uid();
}

@Auditable注解的使用

@Auditable(uid="AuditScenario1")
@Transactional
public void myMethod()
{
   // Something 
}

Spring AOP部分

@Around("execution(public * *(..)) && @annotation(auditableAnnotation)) 
public Object manageAuditToken(ProceedingJoinPoint jp, Auditable auditableAnnotation)
{
    ...
    ...
    AuditService.uidThreadLocal.set(auditableAnnotation.uid())...
    ...
}

希望这会有所帮助。