guava 中 EventBus学习（观察者模式的封装）

喜欢ヅ旅行 2022-12-14 13:39 129阅读 0赞

## 前言 ##

在传统的23中设计模式中的代理模式，我们自己手动实现需要定义一系列的骨架，比如自己的Observer接口，一些其他的接口等，由于观察者模式算是一种较为常见的设计模式，所以google为我们再度封装了这种设计模式，使得我们开箱即用，且更为灵活，让我们来仔细学习一下google中的 EventBus

## EventBus ##

EventBus 在被称为事件，类似于观察者模式中的发布版的概念，就是发布消息EventBus 消息通知通常有两种模式，同步阻塞和异步非阻塞

// 同步阻塞
            EventBus eventBus = new EventBus("test");
            // 异步非阻塞
            EventBus asyncEventBus = new AsyncEventBus(Executors.newFixedThreadPool(20));

创建方式如上  
我们基于上面的同步阻塞来实现一个简单的demo，以便我们更好的理解

## 定义消息接收者 ##

首先我们需要定义两个消息接收者 EventListener 和 EventListener1 两个类的代码基本一样，只是为了区分是不同的消息接受者

*  EventListener

public class EventListener { 
    
        public int lastMessage = 0;
    
        @Subscribe
        public void listen(TestEvent event) { 
            lastMessage = event.getMessage();
            // 业务逻辑处理
            System.out.println("listener 接收到消息:"+lastMessage);
        }
    
        public int getLastMessage() { 
            return lastMessage;
        }
    }

*  EventListener1

public class EventListener1 { 
    
        public int lastMessage = 0;
    
        @Subscribe
        public void listen(TestEvent1 event) { 
            lastMessage = event.getMessage();
            System.out.println("listener1 接收到消息::"+lastMessage);
        }
    
        public int getLastMessage() { 
            return lastMessage;
        }
    }

> EventBus 通过 @Subscribe 来表名某个函数能接受哪种消息类型，比如EventListener 会自动接受TestEvent ，而EventListener1也会自动接受TestEvent1

## 定义两个消息 ##

这里为了区分两个不同的消息也定义了两个类似的消息 TestEvent 和 TestEvent1

*  TestEvent

public class TestEvent { 
    
        private final int message;
        public TestEvent(int message) { 
            this.message = message;
            System.out.println("event 发送消息:" + message);
        }
        public int getMessage() { 
            return message;
        }
    }

*  TestEvent1

public class TestEvent1 { 
    
        private final int message;
        public TestEvent1(int message) { 
            this.message = message;
            System.out.println("event1 发送消息:" + message);
        }
        public int getMessage() { 
            return message;
        }
    }

## 定义 EventBus ##

消息和消息接受者都定义完成后，我们需要定义我们的主体即 EventBus，其中 EventBus核心的几个函数就是这三个

//注册观察者
    public void register(Object object) { 
            this.subscribers.register(object);
        }
    //删除观察者
    public void unregister(Object object) { 
            this.subscribers.unregister(object);
        }
    //发送消息
    public void post(Object event) { 
            Iterator<Subscriber> eventSubscribers = this.subscribers.getSubscribers(event);
            if (eventSubscribers.hasNext()) { 
                this.dispatcher.dispatch(event, eventSubscribers);
            } else if (!(event instanceof DeadEvent)) { 
                this.post(new DeadEvent(this, event));
            }
    
        }

这里我们建立一个 TestEventBus来做测试

public class TestEventBus { 
    
        public static void main(String[] args) { 
            /** * 事件 我们无需要像传统观察者模式定义Observer接口 * 任意对象都可以注册到 EventBus 中 */
            // 同步阻塞
            EventBus eventBus = new EventBus("test");
            // 异步非阻塞
    // EventBus asyncEventBus = new AsyncEventBus(Executors.newFixedThreadPool(20));
            EventListener listener = new EventListener();
            EventListener1 listener1 = new EventListener1();
    
            // 注册观察者
            eventBus.register(listener);
            eventBus.register(listener1);
            //删除观察者
    // eventBus.unregister(listener);
    
            // 给观察者发送消息 这里发送的观察者为匹配的观察者，而不是传统所有观察者
            // 发送对象为 post 参数中 event 父类
            eventBus.post(new TestEvent(200));
            eventBus.post(new TestEvent1(300));
    
            System.out.println("listener外部手动获取消息:"+listener.getLastMessage());
            System.out.println("listener1外部手动获取消息:"+listener1.getLastMessage());
    
        }
    }

## 测试 ##

![在这里插入图片描述][20201013222639842.png]

可以看到结果符合我们的预期，使用 EventBus可以很容易让我们实现一个灵活度非常高的观察者模式，虽然jdk自带对观察者模式模式做了封装，但是很明显还是没有guava中的EventBus方便

[20201013222639842.png]: /images/20221123/1f171b5857fe435aa70d8c59978475c0.png