mongoOperations 的更新似乎不会触发 AbstractMongoEventListener 中的事件。
This post indicates that was at least the case in Nov 2014
目前有什么方法可以收听如下更新事件吗？如果是这样的话，这似乎是一个很大的遗漏。
MongoTemplate.updateMulti()
谢谢！
【问题讨论】：
标签： spring spring-data-mongodb event-listener
这不是疏忽。事件至少是围绕域对象或文档的生命周期设计的，这意味着它们通常包含您感兴趣的域对象的实例。
另一方面，更新完全在数据库中处理。所以MongoTemplate 中没有处理任何文档甚至域对象。考虑这一点基本上与 JPA @EntityListeners 仅针对首先加载到持久性上下文中的实体触发的方式相同，但在执行查询时不会触发，因为查询的执行是在数据库中发生的。
【讨论】：
@Version 是如何处理这个问题的呢？当您调用 mongoTemplate.updateFIrst(...) 时，Spring Data Mongo 会将 , "$inc" : { "version" : { "$numberLong" : "1" } } 添加到您的查询中。
我知道现在回答这个问题为时已晚，我对 MongoTemplate.findAndModify 方法有同样的情况，我需要事件的原因是出于审计目的。这就是我所做的。
1.EventPublisher（MongoTemplate 的方法）
public class CustomMongoTemplate extends MongoTemplate {
private ApplicationEventPublisher applicationEventPublisher;
@Autowired
public void setApplicationEventPublisher(ApplicationEventPublisher
applicationEventPublisher) {
this.applicationEventPublisher = applicationEventPublisher;
}
//Default Constructor here
@Override
public <T> T findAndModify(Query query, Update update, Class<T> entityClass) {
T result = super.findAndModify(query, update, entityClass);
//Publishing Custom Event on findAndModify
if(result!=null && result instanceof Parent)//All of my Domain class extends Parent
this.applicationEventPublisher.publishEvent(new AfterFindAndModify
(this,((Parent)result).getId(),
result.getClass().toString())
);
return result;
} }
2.应用事件
public class AfterFindAndModify extends ApplicationEvent {
private DocumentAuditLog documentAuditLog;
public AfterFindAndModify(Object source, String documentId,
String documentObject) {
super(source);
this.documentAuditLog = new DocumentAuditLog(documentId,
documentObject,new Date(),"UPDATE");
}
public DocumentAuditLog getDocumentAuditLog() {
return documentAuditLog;
}
}
3.应用监听器
public class FindandUpdateMongoEventListner implements ApplicationListener<AfterFindAndModify> {
@Autowired
MongoOperations mongoOperations;
@Override
public void onApplicationEvent(AfterFindAndModify event) {
mongoOperations.save(event.getDocumentAuditLog());
}
}
然后
@Configuration
@EnableMongoRepositories(basePackages = "my.pkg")
@ComponentScan(basePackages = {"my.pkg"})
public class MongoConfig extends AbstractMongoConfiguration {
//.....
@Bean
public FindandUpdateMongoEventListner findandUpdateMongoEventListner(){
return new FindandUpdateMongoEventListner();
}
}
【讨论】：
您可以监听数据库更改，甚至是完全在您的程序之外的更改（MongoDB 4.2 和更新版本）。
（代码是 kotlin 语言。java 也一样）
@Autowired private lateinit var op: MongoTemplate
@PostConstruct
fun listenOnExternalChanges() {
Thread {
op.getCollection("Item").watch().onEach {
if(it.updateDescription.updatedFields.containsKey("name")) {
println("name changed on a document: ${it.updateDescription.updatedFields["name"]}")
}
}
}.start()
}
此代码仅在启用复制时有效。即使只有一个节点也可以启用它：
将以下副本集详细信息添加到 mongodb.conf（/etc/mongodb.conf 或 /usr/local/etc/mongod.conf 或 C:\Program Files\MongoDB\Server\4.0\bin\mongod.cfg）文件
replication:
replSetName: "local"
重启mongo服务，然后打开mongo控制台运行这个命令：
rs.initiate()
【讨论】：