您好，我是湘王，這是我的頭條号「湘王說」，歡迎您來，歡迎您再來～
除了操作集合、限流和緩存，Guava還有另一個隐秘的功能：事件總線EventBus機制——是釋出-訂閱模式的實作，不需要顯式地注冊回調——比觀察者模式更靈活。
EventBus是在單體架構内實作松耦合的一種很好的手段，通過它可以實作與業務邏輯無關的事件監聽和消費。Guava提供的事件總線EventBus分為兩種：
1、同步事件EventBus，主要用于單線程環境；
2、異步事件AsyncEventBus，主要用于多線程環境。
可以稍稍回顧一下觀察者模式。
在支付系統的設計模式中，當完成交易後，需要給使用者發送通知時就使用到了觀察者模式，怎麼做的呢？
1、定義賬戶觀察者接口及其子接口支付觀察者和積分觀察者；
2、支付抽象類實作這兩個子接口，具體支付類阿裡支付、微信支付和餘額支付，也都分别實作這兩個子接口；
3、在賬戶類中加入觀察者接口清單，并增加注冊、删除和調用觀察者接口的方法；
4、在支付時将各類支付方式注冊到賬戶的觀察者清單中；
5、在交易完成後，就可以調用賬戶的調用觀察者接口的方法，實作回調。
觀察者模式的實作稍嫌麻煩。
既然用觀察者模式實作比較麻煩，那不妨換個思路，用Guava EventBus來實作，而且無需繼承任何接口。調用、發送回調通知同樣也很簡單，用EventBus把支付回調再來實作一遍。
先定義觀察者：
/**
* 支付寶觀察者
*
* @author 湘王
*/
public class AliPayObserver {
// 标記目前訂閱者是線程安全的，支援并發接收消息
@AllowConcurrentEvents
@Subscribe
public void pay(Account account) {
if (account.getName().equalsIgnoreCase("ALI")) {
System.out.println("支付寶 >>>>>> 已付款");
System.out.println(account.getMessage());
}
}
}
/**
* 微信支付觀察者
*
* @author 湘王
*/
public class WeixinObserver {
// 标記目前訂閱者是線程安全的，支援并發接收消息
@AllowConcurrentEvents
@Subscribe
public void pay(Account account) {
if (account.getName().equalsIgnoreCase("WEIXIN")) {
System.out.println("微信 >>>>>> 已付款");
System.out.println(account.getMessage());
}
}
}
/**
* 餘額支付觀察者
*
* @author 湘王
*/
public class YuePayObserver {
// 标記目前訂閱者是線程安全的，支援并發接收消息
@AllowConcurrentEvents
@Subscribe
public void pay(Account account) {
if (account.getName().equalsIgnoreCase("YUE")) {
System.out.println("餘額 >>>>>> 已付款");
System.out.println(account.getMessage());
}
}
}
然後定義賬戶類：
/**
* 賬戶
*
* @author 湘王
*/
public class Account {
private String name;
private double amount;
private Date date;
public Account(String name, double amount, Date date) {
this.name = name;
this.amount = amount;
this.date = date;
}
public String getName() {
return name;
}
public String getMessage() {
StringBuilder sb = new StringBuilder();
sb.append("賬戶：").append(this.name).append(", ");
sb.append("金額：").append(amount).append(", ");
sb.append("日期：").append(date);
return sb.toString();
}
}
最後實作事件總線：
/**
* 事件總線
*
* @author 湘王
*/
public class EventBusTest {
// 回調通知
public static void notifyObserver() {
EventBus bus = new EventBus();
AliPayObserver ali = new AliPayObserver();
WeixinObserver weixin = new WeixinObserver();
YuePayObserver yue = new YuePayObserver();
bus.register(ali);
bus.register(weixin);
bus.register(yue);
Account account1 = new Account("ALI", 1.6, new Date());
bus.post(account1);
Account account2 = new Account("WEIXIN", 2.2, new Date());
bus.post(account2);
Account account3 = new Account("YUE", 3, new Date());
bus.post(account3);
}
public static void main(String[] args) throws InterruptedException {
notifyObserver();
}
}
運作main方法，可以看到，盡管沒有顯式聲明觀察者接口，但通過一個@Subscribe注解，就完成了方法回調。這就是EventBus比觀察者模式要靈活強大的地方。
如果還不滿足，那就再來一個例子。建立觀察者接口和具體觀察者：
/**
* 做家務的接口
*
* @author 湘王
*/
public interface HouseWork {
public void dry();
}
/**
* 女主人（具體做家務的人）
*
* @author 湘王
*/
public class Woman implements HouseWork {
@Override
public void dry() {
System.out.println("可以晾衣服了");
}
}
建立Subject：
/**
* 洗衣機（Subject類）
*
* @author 湘王
*/
public class WashingMachine {
private Vector<HouseWork> vector = new Vector<>();
public void register(HouseWork work) {
vector.add(work);
}
public void unregister(HouseWork work) {
vector.remove(work);
}
public void notifyObserver() {
for (HouseWork work : vector) {
work.dry();
}
}
public static void main(String[] args) throws InterruptedException {
// 洗衣機
WashingMachine machine = new WashingMachine();
// 女主人
Woman woman = new Woman();
// 洗衣機讓女主人成為自己的觀察者
machine.register(woman);
System.out.println("将衣服放到洗衣機。。。");
System.out.println("買菜、遛娃中。。。");
Thread.sleep(3000);
// 通知觀察者（女主人），衣服洗完了
machine.notifyObserver();
}
}
用EventBus把剛才家庭婦女做家務的例子再來做一遍（現在換成家庭婦男）：
/**
* 具體觀察者
*
* @author 湘王
*/
public class Man {
@Subscribe
public void dry(Sheet sheet) {
System.out.println("可以晾 " + sheet.getName() + " 床單了");
}
}
/**
* 事件總線
*
* @author 湘王
*/
public class EventBusTest {
// 回調通知
public static void notifyObserver() {
EventBus bus = new EventBus();
Man man = new Man();
bus.register(man);
bus.post(new Sheet("富安娜"));
}
public static void main(String[] args) {
notifyObserver();
}
}
/**
* 床單實體類
*
* @author 湘王
*/
public class Sheet {
private String name;
public Sheet(String name) {
this.name = name;
}
public String getName() {
return name;
}
public void setName(String name) {
this.name = name;
}
}
運作main方法，可以看到和之前一樣的效果。事件總線的一個缺點是，回調接口必須有參數——這并不友好。
感謝您的大駕光臨！咨詢技術、産品、營運和管理相關問題，請關注後留言。歡迎騷擾，不勝榮幸～