Guava系列之EventBus

小咪咪 2023-02-20 02:18 76阅读 0赞

EventBus是Guava中实现的用于发布/订阅模式的事件处理组件，它是设计模式中观察者模式的优雅实现，关于观察者模式可以看一下我的另一篇博客：[设计模式学习-观察者模式][-]

EventBus简化了观察者模式，无须创建复杂的类和接口层次结构

#### EventBus的基本用法 ####

**1、定义事件对象**

public class Event { 
        private String message;
        public Event(String message){ 
            this.message = message;
        }
    
        public String getMessage() { 
            return message;
        }
    }

**2、定义事件监听**

public class EventListener { 
    
        @Subscribe
        public void listener(Event event){ 
            System.out.println("Subscribe 接收消息:" + event.getMessage());
        }
    
    }

**3、注册监听到EventBus,并测试消息发送**

public class MessageEventDemo { 
        public static void main(String[] args){ 
            EventBus eventBus = new EventBus("test");
            //注册监听到eventBus
            eventBus.register(new EventListener());
            //通过eventBus发送两笔消息
            eventBus.post(new Event("send message1"));
            eventBus.post(new Event("send message2"));
        }
    }

运行结果：

Subscribe 接收消息:send message1
    Subscribe 接收消息:send message2

可以看到用EventBus实现这种发布/订阅模式的事件处理是非常简单的

#### 多种类型的事件监听 ####

**1、定义两种类型的事件对象**

public class EventA { 
        private String message;
        public EventA(String message){ 
            this.message = message;
        }
    
        public String getMessage() { 
            return message;
        }
    }
    
    
    public class EventB { 
        private String message;
        public EventB(String message){ 
            this.message = message;
        }
    
        public String getMessage() { 
            return message;
        }
    }

**2、定义事件监听**

public class MultipleEventListener { 
    
        @Subscribe
        public void listenerEventA(EventA eventA){ 
            System.out.println("subscribe EventA:" + eventA.getMessage());
        }
    
        @Subscribe
        public void listenerEventB(EventB eventB){ 
            System.out.println("subscribe EventB:" + eventB.getMessage());
        }
    }

3、注册监听并测试结果

public class EventTest { 
        public static void main(String[] args){ 
            EventBus eventBus = new EventBus("testMultiple");
            //注册监听
            eventBus.register(new MultipleEventListener());
            //发送不同类型的事件
            eventBus.post(new EventA("EventA Message"));
            eventBus.post(new EventB("EventB Message"));
        }
    }

运行结果：

subscribe EventA:EventA Message
    subscribe EventB:EventB Message

从运行结果可以看出来，EventBus在多种类型的事件中，会根据事件类型来区分，把对应的事件发送给相应的订阅者

#### DeadEvent ####

现在假设我们把事件监听改一下，把EventB的监听注释掉，加入一个DeadEvent的监听

public class MultipleEventListener { 
    
        @Subscribe
        public void listenerEventA(EventA eventA){ 
            System.out.println("subscribe EventA:" + eventA.getMessage());
        }
    
    // @Subscribe
    // public void listenerEventB(EventB eventB){ 
    // System.out.println("subscribe EventB:" + eventB.getMessage());
    // }
    
        @Subscribe
        public void listenerDeadEvent(DeadEvent deadEvent){ 
            System.out.println("deadEvent:" + deadEvent.getEvent());
        }
    }

继续运行上面的EventTest，可以得到如下结果：

subscribe EventA:EventA Message
    deadEvent:org.kxg.guava.eventBus.multiple.EventB@2a18f23c

可以看到EventA可以正常发送到订阅者，EventB没有订阅者，会把消息发给DeadEvent

**DeadEvent就是用来接收这种没有订阅者的消息**

> 如果感觉对你有些帮忙，请收藏好，你的关注和点赞是对我最大的鼓励！  
> 如果想跟我一起学习，坚信技术改变世界，请关注Java天堂公众号，我会定期分享自己的学习成果，第一时间推送给您

![在这里插入图片描述][20200528221140804.jpg_pic_center_pic_center_pic_center_pic_center_pic_center_pic_center_pic_center]

[-]: https://blog.csdn.net/pzjtian/article/details/80101668
[20200528221140804.jpg_pic_center_pic_center_pic_center_pic_center_pic_center_pic_center_pic_center]: https://img-blog.csdnimg.cn/20200528221140804.jpg#pic_center#pic_center#pic_center#pic_center#pic_center#pic_center#pic_center