事件总线 EventBus

前言

EventBus 顾名思义，事件总线，是一个轻量级的 发布 - 订阅 模式的应用模式。相比于 MQ 更加简洁，轻量，它可以在一个小系统模块内部使用

EventBus允许组件之间通过发布 - 订阅进行通信，而不需要组件之间显示的注册。它专门设计为了代替使用显示注册的传统的 Java 进程内事件分发。它不是通用的发布-订阅系统，也不是用于进程间通信的。

EventBus 介绍

EventBus 是 google 的 Guava 库中的一个处理组件间通信的事件总线，它基于发布/订阅模式，实现了多组件之间通信的解耦合，事件产生方和事件消费方实现解耦分离，提升了通信的简洁性。

当一个事件的发生(事件产生方)，需要触发很多事件(事件消费方)的时候，我们通常会在事件产生方中，分别的去调用那些事件消费方，这样往往是很浪费资源。事件的产生方与事件的消费方，产生了极大的耦合，如果我们要改动某一个事件消费方，我们很可能还要改动事件的产生方。

使用场景

在工作中，经常会遇见使用异步的方式来发送事件，或者触发另外一个动作：经常用到的框架是MQ（分布式方式通知）。如果是同一个 jvm 里面通知的话，就可以使用EventBus。由于EventBus使用起来简单、便捷，因此，工作中会经常用到。

事件总线三要素

事件（Event）

事件是EventBus之间相互通信的基本单位，一个Event可以是任何类型。一般会定义特定的事件类，类名以Event作为后缀，里面定义一些变量或者函数等。

发布者（Publisher）

事件发布者，就是发送事件到EventBus事件总线的一方，事件发布者调用Post()方法，将事件发给EventBus。可以在程序的任何地方，调用EventBus的post()方法，发送事件给EventBus。

订阅者（Subscriber）

事件订阅者，就是接收事件的一方，这些订阅者需要在自己的方法上，添加@Subscribe注解声明自己为事件订阅者。不过只声明是不够的，还需要将自己所在的类，注册到EventBus中，EventBus才能扫描到这个订阅者。

EventBusConfig 配置

config

/**
 * @date 2022/7/14 10:45
 * @desc 事件总线配置
 */
@Configuration
public class EventBusConfig {

	@Bean
	public AsyncEventBus asyncEventBus() {
		int corePoolSize = Runtime.getRuntime().availableProcessors();
		int maxPoolSize = 100;
		int keepAliveTime = 60 * 1000;

		BlockingQueue<Runnable> workQueue = new ArrayBlockingQueue<>(5000);
		RejectedExecutionHandler handler = new ThreadPoolExecutor.AbortPolicy();
		ThreadFactory factory = new ThreadFactory() {
			private final AtomicInteger integer = new AtomicInteger(1);

			@Override
			public Thread newThread(@Nonnull Runnable r) {
				return new Thread(r, "TheadPool-Thread-" + integer.getAndIncrement());
			}
		};

		return new AsyncEventBus(new ThreadPoolExecutor(corePoolSize, maxPoolSize, keepAliveTime, TimeUnit.SECONDS, workQueue, factory, handler));
	}

}

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29

Handler

public class xxxEventHandler {
    
    @PostConstruct
    public void init() {
        asyncEventBus.register(xxxListener);
    }
    
    @PreDestroy
    public void destroy() {
        asyncEventBus.unregister(xxxListener);
    }
}
1
2
3
4
5
6
7
8
9
10
11
12

Listener

@Subscribe
public void onMessageEvent(Event event){
    // todo
}
1
2
3
4

post

asyncEventBus.post(event);
1

EventBus 和 AsyncEventBus 区别

EventBus: 同步事件总线

1. 同步执行，事件发送方在发出事件之后，会等待所有的事件消费方执行完毕后，才会回来继续执行自己后面的代码。
2. 事件发送方和事件消费方会在同一个线程中执行，消费方的执行线程取决于发送方。
3. 同一个事件的多个订阅者，在接收到事件的顺序上面有不同。谁先注册到EventBus的，谁先执行，如果是在同一个类中的两个订阅者一起被注册到EventBus的情况，收到事件的顺序跟方法名有关。

AsyncEventBus: 异步事件总线

1. 异步执行，事件发送方异步发出事件，不会等待事件消费方是否收到，直接执行自己后面的代码。
2. 在定义AsyncEventBus时，构造函数中会传入一个线程池。事件消费方收到异步事件时，消费方会从线程池中获取一个新的线程来执行自己的任务。
3. 同一个事件的多个订阅者，它们的注册顺序跟接收到事件的顺序上没有任何联系，都会同时收到事件，并且都是在新的线程中，异步并发的执行自己的任务。