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<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方法,可以看到和之前一样的效果。事件总线的一个缺点是,回调接口必须有参数——这并不友好。
相关文章
- 【JavaSE】初识Java--01
- 【Java学习笔记】什么是JNI
- Java集合---HashMap源码剖析
- Java集合类解析 ***
- java 8 新特性 笔记
- 并发编程(十二)—— Java 线程池 实现原理与源码深度解析 之 submit 方法 (二)
- 干货分享!java开发流程图工具
- Java架构笔记:用JWT对SpringCloud进行认证和鉴权
- 推荐一个 Java 实体映射工具 MapStruct
- java keytool证书工具使用小结
- java代码分析及分析工具
- Java线程死锁查看分析方法、工具,怎么检查死锁,死锁的原因是什么?
- Java 基础(Arrays工具类的使用, 数组中的常见异常)
- java-框架-AKKA
- java-maven
- Java性能优化的9大工具
- 转义字符(在hive+shell以及java中注意事项):正则表达式的转义字符为双斜线,split函数解析也是正则
- YourKit Java Profiler 命令行工具自动弹出
- 不错位的java .class 反编译工具推荐
- 安卓AES加密、解密工具类(Kotlin版+Java版)
- Java 并发/多线程教程(十二)-JAVA同步块
- Java 记录(8)http 请求 demo
- LeetCode-168. Excel表列名称(java)
- Java工作利器之常用工具类(三)——字符串工具类-智能截取
- 我的Java开发学习之旅------>工具类:Java使用正则表达式分离出字符串中的中文和英文
- 我的Java开发学习之旅------>工具类:将播放器的进度值转换成相应的时间格式