EventBus 深入学习一

EventBus是一个消息总线，以观察者模式实现，用于简化程序的组件、线程通信，可以轻易切换线程、开辟线程; 传统上，Java的进程内事件分发都是通过发布者和订阅者之间的显式注册实现的。设计EventBus就是为了取代这种显示注册方式，使组件间有了更好的解耦。EventBus不是通用型的发布-订阅实现，不适用于进程间通信

序

开始之前，我们可以先想一下，什么东西是发布-订阅模型，如果要让我们自己设计一个发布-订阅模型的框架，要怎么处理

举一个小例子，谈一下我的理解

有一个存钱罐，长辈向里面放钱（1毛，5毛，1元，5元，10元，20元，50元，100元）， 晚辈从里面取钱；与现实有点不同的是，每个长辈只能投相同面额的钱，晚辈只能获取相同面额的钱假设小红，小明，小刚三个人是取10元钱的，现在张三放了10元钱， 然后主动把这10元钱给这三个人，不管他们去干嘛（与现实不同的是，张三只防了10元钱，但是小红，小明，小刚都拿到了这10元钱）

接本的业务流程如下：

• 三个角色，发布消息者（长辈），存储消息的管道（存钱罐子），订阅者（晚辈）；
• 发布者将发送消息到消息管道
• 管道则将消息推送给订阅者

设计：

• 发布者： 任何发布消息的人
• 消息管道： 连接发布者和订阅者的桥梁，主要有两个功能，一是接受发布者发布的消息；而是将消息推送给订阅者
  • 维护一个订阅者关系（消息->订阅者）， 因此需要开放给订阅者一个注册的接口
  • 接受发布者发送消息， 因此需要开放给发布者一个发布消息的接口
  • 推送消息给订阅者， （这里调用订阅者提供的消息接受回调方法，实现消息推送）
• 订阅者： 每个订阅者，关注并处理一种消息类型，
  • 想成为一个订阅者，先到消息管道这里注册，（告知消费信息的类型以及接受消息的回调方法）
  • 接受消息的回调方法（即接受消息后执行业务逻辑的主体）



使用

使用非常简单, 创建一个 EventBus 实例, 订阅方，调用 EventBus.register() 方法注册， 消息发布方，调用eventBus.post(event); 来发布消息， 则订阅类中，添加 @subscribe 注解的方法将会接受到这条消息

实例如下：

/** * 发送的消息 */@ToString@Getter@Setterpublic class AuditEvent {    /**     * 审核人     */    private String auditUser;    /**     * 审核记录     */    private String record;    /**     * 审核结果     */    private AuditEventEnum auditResultEnum;    public enum AuditEventEnum {        ACCEPT,        REJECT,        RETRY;    }}

订阅者

/** * 初审 & 复审的监听器 * 
 * Created by yihui on 2017/3/1. */@Componentpublic class AuditEventListener {    private static final Logger logger = LoggerFactory.getLogger(AuditEventListener.class);    /**     * 注册事件     */    @PostConstruct    public void init() {        ActionEventBus.register(this);    }    /**     * 审核完成后,会发送一条消息     * 
     * 1. 通过审核     * 2. 拒绝审核     * 3. 重新审核     * 
     * 根据消息, 做出不同的action     *     * @param args     */    @Subscribe    public void invoke(AuditEvent args) {        if (args.getAuditResultEnum() == AuditEvent.AuditEventEnum.ACCEPT) {            System.out.println(1111);            logger.info("审核通过!!!! {}", args.getRecord());        } else if (args.getAuditResultEnum() == AuditEvent.AuditEventEnum.REJECT) {            System.out.println(2222);            logger.info("审核拒绝!!!! {}", args.getRecord());        } else {            logger.info("重新审核!!!! {}", args.getRecord());        }    }}

EventBus管理工厂

public class ActionEventBus {    private final static EventBus eventBus = new EventBus();    public static void post(Object event) {        eventBus.post(event);    }    public static void register(Object handler) {        eventBus.register(handler);    }    public static void unregister(Object handler) {        eventBus.unregister(handler);    }}

发布消息

@Testpublic void testAudit() {   AuditEvent auditEvent = new AuditEvent();   auditEvent.setAuditResultEnum(AuditEvent.AuditEventEnum.ACCEPT);   auditEvent.setAuditUser("1hui");   auditEvent.setRecord("test1");   // 发布一条成功的消息   ActionEventBus.post(auditEvent);   auditEvent.setAuditResultEnum(AuditEvent.AuditEventEnum.REJECT);   auditEvent.setAuditUser("2hui");   auditEvent.setRecord("test2");   // 发布一条拒绝的消息   ActionEventBus.post(auditEvent);   BuyEvent buyEvent = new BuyEvent();   buyEvent.setBuyerUser("3hui");   buyEvent.setCount(1);   buyEvent.setTotalPrice(10000L);   buyEvent.setItem("java book");   buyEvent.setBuyEventEnum(BuyEventEnum.PAY);   ActionEventBus.post(buyEvent);   System.out.println("over");}

分析

说明，我们先拿google的 Guava中的 EventBus 来作为研究对象； 后续会对比下android平台上使用非常多的greenrobot/EventBus

从上面的使用可以简单的看出EventBus的设计思路基本上还是 消息-订阅的模子，但是设计非常巧妙

从订阅者角度来看，首先是要注册，没什么好说的，关键点就在于接受消息的处理方法上

- 添加一个注解，指定消息接收类型（即参数类型）， 就可以接受这类消息- 基于上面的方法，一个订阅者，可以实现订阅多个不同的消息源

消息发布方来看，直接调用 EventBus.post() 就算是发布消息，使用起来超级简单

其中 EventBus 作为沟通的桥梁，也就是上面我们说的‘储钱罐’， 如果希冀实现异步的消息处理，则直接用AsyncEventBus 即可

从上面的使用来看，极大的简化了使用的流程，简直不能更easy了; 唯一的遗憾是，从上面的描述中，发现使用异步的话，还得改用AsyncEventBus 有点麻烦，如果能直接再 @subscribe 注解中添加个标识，表示是否使用异步消费就完美了

前期准备

在真正进入源码分析之前，我们先做些准备工作，了解下基本的术语和背景

1. 事件监听者(Listeners)

即我们上面的订阅者，最终接受事件，并执行响应的业务逻辑的主体

在EventBus实例上调用EventBus.register(Object)方法注册事件监听者；需要注意的是请保证事件生产者和监听者共享相同的EventBus实例

2. 事件生产者(Producers)

发送事件的主体，通过把事件传递给 EventBus.post(Object)方法。异步分发可以直接用EventBus的子类AsyncEventBus。

3. 术语