Google Guava 之 EventBus_综合

文章目录

什么是消息总线？
什么时候使用消息总线？
Google Guava 之 EventBus?
- - EventBus是什么？
  - EventBus的基本用法
  - DeadEvent
- 同步任务和异步任务

什么是消息总线？

消息代理中间件构建一个公用的消息主题让所有微服务实例订阅，当该消息主题产生消息时会被所有的微服务实例监听到和消费。
消息总线就是把所有的微服务实例连接起来。

什么时候使用消息总线？

就是在我们需要把一个操作散发到所有后端相关服务器的时候，就可以使用消息总线了。

Google Guava 之 EventBus?

EventBus是什么？

EventBus是Guava的事件处理机制，是设计模式中的观察者模式（生产/消费者编程模型）的优雅实现，在应用中可以处理一些异步任务。

是于消息发布-订阅类库，EventBus是一个非常优雅和简单解决方案，我们不用创建复杂的类和接口层次结构。

图示如下：
在这里插入图片描述
流程图描述：EventBus实际上是一个消息队列，Event Source发送一个消息到EventBus，然后再由EventBus将消息推送到所监听的Listener。

EventBus的基本用法

1、创建Listener

我们可以通过@Subscribe注解将任意的类中的方法变为一个Listener。

public class SimpleListener {
    private final static Logger LOGGER = LoggerFactory.getLogger(SimpleListener.class);/*** 一个简单的Listener方法* @param event Guava规定此处只能有一个参数*/@Subscribepublic void doAction(final String event){
    if (LOGGER.isInfoEnabled()){
    LOGGER.info("Received event [{}] and will take a action", event);}}
}

2、创建EventBus并发送消息

然后我们可以定义一个EventBus，先将上面的这个Listener类进行注册，通过Post方法即可向其发送消息。

public class SimpleEventBusExample {
    public static void main(String[] args) {
    final EventBus eventBus = new EventBus();//注册ListenereventBus.register(new SimpleListener());System.out.println("post the simple event.");//向订阅者发送消息eventBus.post("Simple Event");}
}

EventBus的基本用法之——Listener之间有继承关系

当两个Listener之间有继承关系时，只注册子类的Listener到EventBus。然后发送向EventBus发送消息，父类Listener也会接收到消息。

EventBus的基本用法之——存在不同类型参数的Subscribe

在一个类中创建多个不同类型参数的监听方法，即 Subscribe。

public class MultipleEventListeners {
    private final static Logger LOGGER = LoggerFactory.getLogger(MultipleEventListeners.class);@Subscribepublic void task1(final String event){
    if (LOGGER.isInfoEnabled()){
    LOGGER.info("Received event [{}] and will take a action by ==task1==", event);}}@Subscribepublic void task2(final String event){
    if (LOGGER.isInfoEnabled()){
    LOGGER.info("Received event [{}] and will take a action by ==task2==", event);}}@Subscribepublic void intTask(final Integer event){
    if (LOGGER.isInfoEnabled()){
    LOGGER.info("Received event [{}] and will take a action by ==intTask==", event);}}
}

定义EventBus：

public class MultipleEventBusExample {
    public static void main(String[] args) {
    final EventBus eventBus = new EventBus();eventBus.register(new MultipleEventListeners());System.out.println("post the string event.");eventBus.post("I am String event");System.out.println("post the int event.");eventBus.post(1000);}
}

Output:
post the string event.
2018-05-20 22:28:23:INFO main com.guava.eventbus.listeners.MultipleEventListeners - Received event [I am String event] and will take a action bytask1
2018-05-20 22:28:23:INFO main com.guava.eventbus.listeners.MultipleEventListeners - Received event [I am String event] and will take a action bytask2
post the int event.
2018-05-20 22:28:23:INFO main com.guava.eventbus.listeners.MultipleEventListeners - Received event [1000] and will take a action by intTask

结论：eventBus会根据Listener的参数类型的不同，分别向不同的Subscribe发送不同的消息。

DeadEvent

当EventBus发布了一个事件，但是注册的订阅者中没有找到处理该事件的方法，那么EventBus就会把该事件包装成一个DeadEvent事件来重新发布；我们在应用中可以提供如下的事件处理方法来处理DeadEvent。

创建listener:

public class DeadEventListener {
    @Subscribepublic void handle(DeadEvent event){
    //获取事件源System.out.println(event.getSource());//DEAD-EVENT-BUS//获取事件System.out.println(event.getEvent());//DeadEventListener event}
}

创建EventBus：

public class DeadEventBusExample {
    public static void main(String[] args) {
    //重写EventBus的toString方法，使eventBus的名称为DEAD-EVENT-BUSfinal EventBus eventBus = new EventBus(){
    @Override public String toString() {
    return "DEAD-EVENT-BUS";}};DeadEventListener deadEventListener = new DeadEventListener();eventBus.register(deadEventListener);eventBus.post("DeadEventListener event");eventBus.post("DeadEventListener event");}
}

Output:
DEAD-EVENT-BUS
DeadEventListener event
DEAD-EVENT-BUS
DeadEventListener event

观察者模式 https://blog.csdn.net/lmj623565791/article/details/24179699

Google Guava 之 EventBus https://blog.csdn.net/wangdong5678999/article/details/80561198

https://blog.csdn.net/wuyuxing24/article/details/95505102

https://blog.csdn.net/zhglance/article/details/54314823?utm_medium=distribute.pc_relevant_t0.none-task-blog-2%7Edefault%7EBlogCommendFromMachineLearnPai2%7Edefault-1.control&dist_request_id=1619590368475_98094&depth_1-utm_source=distribute.pc_relevant_t0.none-task-blog-2%7Edefault%7EBlogCommendFromMachineLearnPai2%7Edefault-1.control

同步任务和异步任务

同步任务：任务之间是有严格的顺序关系的，只有任务A执行完成之后任务B才能执行。否则任务A就会一直处于阻塞状态。任务AB之间是强依赖的关系。

异步任务：在执行任务A时，若需要执行任务B，则不存在严格的执行顺序关系，任务AB可以并发的执行，或者任务B可以延迟执行。

Google Guava 之 EventBus