Seam的Events用的很舒服spring提供的事件机制太罗嗦所以起了念头着这思路移植一下最终效果如下
//发布事件
Eventsinstance()fire(eventNameargarg)
//发布异步事件
Eventsinstance()fireAsynchronous(eventNameargarg)
//在事务中发布当事务成功commit时触发的事件
Eventsinstance()fireOnTransactionSuccess(eventNameargarg)
//在事务中发布当事务完成(commit/rollback)时触发的事件
Eventsinstance()fireOnTransactionCompletion(eventNameargarg)
//下面是监听事件的方式
//在任意application scope的bean中在方法上加@Observer注解同时保证参数列表和发布事件时的参数列表相同
@Observer(eventName)
public void someEventListener(A argB arg){
//
}
//以上代码针对的是Eventsinstance()fireXx方式发布的事件如果要监听spring方式发布的事件可以这么写
@Observer(type=ContextRefreshedEventclass)
public void initAll(ContextRefreshedEvent event){
//注意参数只能是一个spring的event
}
采用如上的方式发布监听事件免去了eventPublisher之类的东西也免去了event类型的定义用起来还是比较舒服的
实现起来也很简单系统启动的时候扫描一遍标记了Observer注解的方法记录一下然后在事件触发的时候做相应的处理即可其中异步事件使用了一个TaskExecutor来完成触发比较实用的和事务相关的两种事件促发方式使用了spring提供的TransactionSynchronizationManager这个类的静态方法registerSynchronization实现起来也很简单
附件放上相关的几个类其中可能还有些不完善的地方大伙儿可以看看