Java兩大工具庫Commons和Guava使用示例詳解

更新時(shí)間：2023年02月07日 16:39:46 作者：湘王

這篇文章主要為大家介紹了Java兩大工具庫Commons和Guava使用示例詳解，有需要的朋友可以借鑒參考下，希望能夠有所幫助，祝大家多多進(jìn)步，早日升職加薪

正文

除了操作集合、限流和緩存，Guava還有另一個(gè)隱秘的功能：事件總線EventBus機(jī)制——是發(fā)布-訂閱模式的實(shí)現(xiàn)，不需要顯式地注冊回調(diào)——比觀察者模式更靈活。

EventBus是在單體架構(gòu)內(nèi)實(shí)現(xiàn)松耦合的一種很好的手段，通過它可以實(shí)現(xiàn)與業(yè)務(wù)邏輯無關(guān)的事件監(jiān)聽和消費(fèi)。Guava提供的事件總線EventBus分為兩種：

1、同步事件EventBus，主要用于單線程環(huán)境；
2、異步事件AsyncEventBus，主要用于多線程環(huán)境。

可以稍稍回顧一下觀察者模式。

在支付系統(tǒng)的設(shè)計(jì)模式中，當(dāng)完成交易后，需要給用戶發(fā)送通知時(shí)就使用到了觀察者模式，怎么做的呢？

1、定義賬戶觀察者接口及其子接口支付觀察者和積分觀察者；
2、支付抽象類實(shí)現(xiàn)這兩個(gè)子接口，具體支付類阿里支付、微信支付和余額支付，也都分別實(shí)現(xiàn)這兩個(gè)子接口；
3、在賬戶類中加入觀察者接口列表，并增加注冊、刪除和調(diào)用觀察者接口的方法；
4、在支付時(shí)將各類支付方式注冊到賬戶的觀察者列表中；
5、在交易完成后，就可以調(diào)用賬戶的調(diào)用觀察者接口的方法，實(shí)現(xiàn)回調(diào)。

觀察者模式的實(shí)現(xiàn)稍嫌麻煩。

既然用觀察者模式實(shí)現(xiàn)比較麻煩，那不妨換個(gè)思路，用Guava EventBus來實(shí)現(xiàn)，而且無需繼承任何接口。調(diào)用、發(fā)送回調(diào)通知同樣也很簡單，用EventBus把支付回調(diào)再來實(shí)現(xiàn)一遍。

先定義觀察者

/**
 * 支付寶觀察者
 *
 * @author 湘王
 */
public class AliPayObserver {
    // 標(biāo)記當(dāng)前訂閱者是線程安全的，支持并發(fā)接收消息
    @AllowConcurrentEvents
    @Subscribe
    public void pay(Account account) {
        if (account.getName().equalsIgnoreCase("ALI")) {
            System.out.println("支付寶 >>>>>> 已付款");
            System.out.println(account.getMessage());
        }
    }
}

/**
 * 微信支付觀察者
 *
 * @author 湘王
 */
public class WeixinObserver {
    // 標(biāo)記當(dāng)前訂閱者是線程安全的，支持并發(fā)接收消息
    @AllowConcurrentEvents
    @Subscribe
    public void pay(Account account) {
        if (account.getName().equalsIgnoreCase("WEIXIN")) {
            System.out.println("微信 >>>>>> 已付款");
            System.out.println(account.getMessage());
        }
    }
}

/**
 * 余額支付觀察者
 *
 * @author 湘王
 */
public class YuePayObserver {
    // 標(biāo)記當(dāng)前訂閱者是線程安全的，支持并發(fā)接收消息
    @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();
    }
}

最后實(shí)現(xiàn)事件總線

/**
 * 事件總線
 *
 * @author 湘王
 */
public class EventBusTest {
    // 回調(diào)通知
    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();
    }
}

運(yùn)行main方法，可以看到，盡管沒有顯式聲明觀察者接口，但通過一個(gè)@Subscribe注解，就完成了方法回調(diào)。這就是EventBus比觀察者模式要靈活強(qiáng)大的地方。

如果還不滿足，那就再來一個(gè)例子。

創(chuàng)建觀察者接口和具體觀察者

/**
 * 做家務(wù)的接口
 *
 * @author 湘王
 */
public interface HouseWork {
    public void dry();
}

/**
 * 女主人（具體做家務(wù)的人）
 *
 * @author 湘王
 */
public class Woman implements HouseWork {
    @Override
    public void dry() {
        System.out.println("可以晾衣服了");
    }
}

創(chuàng)建Subject：

/**
 * 洗衣機(jī)（Subject類）
 *
 * @author 湘王
 */
public class WashingMachine {
    private Vector&lt;HouseWork&gt; vector = new Vector&lt;&gt;();
    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 {
        // 洗衣機(jī)
        WashingMachine machine = new WashingMachine();
        // 女主人
        Woman woman = new Woman();
        // 洗衣機(jī)讓女主人成為自己的觀察者
        machine.register(woman);
        System.out.println("將衣服放到洗衣機(jī)。。。");
        System.out.println("買菜、遛娃中。。。");
        Thread.sleep(3000);
        // 通知觀察者（女主人），衣服洗完了
        machine.notifyObserver();
    }
}

用EventBus把剛才家庭婦女做家務(wù)的例子再來做一遍（現(xiàn)在換成家庭婦男）：

/**
 * 具體觀察者
 *
 * @author 湘王
 */
public class Man {
    @Subscribe
    public void dry(Sheet sheet) {
        System.out.println("可以晾 " + sheet.getName() + " 床單了");
    }
}

/**
 * 事件總線
 *
 * @author 湘王
 */
public class EventBusTest {
    // 回調(diào)通知
    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();
    }
}

/**
 * 床單實(shí)體類
 *
 * @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;
    }
}

運(yùn)行main方法，可以看到和之前一樣的效果。事件總線的一個(gè)缺點(diǎn)是，回調(diào)接口必須有參數(shù)——這并不友好。

以上就是Java兩大工具庫Commons和Guava使用示例詳解的詳細(xì)內(nèi)容，更多關(guān)于Java工具庫Commons Guava的資料請(qǐng)關(guān)注腳本之家其它相關(guān)文章！

您可能感興趣的文章: