Nacos中的事件发布与订阅--观察者模式
大概看了下 发布订阅模式的实现，什么鬼额，这不是 guava 的 event bus 的实现嘛？
天下代码一大抄-------------啥哈哈哈---
言归正传
今天要研究的发布订阅代码位于 nacos-config module 目录下：
首先来看：
EventDispatcher
EventDispatcher 是nacos中一个事件发布与订阅的类，也就是我们经常使用的Java 设计模式---事件驱动模式（观察者模式）
一般发布与订阅注意有三个角色：
- 事件：某些类型的事件动作，例如nacos 中的本地数据发生变更事件LocalDataChangeEvent
- 事件源：事件源可以看作一个动作，某个事件发生的动作，例如：nacos中本地数据发生了变更，就会通知给所有该事件的监听器
- 事件监听器：事件监听器听到事件源后，会执行自己的一些业务处理，监听器必须要有回掉方法供事件源回掉
通俗点讲，就是类似于一个分发总线，或者事件分发器，或者事件中转站之类的。
既然是事件分发总线，那么那要具备哪些功能呢？
事件是什么？事件来自哪里？事件分发给谁？
- 注册监听着
- 分发事件
- 清空监听着？（哈哈哈 非必需）
1、 首先，注册的监听对象：
static final CopyOnWriteArrayList<Entry> LISTENER_HUB = new CopyOnWriteArrayList<>();
static public void addEventListener(AbstractEventListener listener) {
for (Class<? extends Event> type : listener.interest()) {
getEntry(type).listeners.addIfAbsent(listener);
}
}
具体容器使用方法，这里不表述，参考之前文章。
其实，这里还有另一种实现思路，MultiValueMap 参考该类的实现，可以替代该容器，可以简单很多
2、发布事件
static public void fireEvent(Event event) {
if (null == event) {
throw new IllegalArgumentException("event is null");
}
for (AbstractEventListener listener : getEntry(event.getClass()).listeners) {
try {
listener.onEvent(event);
} catch (Exception e) {
log.error(e.toString(), e);
}
}
}
下面再来看下 事件监听器
AbstractEventListener
static public abstract class AbstractEventListener {
public AbstractEventListener() {
/**
* automatic register
*/
EventDispatcher.addEventListener(this);
}
/**
* 感兴趣的事件列表
*
* @return event list
*/
abstract public List<Class<? extends Event>> interest();
/**
* 处理事件
*
* @param event event
*/
abstract public void onEvent(Event event);
}
默认实现--注册 Listener的功能。具体感兴趣的事件，交由子类去实现。当监听到感兴趣的事件时，执行什么样的操作也是由子类去实现。
下面我们看一个具体的 listener 实现：
AsynNotifyService.class
简单实现：
//感兴趣的事件
@Override
public List<Class<? extends Event>> interest() {
List<Class<? extends EventDispatcher.Event>> types = new ArrayList<>();
types.add(ConfigDataChangeEvent.class);
return types;
}
//监听时间后处理逻辑
@Override
public void onEvent(Event event) {
System.out.println("i get the event" + event.getClass());
}
下面来看下 事件
//所有事件继承自这个接口
public interface Event {
}
具体可以参考ConfigDataChangeEvent.class 代表了一次变动事件。即配置信息的变更。
下面以一个具体的流程图，来展示下 具体的配置变更过程，具体的代码分析，下一篇章来。
1.png
OK , 这里就写 这么多吧 。下一篇文章要分析下 ，Springboot nacos 配置文件的加载过程吧
网友评论