在任何軟件應用程序中都是如此，有些對象需要共享信息才能完成工作。 在Java應用程序中，實現信息共享的一種方法是擁有事件偵聽器，其唯一目的是在發生所需事件時采取某些措施。 在大多數情況下，此過程有效，并且最有經驗的Java開發人員習慣于編寫實現某些事件偵聽器接口的必需的匿名內部類。 這篇文章是關于使用Guava的EventBus處理Java事件的另一種方法。 EventBus允許對象訂閱或發布事件，而無需彼此明確了解。 EventBus并不旨在成為通用的發布/訂閱系統，也不支持進程間通信。

EventBus類別

EventBus非常靈活，可以用作單例，或者應用程序可以具有多個實例以適應在不同上下文中傳輸事件。 EventBus將按順序分派所有事件，因此，保持事件處理方法的輕量化很重要。 如果需要在事件處理程序中進行更重的處理，則可以使用EventBus的另一種形式，即AsyncEventBus。 AsyncEventBus在功能上是相同的，但是采用ExecutorService作為構造函數參數來允許事件的異步調度。

訂閱活動

對象通過以下步驟預訂事件：

定義一個采用所需事件類型的單個參數的公共方法，并在該方法上放置@Subscribe批注。

通過將對象的實例傳遞給EventBus.register方法來向EventBus注冊。

這是一個簡短的示例，為清楚起見省略了詳細信息：

public class PurchaseSubscriber {@Subscribepublic void handlePurchaseEvent(PurchaseEvent event) {.....}.....EventBus eventBus = new EventBus();PurchaseSubscriber purchaseSubscriber = new PurchaseSubscriber();eventBus.register(purchaseSubscriber);

還有一個可以與@Subscribe結合使用的注釋，即@AllowConcurrentEvents。 @AllowConcurrentEvents將處理程序方法標記為線程安全的，因此EventBus（很可能是AsyncEventBus）可以潛在地從同時線程調用事件處理程序。 我在單元測試中發現的一件有趣的事情是，如果處理程序方法沒有@AllowConcurrentEvents批注，則即使使用AsyncEventBus，它也會按順序調用事件的處理程序。 重要的是要注意，@ AllowConcurrentEvents不會將方法標記為事件處理程序，@ Subscribe批注仍需要存在。 最后，事件處理方法必須具有一個且只有一個參數，否則當您在EventBus中注冊對象時，將拋出IllegalArgumentException。

發布事件

同樣，使用EventBus發布事件也很簡單。 在您要發送事件通知的代碼部分中，調用EventBus.post，將為該事件對象注冊的所有訂閱者進行通知。

public void handleTransaction(){purchaseService.purchase(item,amount);eventBus.post(new CashPurchaseEvent(item,amount));....}

盡管這很明顯，但是訂閱類和發布類共享同一EventBus實例很重要，并且使用Guice或Spring幫助管理依賴項是有意義的。

有關事件處理程序的更多信息

EventBus的一項非常強大的功能是，您可以根據需要使處理程序正常運行或細化。 EventBus將為已發布事件對象的所有子類型和已實現的接口調用注冊的訂戶。 例如，要處理所有事件，可以創建一個帶有Object類型參數的事件處理程序。 要僅處理單個事件，請創建一個特定于類型的處理程序。 為了幫助說明，請考慮以下簡單事件層次結構：

public abstract class PurchaseEvent {String item;public PurchaseEvent(String item){this.item = item;} }public class CashPurchaseEvent extends PurchaseEvent {int amount;public CashPurchaseEvent(String item, int amount){super(item);this.amount = amount;} }public class CreditPurchaseEvent extends PurchaseEvent {int amount;String cardNumber;public CreditPurchaseEvent(String item,int amount, String cardNumber){super(item);this.amount = amount;this.cardNumber = cardNumber;} }

以下是相應的事件處理類：

//Would only be notified of Cash purchase eventspublic class CashPurchaseSubscriber {@Subscribepublic void handleCashPurchase(CashPurchaseEvent event){... }}//Would only be notified of credit purchasespublic class CreditPurchaseSubscriber {@Subscribepublic void handleCreditPurchase(CreditPurchaseEvent event) {....} } //Notified of any purchase eventpublic class PurchaseSubscriber {@Subscribepublic void handlePurchaseEvent(PurchaseEvent event) {.....} }

如果需要捕獲各種各樣的事件類型，則替代方法是在一個類中具有多個事件處理方法。 擁有多個處理程序可能是一個更好的解決方案，因為您不必對事件對象參數進行任何“ instanceof”檢查。 這是我的單元測試中的一個簡單示例：

public class MultiHandlerSubscriber {List<CashPurchaseEvent> cashEvents = new ArrayList<ashPurchaseEvent>();List<CreditPurchaseEvent> creditEvents = new ArrayList<CreditPurchaseEvent>();List<SimpleEvent> simpleEvents = new ArrayList<SimpleEvent>();public MultiHandlerSubscriber(EventBus eventBus){eventBus.register(this);}@Subscribepublic void handleCashEvents(CashPurchaseEvent event){cashEvents.add(event);}@Subscribepublic void handleCreditEvents(CreditPurchaseEvent event){creditEvents.add(event);}@Subscribepublic void handleSimpleEvents(SimpleEvent event){simpleEvents.add(event);} ....

測試中

由于事件處理程序只是普通方法，因此可以通過在測試用例中實例化一個EventBus或通過傳遞適當的事件對象來模擬EventBus來輕松對其進行測試。 當使用EventBus時，我發現很容易：

• 忘記在EventBus中注冊訂閱對象
• 忽略添加@Subscribe批注。

如果似乎未調用事件處理程序，請首先檢查這兩個錯誤。
一種有用的調試技術是訂閱DeadEvent類。 EventBus將在DeadEvent實例中包裝任何沒有處理程序的已發布事件。 DeadEvent提供了getEvent方法，該方法返回原始事件對象。

結論

Guava EventBus類為標準Java事件處理機制提供了一種有吸引力且有用的替代方法。 希望讀者會發現EventBus像我一樣有用。 一如既往地歡迎提出意見和建議。

資源資源

• EventBus API
• 番石榴API
• 樣例代碼
• 活動合作

參考：來自我們的JCG合作伙伴 Bill Bejeck的Google Guava EventBus進行事件編程，來自Random Thoughts On Coding博客。

翻譯自: https://www.javacodegeeks.com/2012/11/google-guava-eventbus-for-event-programming.html

總結

以上是生活随笔為你收集整理的Google Guava EventBus用于事件编程的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。