一、原理

1、介绍

        监听器是基于事件驱动的，用于对操作事件进行监听，当监听到有操作事件的时候进行的逻辑处理，是观察者设计模式的应用。

2、监听器三元素

• 事件源：事件发生的源头。比如Zookeeper
• 事件：对事件进行抽象、封装
• 监听器：用于监听事件源，当事件发生时进行处理

3、监听器本质

首先：监听器像服务端的事件源注册一个对某种事件源的监听

然后：生产者通过事件源产生一个事件

再然后：服务端事件源根据本地注册的监听器逐个去调用监听器，这个监听器可以是远程，也可以是本地，远程监听器一般是需要注册Ip地址

最后：监听器收到事件源的调用之后开始进行自己的逻辑处理。

伪代码如下：

//事件源对象一般是服务端维护，联动生产者和监听者
EventSource eventSource=new EventSource();//事件源一般是单例，生产者（产生事件的端）和消费者（监听器，即监听产生的事件）共用//消费者像服务端注册一个监听器
EventListenerHandler addEventListenerHandler=new AddEventListenerHandler();
eventSource.registryEventListenerHandler(addEventListenerHandler);//生产者生产一个事件
eventSource.addCar();
eventSource.addCar();

二、观察者模式应用场景

观察者模式最典型的应用就是消息的发布订阅模式，生产者与消费者模式，监听的应用等。

应用案例：

1、各种消息队列。如Kafka，ActiveMQ，RocketMQ等

2、Zookeeper的watcher等，这个场景有很多，下面列举一些：

• 分布式锁。如多个操作操作排序等待操作某条数据。观察者模式表现在：
  • 事件监听器：等待操作的客户端，会注册一个watcher
  • 事件源：前面的临时Znode的操作事件，比如删除
  • 事件：即删除事件
• 分布式系统选主过程
• HBase的Master节点通过zookeeper监听各个regionserver的健康状况

3、服务注册与发现。客户端监听注册中心是否有服务变更，如果有变更需要实时的更新到本地。

参考：

Java监听器原理及实例