使用EventBus实现组件间异步
1. 背景
最近新换了工作，刚来比较轻松，所以想自己写几个小工具提升下自己的效率。在开发过程中发现组件的一些通讯问题，如果采用异步的方式，效率能得到很大提升，所以决定使用到EventBus（消息总线）技术，达到异步事件处理的目的。
2. EventBus
EventBus是事件总线，事件发送者会将消息发送到总线上，事件订阅者向事件总线订阅和接受事件并进行处理。订阅者不只是可以订阅消息，它同样也可以是消息发送者。
3. 实现方式
3.1 Guava EventBus
Guava EventBus 提供了一个发布-订阅事件机制，该机制允许对象通过观察者模式相互通信，Guava工具中提供的EventBus提供同步和异步两种方式。下面分别看下如何实现。
3.1.1 同步总线（以下代码为代码片段，请酌情使用）
// 创建一个EventBus对象
EventBus logEventBus = new EventBus("log");
EventBus commandEventBus = new EventBus("command");
// 定义两消息类型
@Data
public class EventMessage {
/**
* 消息ID
*/
protected String messageId = UUID.randomUUID().toString();
/**
* 消息生成时间
*/
protected LocalDateTime last = LocalDateTime.now();
}
@Data
@ToString
public class CommandMessage extends EventMessage {
/**
* 作用平台
*/
private PlatformEnum platform;
/**
* 命令类型
*/
private int commandType;
/**
* 命令
*/
private String command;
}
@Data
@ToString
public class LogMessage extends EventMessage {
/**
* 日志内容
*/
private String content;
}
// 定义一个listener类
public class EventListener {
@Subscribe
public void listenLogEvent(LogMessage logMessage) {
System.out.println("EventListener#listenLogEvent ->" + logMessage);
}
@Subscribe
public void listenCommandEvent(CommandMessage commandMessage) {
System.out.println("EventListener#listenCommandEvent ->" + commandMessage);
}
}
// 绑定总线并发送消息
LogMessage logMessage = new LogMessage();
logMessage.setContent("我是一个日志消息");
logEventBus.post(logMessage);
CommandMessage commandMessage = new CommandMessage();
commandMessage.setCommand("ipconfig");
commandMessage.setCommandType(1);
commandMessage.setPlatform(PlatformEnum.WINDOWS);
commandEventBus.post(commandMessage);
// 打印结果
EventListener#listenLogEvent ->LogMessage(content=我是一个日志消息)
EventListener#listenCommandEvent ->CommandMessage(platform=WINDOWS, commandType=1, command=ipconfig)
3.1.2 异步总线（以下代码为代码片段，请酌情使用）
3.1.3 异常处理
// 创建一个EventBus对象
AsyncEventBus logEventBus = new AsyncEventBus("log");
AsyncEventBus commandEventBus = new AsyncEventBus("command");
// 其余代码同同步代码片段，省略...
// 可在创建EventBus时创建一个捕获异常的handler
EventBus eventBus = new EventBus((exception, context) -> {
System.out.println(exception.getCause());
});