EventBus允许在组件之间进行发布-订阅式的通信,而不需要组件之间显式地进行注册(从而相互了解)。它的设计完全是为了用显式注册代替传统的Java进程内事件分布。它不是通用的发布-订阅系统,也不是用于进程间通信的。
EventBus对象的创建
通过EventBus.register(Object object)方法来注册订阅者(subscriber ),使用EventBus.post(Object event)方法来发布事件。
@Test
public void test1() {
//创建EventBus对象,并给予identifier
//identifier:此总线的简短名称,用于日志记录。应该是一个有效的java标识符。
EventBus eventBus = new EventBus("choxsu");
//注册所有的订阅
eventBus.register(new HelloEventListener());
//eventBus.register(new Hello2EventListener());
//发布事件
eventBus.post(new OrderEvent("hello"));
eventBus.post(new OrderEvent("world"));
eventBus.post("hello world");
eventBus.post("hello world2");
eventBus.post(1);
eventBus.post(12);
}
(订阅)Listener类的定义,具体实现见代码
使用Guava之后发布-订阅模式就变得很简单了,如果你需要订阅某种类型的消息,只需要在指定的方法上加上@Subscribe注解即可。
1.一个subscriber也可以同时订阅多个事件,Guava会通过事件类型来和订阅方法的形参来决定到底调用subscriber的哪个订阅方法
EventBus post OrderEvent类型事件时,Hello2EventListener 的listen(OrderEvent event)方法会被调用,当post String类型事件时,Hello2EventListener 的listen(String event) 会被调用。
class HelloEventListener {
@Subscribe
public void listen(OrderEvent event) {
System.out.println("receive1 msg:" + event.getMessage());
}
@Subscribe
public void listen(String event) {
System.out.println("receive2 msg:" + event);
}
@Subscribe
public void listen(Integer event) {
System.out.println("receive3 msg:" + event);
}
}
2.如果多个subscriber订阅了同一个事件,那么每个subscriber都将收到事件通知,并且收到事件通知的顺序跟注册的顺序保持一致
class Hello2EventListener {
@Subscribe
public void listen(OrderEvent event) {
System.out.println("hello2 receive2 msg:" + event.getMessage());
}
@Subscribe
public void listen(String event) {
System.out.println("hello2 receive2 msg:" + event);
}
}
//注册所有的订阅
eventBus.register(new HelloEventListener());
eventBus.register(new Hello2EventListener());
HelloEventListener和MultiEventListener都订阅了OrderEvent 事件,所以他们都会收到OrderEvent 事件通知。但是HelloEventListener会第一个收到OrderEvent 事件通知,其次是Hello2EventListener。
自定义Event对象(一个简单POJO)
Guava 发布-订阅模式 中传递的事件,是一个普通的POJO类。
class OrderEvent {
private String message;
public OrderEvent(String message) {
this.message = message;
}
public String getMessage() {
return message;
}
}
输出结果
receive1 msg:hello
hello2 receive2 msg:hello
receive1 msg:world
hello2 receive2 msg:world
receive2 msg:hello world
hello2 receive2 msg:hello world
receive2 msg:hello world2
hello2 receive2 msg:hello world2
receive3 msg:1
receive3 msg:12