原文地址：Guava库学习：学习Guava EventBus（二）EventBus 事件订阅示例
上一篇Guava库学习：学习Guava EventBus（一）EventBus，我们简单的对Guava基于事件的编程进行了介绍，学习和了解了EventBus类的使用，本篇起，我们通过一系列的示例代码深入的学习EventBus类，本篇学习Guava EventBus（二）EventBus 事件订阅示例。
订阅Subscribe
首先，我们假定定义了如下所示的TradeAccountEvent类，如下：
1public class TradeAccountEvent { 2 private double amount; 3 private Date tradeExecutionTime; 4 private TradeType tradeType; 5 private TradeAccount tradeAccount; 6 public TradeAccountEvent(TradeAccount account, double amount, 7 Date tradeExecutionTime, TradeType tradeType) { 8 checkArgument(amount > 0.0, "Trade can't be less than zero"); 9 this.amount = amount; 10 this.tradeExecutionTime = 11 checkNotNull(tradeExecutionTime, "ExecutionTime can't be null"); 12 this.tradeAccount = checkNotNull(account, "Account can't be null "); 13 this.tradeType = checkNotNull(tradeType, "TradeType can't be null "); 14 } 15 //Details left out for clarity 16}
每当执行买卖交易时，我们都将创建TradeAccountEvent类的一个实例。现在，假定我们有一个需要审计的交易，并且正在执行，所以我们需要有这样一个SimpleTradeAuditor类，如下所示：
1 public class SimpleTradeAuditor { 2 private List<TradeAccountEvent> tradeEvents = 3 Lists.newArrayList(); 4 public SimpleTradeAuditor(EventBus eventBus) { 5 eventBus.register(this); 6 } 7 @Subscribe 8 public void auditTrade(TradeAccountEvent tradeAccountEvent) { 9 tradeEvents.add(tradeAccountEvent); 10 System.out.println("Received trade " + tradeAccountEvent); 11 } 12 }
这里简单的分析一下上面的代码。在SimpleTradeAuditor的构造方法中，我们接收了EventBus类的一个实例，并且通过EventBus立即注册了SimpleTradeAuditor类，来接收TradeAccountEvents类的通知。我们通过在auditTrade方法上添加@Subscribe注解，来指定auditTrade作为事件处理方法。在上面的例子中，我们只是简单的把TradeAccountEvent对象添加到一个list，并简单的输出到控制台。
发布Publishing
首先来看下面的示例代码，代码如下：
1 public class SimpleTradeExecutor { 2 private EventBus eventBus; 3 public SimpleTradeExecutor(EventBus eventBus) { 4 this.eventBus = eventBus; 5 } 6 public void executeTrade(TradeAccount tradeAccount, double 7 amount, TradeType tradeType) { 8 TradeAccountEvent tradeAccountEvent = 9 processTrade(tradeAccount, amount, tradeType); 10 eventBus.post(tradeAccountEvent); 11 } 12 private TradeAccountEvent processTrade(TradeAccount 13 tradeAccount, double amount, TradeType tradeType) { 14 Date executionTime = new Date(); 15 String message = String.format("Processed trade for %s of amount %n type %s @%s", tradeAccount, amount, tradeType, executionTime); 16 TradeAccountEvent tradeAccountEvent = new TradeAccountEvent(tradeAccount, amount, executionTime, tradeType); 17 System.out.println(message); 18 return tradeAccountEvent; 19 } 20 }
与SimpleTradeAuditor类相似，我们也通过EventBus实例，构造了SimpleTradeExecutor。但是与SimpleTradeAuditor类不同的是，我们保存了一份EventBus的引用以备后用。你可能看到过很多类似的编码，对于相同实例在两个类之间的传递，这是至关重要的。在以后的示例中，我们将会介绍使用多个EventBus实例，在本篇的例子中， 我们使用单个EventBus实例。
在上面的例子中，SimpleTradeExecutor类，有一个公共的executeTrade方法，它接收了用来处理交易所需要的所有信息。我们调用processTrade方法传递所需的信息，当执行交易的时候打印信息到控制台，然后返回一个TradeAccountEvent实例。当processTrade方法执行完成，我们调用EventBus.post()方法发布返回的TradeAccountEvent实例，并通知所有TradeAccountEvent对象的订阅者。如果我们快速的比较下SimpleTradeAuditor和SimpleTradeExecutor类，我们看到，虽然两个类都参与共享所需的信息，但是它们彼此之间没有任何的耦合。
更细粒度的订阅
上面我们看到了使用EventBus类进行发布和订阅的简单例子，EventBus基于类型发布事件，这些类型被订阅的方法接受。这让我们能够灵活的将事件发送给不同的用户类型。例如，我们需要单独的进行买卖交易的审计。首先，我们需要创建两个不同类型的事件。
1 public class SellEvent extends TradeAccountEvent { 2 public SellEvent(TradeAccount tradeAccount, double amount, Date 3 tradExecutionTime) { 4 super(tradeAccount, amount, tradExecutionTime, TradeType.SELL); 5 } 6 } 7 public class BuyEvent extends TradeAccountEvent { 8 public BuyEvent(TradeAccount tradeAccount, double amount, Date 9 tradExecutionTime) { 10 super(tradeAccount, amount, tradExecutionTime, TradeType.BUY); 11 } 12 }
现在我们已经创建了两个离散事件类：SellEvent和BuyEvent，他们都继承了TradeAccountEvent类。为了实现单独的审计，我们首先为审计SellEvent类创建一个实例：
1 public class TradeSellAuditor { 2 private List<SellEvent> sellEvents = Lists.newArrayList(); 3 public TradeSellAuditor(EventBus eventBus) { 4 eventBus.register(this); 5 } 6 @Subscribe 7 public void auditSell(SellEvent sellEvent){ 8 sellEvents.add(sellEvent); 9 System.out.println("Received SellEvent "+sellEvent); 10 } 11 public List<SellEvent> getSellEvents() { 12 return sellEvents; 13 } 14 }
我们看到，上面的TradeSellAuditor非常类似于SimpleTradeAuditor，不过TradeSellAuditor 只会接收SellEvent实例。接下来，我们创建一个只审计BuyEvent类的实例：
1 public class TradeBuyAuditor { 2 private List<BuyEvent> buyEvents = Lists.newArrayList(); 3 public TradeBuyAuditor(EventBus eventBus) { 4 eventBus.register(this); 5 } 6 @Subscribe 7 public void auditBuy(BuyEvent buyEvent){ 8 buyEvents.add(buyEvent); 9 System.out.println("Received TradeBuyEvent "+buyEvent); 10 } 11 public List<BuyEvent> getBuyEvents() { 12 return buyEvents; 13 } 14 }
下面，我们简单的修改一下SimpleTradeExecutor类的代码，使其能够根据交易的类型来创建正确的TradeAccountEvent实例，代码如下：
1 public class BuySellTradeExecutor { 2 private EventBus eventBus; 3 public BuySellTradeExecutor(EventBus eventBus) { 4 this.eventBus = eventBus; 5 } 6 public void executeTrade(TradeAccount tradeAccount, double 7 amount, TradeType tradeType) { 8 TradeAccountEvent tradeAccountEvent = 9 processTrade(tradeAccount, amount, tradeType); 10 eventBus.post(tradeAccountEvent); 11 } 12 private TradeAccountEvent processTrade(TradeAccount 13 tradeAccount, double amount, TradeType tradeType) { 14 Date executionTime = new Date(); 15 String message = String.format("Processed trade for %s of amount %n type %s @%s", tradeAccount, amount, tradeType, executionTime); 16 TradeAccountEvent tradeAccountEvent; 17 if (tradeType.equals(TradeType.BUY)) { 18 tradeAccountEvent = new BuyEvent(tradeAccount, amount, 19 executionTime); 20 } else { 21 tradeAccountEvent = new SellEvent(tradeAccount, 22 amount, executionTime); 23 } 24 System.out.println(message); 25 return tradeAccountEvent; 26 } 27 }
这样我们就已经创建了一个新的BuySellTradeExecutor类，根据交易的类型，我们将创建相应的BuyEvent或SellEvent实例，它的作用与我们之前的SimpleTradeExecutor类相似。但是，EventBus类是完全没有意识到这些变化的。我们注册了不同的订阅者并发布了不同的事件，这些变化对EventBus类来说是透明的。
注意，我们不需要为这些事件的通知创建单独的类。我们的SimpleTradeAuditor类会在事件发生时继续接收这些通知。如果我们想根据事件的类型做单独的处理，我们可以简单的添加一个检查事件的类型。最后，如果需要，我们也可以定义一个类有多个订阅方法：
1 public class AllTradesAuditor { 2 private List<BuyEvent> buyEvents = Lists.newArrayList(); 3 private List<SellEvent> sellEvents = Lists.newArrayList(); 4 public AllTradesAuditor(EventBus eventBus) { 5 eventBus.register(this); 6 } 7 @Subscribe 8 public void auditSell(SellEvent sellEvent) { 9 sellEvents.add(sellEvent); 10 System.out.println("Received TradeSellEvent " + sellEvent); 11 } 12 @Subscribe 13 public void auditBuy(BuyEvent buyEvent) { 14 buyEvents.add(buyEvent); 15 System.out.println("Received TradeBuyEvent " + buyEvent); 16 } 17 }
上面我们创建了一个包含两个事件处理方法的类，AllTradesAuditor方法将接收所有交易事件的通知，它只是一个被EventBus（基于事件类型）调用的方法。采取一个极端，我们可以创建一个事件处理方法，该方法接受一个Object类型的对象,Object在java中是所有对象的父类，这样我们就可以接收任何和所有由EventBus处理的事件的通知了。最后，没有什么能够阻止我们拥有多个EventBus实例。如果我们要重构BuySellTradeExecutor类成两个独立的类，我们可以为每个类注入一个单独的EventBus实例。那么它将是一个注入正确EventBus实例审计类的方法，我们就有了一套完整独立的发布-订阅事件。
取消订阅
正如我们想订阅事件，有些情况下我们可能需要取消事件的订阅。可以通过订阅对象的eventbus.unregister方法实现。例如，如果我们需要取消订阅事件，我们可以将下面的方法添加到我们的订阅类：
1 public void unregister(){ 2 this.eventBus.unregister(this); 3 }
一旦调用此方法，该特定实例将停止接收无论多久以前注册的事件。其他注册了相同事件的实例则会继续接收通知。
异步EventBus
Eventbus处理所有的事件都以串行的方式，这种事件处理方法确保了处理的轻量性。不过，我们仍然有另外的选择AsyncEventBus，AsyncEventBus类提供了与EcentBus相同的功能，但是使用了java.util.concurrent.executor实例来进行方法的异步处理。
我们可以通过类似于EventBus实例的方式，创建一个AsyncEventBus实例：
AsyncEventBus asyncEventBus = new AsyncEventBus(executorService);
上面我们通过一个ExecutorService实例创建了AsyncEventBus实例，除了ExecutorService实例，也可以通过提供一个字符串标识符创建AsyncEventBus。当我们的订阅者在接收事件时需要执行繁重的处理时，使用AsyncEventBus会很有用。
DeadEvents
当EventBus收到事件通过post方法发送的通知，并且没有注册的订阅者，那么事件则是被DeadEvent类的一个实例包裹。当试图确保所有的事件都有注册的订阅者时，有一个DeadEvents实例的订阅类是非常有用的。DeadEvents类提供了一个公共的getEvent方法，可以用来检查那些未交付的原始事件。例如，我们可以通过下面的方式创建一个非常简单的例子：
1 public class DeadEventSubscriber { 2 public DeadEventSubscriber(EventBus eventBus) { 3 eventBus.register(this); 4 } 5 @Subscribe 6 public void handleUnsubscribedEvent(DeadEvent deadEvent) { 7 System.out.println("No subscribers for " + deadEvent.getEvent()); 8 } 9 }
上面简单的对任何DeadEvent实例进行了注册，并记录了那些没有订阅者的事件。
Dependency injection依赖注入
为了确保我们为相同的EventBus实例注册了订阅者和发布者，使用依赖注入框架（Spring或Guice）显得很有意义。接下来的例子中，我们会介绍怎么配置Spring框架在SimpleTradeAuditor和SimpleTradeExecutor类。首先，我们对SimpleTradeAuditor和SimpleTradeExecutor类做如下的修改：
1 @Component 2 public class SimpleTradeAuditor { 3 private List<TradeAccountEvent> tradeEvents = 4 Lists.newArrayList(); 5 @Autowired 6 public SimpleTradeAuditor(EventBus eventBus) { 7 eventBus.register(this); 8 } 9 @Subscribe 10 public void auditTrade(TradeAccountEvent tradeAccountEvent) { 11 tradeEvents.add(tradeAccountEvent); 12 System.out.println("Received trade " + tradeAccountEvent); 13 } 14 } 15 16 @Component 17 public class SimpleTradeExecutor { 18 private EventBus eventBus; 19 @Autowired 20 public SimpleTradeExecutor(EventBus eventBus) { 21 this.eventBus = eventBus; 22 } 23 public void executeTrade(TradeAccount tradeAccount, double 24 amount, TradeType tradeType) { 25 TradeAccountEvent tradeAccountEvent = 26 processTrade(tradeAccount, amount, tradeType); 27 eventBus.post(tradeAccountEvent); 28 } 29 private TradeAccountEvent processTrade(TradeAccount 30 tradeAccount, double amount, TradeType tradeType) { 31 Date executionTime = new Date(); 32 String message = String.format("Processed trade for %s of amount %n type %s @%s", tradeAccount, amount, tradeType, executionTime); 33 TradeAccountEvent tradeAccountEvent = new TradeAccountEvent(tradeAccount, amount, executionTime, tradeType); 34 System.out.println(message); 35 return tradeAccountEvent; 36 } 37 }
上面我们简单的为两个类添加了类级别的@Component注解，这是为了使Spring将这些我们想注入的类作为bean。这样，我们就需要使用构造注入，所以在两个类的构造方法上添加了@Autowired注解，@Autowired告诉Spring给两个类注入EventBus的一个实例。最后，我们有我们的配置类，来指示Spring框架在哪里寻找组件，并连接配置类中定义的bean：
1 @Configuration 2 @ComponentScan(basePackages = {"guava"}) 3 public class EventBusConfig { 4 @Bean 5 public EventBus eventBus() { 6 return new EventBus(); 7 } 8 }
上面我们使用了@Configuration注解，它标识了此类作为Spring上下文包含bean的创建和注入。我们定义了eventBus方法构造并且返回了EventBus类的一个实例，它将被注入给其他对象。这种情况下，当我们在SimpleTradeAuditor和SimpleTradeExecutor类的构造方法上使用@Autowire注解，Spring会自动注入相同的EventBus实例，这正是我们所需要的。值得注意的是，Spring默认情况下创建单例类，这也是我们这里想要的。正如我们所看到的，使用依赖注入框架可以确保我们基于事件的系统配置的合理正确。
Summary
在本篇中，我们已经介绍了如何通过Guava EventBus类使用基于事件的编程，来减少我们的代码耦合。我们介绍了如何创建一个EventBus实例并注册订阅者和发布者。我们也探讨了强大的使用类型注册那些我们感兴趣的事件。我们了解了AsyncEventBus类，它允许我们发送异步事件。我们看到了如何使用DeadEvent类，以确保我们的事件都拥有订阅者。最后，我们看到了如何使用依赖注入框架来解耦我们基于事件的系统配置。
下一个系列中， 我们将会学习如何通过Guava对文件进行操作。敬请关注。