EventBus实现组件间异步-阿里云开发者社区

EventBus实现组件间异步

2022-04-01 304

版权

本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。

简介： 最近新换了工作，刚来比较轻松，所以想自己写几个小工具提升下自己的效率。在开发过程中发现组件的一些通讯问题，如果采用异步的方式，效率能得到很大提升，所以决定使用到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 异步总线（以下代码为代码片段，请酌情使用）

// 创建一个EventBus对象
AsyncEventBus logEventBus = new AsyncEventBus("log");
AsyncEventBus commandEventBus = new AsyncEventBus("command");
// 其余代码同同步代码片段，省略...

3.1.3 异常处理

// 可在创建EventBus时创建一个捕获异常的handler
EventBus eventBus = new EventBus((exception, context) -> {
   System.out.println(exception.getCause());
});