事件总线
Guava 事件总线(EventBus)是 Google Guava 库中的一个组件,用于实现发布–订阅模式的事件通信。它提供了一种简单而强大的方式,让不同的组件之间能够解耦、相互通信、完成事件处理。
特点
-
通过注册订阅者到事件总线中,订阅者可以接收和处理特定的事件。订阅者需要定义一个或多个事件处理方法,并使用 @Subscribe 注解进行标识。
-
发布事件
-
Guava 事件总线支持异步处理事件,通过使用 AsyncEventBus,可以在发送事件时指定自定义的线程池来处理事件。这样可以避免事件处理影响主线程的性能。
-
可以使用 @Subscribe 注解的 @AllowConcurrentEvents 和 @AllowUserConcurrentEvents 参数来控制事件处理的并发性质。
-
父子事件总线
使用
-
创建事件类:
public class MyEvent { private final String message; public MyEvent(String message) { this.message = message; } public String getMessage() { return message; } }
-
创建订阅者类:
public class MySubscriber { @Subscribe public void handleEvent(MyEvent event) { System.out.println("Received event: " + event.getMessage()); } }
-
注册订阅者并发送事件:
public class Main { public static void main(String[] args) { EventBus eventBus = new EventBus(); // 注册订阅者 MySubscriber subscriber = new MySubscriber(); eventBus.register(subscriber); // 发送事件 for (int i = 0; i < 10; i++) { eventBus.post(new MyEvent("Hello, World!")); } } }
-
public class Main { public static void main(String[] args) { EventBus eventBus = new AsyncEventBus(Executors.newFixedThreadPool(3)); // 注册订阅者 MySubscriber subscriber = new MySubscriber(); eventBus.register(subscriber); // 发送事件 for (int i = 0; i < 10; i++) { eventBus.post(new MyEvent("Hello, World!")); } } }
需要注意的是:Guava 事件总线是单进程的,且只适用于同一个 JVM 内部的组件通信。如果需要跨进程或分布式系统间的事件通信,可以考虑使用其他技术,例如消息队列、消息中间件等。
原文地址:https://blog.csdn.net/JokerLJG/article/details/134613803
本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。
如若转载,请注明出处:http://www.7code.cn/show_36446.html
如若内容造成侵权/违法违规/事实不符,请联系代码007邮箱:suwngjj01@126.com进行投诉反馈,一经查实,立即删除!
声明:本站所有文章,如无特殊说明或标注,均为本站原创发布。任何个人或组织,在未征得本站同意时,禁止复制、盗用、采集、发布本站内容到任何网站、书籍等各类媒体平台。如若本站内容侵犯了原著者的合法权益,可联系我们进行处理。