azeroth-event：轻量级事件驱动插件
azeroth-event
轻量级事件驱动插件
内部使用的事件插件, 用于业务解耦以及事件分发。
结构图
使用
// 插件配置
// 初始化插件
EventBus plugin = new EventBus();
// 全局开启异步,默认不开启的话即同步阻塞处理
plugin.async(1024, 8);
// 扫描包含有@Listener注解方法的类。2:实现ApplicationEventListener接口
// 设置扫描jar包包括引入的第三方jar包，默认不扫描
plugin.scanJar();
// 设置默认扫描的包命，默认全扫描
plugin.scanPackage("com.github.edagarli.eventbus.listener");
// 启动插件
plugin.start();
// 事件驱动
// 发送第一个消息
plugin.publish("123", new EventSource("test"));
// 发送第二个消息
plugin.publish("123", new EventSource("test111111"));
// 发送带tag的消息
// 事件驱动一对多 发布一个事件触发多个事件处理
// 相同tag 共存多个事件 提供优先级处理 priority的值越小,优先权重越大
plugin.publish("test", new EventSource("123123"));
Awaitility.await().atMost(2, TimeUnit.MINUTES).until(new Callable<Boolean>() {
@Override
public Boolean call() throws Exception {
return eventBus.stop();
}
});
maven仓库~
<dependency> <groupId>com.github.edagarli</groupId> <artifactId>azeroth-event</artifactId> <version>1.0.0</version> </dependency>
更新说明
TODO
- 最终一致性(考虑sql持久化,增加重试机制)
- 支持el动态表达式
- 代码重构，职责更细分清晰，方便扩展
2019-01-12 v1.0.0
- 支持并发,加速服务处理效率,事件发布和异步处理能力(disruptor)
- 项目内服务解耦 观察者和发布者互不干涉
- 模仿spring事件驱动模型 一对多即发布一个事件触发多个事件处理
- 增加多个监听器优先处理权 异步处理的情况下保证提交次序,不能保证执行完成的次序
- 异步队列支持优雅停机保证内存Channel的可靠性
- 增加阀值,异步模式下 ringbuffer超过阀值 自动切回同步 恢复正常再次切换成异步模式
参考
模仿的Spring中的消息事件： 详解Spring事件驱动模型
结合Disruptor异步处理框架： 详情Disruptor异步处理框架
正文到此结束
热门推荐
相关文章
Loading...
![[HBLOG]公众号](https://www.liuhaihua.cn/img/qrcode_gzh.jpg)
