Java兩大工具庫:Commons和Guava(6)
您好,我是湘王,這是我的掘金小站,歡迎您來,歡迎您再來~
除了操作集合、限流和快取,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
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方法,可以看到和之前一樣的效果。事件匯流排的一個缺點是,回撥介面必須有引數——這並不友好。
感謝您的大駕光臨!諮詢技術、產品、運營和管理相關問題,請關注後留言。歡迎騷擾,不勝榮幸~