我正在使用 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);
}
}
最佳答案
@菲利普
据我了解,您的要求是:
- 在每笔交易中生成一个唯一的 token (数据库 当然是交易)
- 让这个独特的 token 在所有层都易于访问
因此,您很自然地会考虑将 Spring 提供的 TransactionSynchronizationManager 作为存储唯一 token (在本例中为 UID)的工具
使用这种方法要非常小心,TransactionSynchronizationManager 是管理 Spring 所有@Transactional 处理的主要存储助手。在@Transactional 引擎盖下,Spring 正在创建一个适当的 EntityManager,一个适当的同步对象,并使用 TransactionSynchronizationManager 将它们附加到本地线程。
在您的服务类代码中,在您篡改同步对象的 @Transactional 方法中,它最终可能会出现不良行为。
我在这里对@Transactional 的工作原理做了深入的分析,看看:http://doanduyhai.wordpress.com/2011/11/20/spring-transactional-explained/
现在回到您的需求。你可以做的是:
- 在 AuditService 中添加一个本地线程,在进入 @Transactional 方法时包含唯一 token ,并在退出该方法时销毁它。在此方法调用中,您可以访问任何层中的唯一 token 。可以在此处找到有关 ThreadLocal 用法的说明:http://doanduyhai.wordpress.com/2011/12/04/threadlocal-explained/
创建一个新注解,比如@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())...
...
}
希望这会有所帮助。
关于java - 将声明式和编程式事务与 Spring 和 JPA 监听器混合,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/6346073/