1.原理
核心思想是基于发布/订阅模式,用一个共享的数据结构来管理事件和事件监听器。主要功能包括事件订阅、取消订阅、发布事件等功能。
实现思路
- 定义事件和监听器接口:首先定义一个
Event
类和一个 EventListener
接口,所有事件和监听器都继承自它们。
- 管理订阅关系:使用
Map<Class<? extends Event>, List<EventListener<?>>>
来存储事件类型与监听器的关系。
- 发布事件:通过指定事件类型查找所有订阅的监听器,并调用监听器的处理方法。
2.代码工程
Step 1: 定义基础的事件和监听器接口
package com.et;
// event listen interface
public interface EventListener<T extends Event> {
void onEvent(T event);
}
Step 2: 实现 EventBus 类
Step 3: 定义自定义事件和监听器
package com.et;
public class UserLoginListener implements EventListener<UserLoginEvent> {
@Override
public void onEvent(UserLoginEvent event) {
System.out.println("User logged in: " + event.getUsername());
}
}
代码解释
register
方法:将监听器与事件类型绑定。
post
方法:发布事件,找到所有订阅该事件的监听器并通知它们。
unregister
方法:从事件类型的监听器列表中移除指定监听器。
优化建议
- 异步处理:可以使用线程池异步发布事件,提高性能。
- 过滤器机制:支持对事件的过滤,以便监听器只接收满足条件的事件。
- 事件优先级:可以为监听器定义优先级,根据优先级顺序处理。
这种简单的 EventBus 实现适合单进程内的轻量事件传递。如果需要更复杂的功能(如分布式支持、持久化消息),则可以使用成熟的消息代理系统,如 RabbitMQ 或 Kafka。
3.测试
package com.et;
public class EventBusTest {
public static void main(String[] args) {
EventBus eventBus = new EventBus();
// register
UserLoginListener userLoginListener = new UserLoginListener();
eventBus.register(UserLoginEvent.class, userLoginListener);
// publish
UserLoginEvent loginEvent = new UserLoginEvent("Alice");
eventBus.post(loginEvent);
// unregister
eventBus.unregister(UserLoginEvent.class, userLoginListener);
eventBus.post(new UserLoginEvent("Bob")); // don't take effort,because the event is unregister
}
}
运行代码,返回结果
User logged in: Alice