详解Guava中EventBus的使用_开发_开发者_运维开发者技术经验分享

Guava EventBus

EventBus是Guava的事件处理机制，是设计模式中观察者模式（生产/消费者编程模型）的优雅实现。对于事件监听和发布订阅模式，EventBus使用非常简单便捷。

详解Guava中EventBus的使用

如果你做过CS的开发，下面这段代码可能会比较熟悉。

Buttonbutton=newButton("确定");

button.addListener(newListener(){
...
publicvoidonClick(Eventevent){
//
}
...
});

为按钮注册事件监听，当按钮被点击时，则触发监听中相应的回调。在上面的代码中，有三个角色事件（Event），事件源（Button），监听（Listener），按钮作为事件源，当点击行为触发时，会将该行为封装成对应的点击事件，并根据行为类型将事件传递到响应的监听器上，这也就是我们常说的监听器模式。

使用场景

实现消息生产者与消费者间的解耦，对应事件源与监听器，而消息则是事件

通过事件驱动业务流程扭转，通过异步执行机制实现代码非阻塞执行

扩展主线外的分支业务，减少代码的侵入，比如各个环节的消息通知、短信提醒等

实现消息广播到不同的模块中

示例

订单支付时的消息发送

//商品
publicclassProductOrder{
privateStringuser;//用户
pjehOthyQurivateStringproduct;//商品
privatedoubleamount;//金额
@Override
publicStringtoString(){
returnString.format("用户：%s购买了商品：%s，总金额：%s",user,product,amount);
}
}
//事件
@Data
@AllArgsConstructor
publicstaticclassCreateOrderEventimplementsOrderEvent{
privateProductOrderorder;
}
//监听
publicstaticclassCreateOphprderListener{
@Subscribe
publicvoidonEvent(CreateOrderEventevent){
log.info("创建订单:{}",event.getOrder());
}
}

测试: 我们可以定义各种事件，比如订单创建、订单取消、订单支付... 只需要简单js的三个步骤即可：

//1.创建事件总线
EventBuseventBus=newEventBus(ProductOrder.class.getName());
//2.注册事件监听
eventBus.r开发者_C开发egister(newCreateOrderListener());
eventBus.register(newpayOrderListener());
eventBus.register(newCancelOrderListener());
eventBus.register(newRenewOrderListe编程ner());
//3.发送事件通知
eventBus.post(newProductOrder.CreateOrderEvent(order));
TimeUnit.SECONDS.sleep(1);
eventBus.post(newProductOrder.CancelOrderEvent(order));
TimeUnit.SECONDS.sleep(1);
eventBus.post(newProductOrder.RenewOrderEvent(order));
TimeUnit.SECONDS.sleep(1);
eventBus.post(newProductOrder.PayOrderEvent(order));
TimeUnit.SECONDS.sleep(5);
eventBus.post(newProductOrder.ReturnOrderEvent(order));

同时我们可python以通过AsyncEventBus建立事件异步总线，这样在事件被触发时，可以异步通知监听者完成事件回调，以此来提高响应速度。

核心

EventBus

事件总线，可以理解为事件与监听器的上下文，主要实现事件的注册、事件的分发、以及监听器的回调，主要提供的方法包括：

register 注册监听，将监听器注册到事件总线，通过注解@Subscribe通知其监听的事件类型（第一个方法参数类型）
unregister 卸载监听，从事件总线移除监听
post 发送事件通知，根据post事件类型，找到所有订阅了该类型事件的监听器，并将事件推送到监听器对应的监听方法

Subscribe

通过@Subscribe标识监听器所关注的事件类型

Event

可以是任何对象，当然不建议将基础类型或String作为事件类型，这样就没法做到按类型区分了

详解Guava中EventBus的使用

通过上面的图就可以很清楚各个各个组件的职责，以及如何通过事件总线完成事件向监听的传播，最终基于事件回调机制完成消息传递。基于事件驱动的服务模型

上面这种结构的图形是不是在很多位置都见过，这是一种经典的设计模式。试想一下，我们不通过事件驱动行为时，一般你们怎么写代码，通过ifelse？或者其他有着异曲同工的实现方法，目的最后都是一样。基于Guava提供的工具，我们不仅在使用时只需要简单的三个步骤就能实现，同样，当需要屏蔽该功能时只需要去掉register一行即可，对整体功能也没有任何的影响。

在我们引入某种设计模式，某种架构模型时，总的目的都是为了降低代码模块间的耦合度，提升代码整体的可读性，最终让代码能够易于维护性，或者有一定的复用性。