番石榴EventBus

Google Guava库具有有用的package eventbus 。 EventBus类允许组件之间进行发布-订阅式通信，而无需组件之间进行显式注册。 因为我们开发Web应用程序，所以应该将此类的实例封装在有作用域的bean中。

让我们编写EventBusProvider bean。

public class EventBusProvider implements Serializable {private EventBus eventBus = new EventBus("scopedEventBus");public static EventBus getEventBus() {// access EventBusProvider beanELContext elContext = FacesContext.getCurrentInstance().getELContext();EventBusProvider eventBusProvider =(EventBusProvider) elContext.getELResolver().getValue(elContext, null, "eventBusProvider");return eventBusProvider.eventBus;}
}

我仅以一个示例来演示Guava EventBus的所有主要功能。 让我们编写以下事件层次结构：

public class SettingsChangeEvent {}public class LocaleChangeEvent extends SettingsChangeEvent {public LocaleChangeEvent(Object newLocale) {...}
}public class TimeZoneChangeEvent extends SettingsChangeEvent {public TimeZoneChangeEvent(Object newTimeZone) {...}
}

public MyBean1 implements Serializable {@PostConstructpublic void initialize() throws Exception {EventBusProvider.getEventBus().register(this);}@Subscribepublic void handleLocaleChange(LocaleChangeEvent event) {// do something}@Subscribepublic void handleTimeZoneChange(TimeZoneChangeEvent event) {// do something}
}public MyBean2 implements Serializable {@PostConstructpublic void initialize() throws Exception {EventBusProvider.getEventBus().register(this);}@Subscribepublic void handleSettingsChange(SettingsChangeEvent event) {// do something}
}

要发布事件，只需将事件对象提供给EventBus实例的post（）方法。 EventBus实例将确定事件的类型，并将其路由到所有已注册的侦听器。

public class UserSettingsForm implements Serializable {private boolean changed;public void localeChangeListener(ValueChangeEvent e) {changed = true;        // notify subscribersEventBusProvider.getEventBus().post(new LocaleChangeEvent(e.getNewValue()));}public void timeZoneChangeListener(ValueChangeEvent e) {changed = true;        // notify subscribersEventBusProvider.getEventBus().post(new TimeZoneChangeEvent(e.getNewValue()));}public String saveUserSettings() {...if (changed) {// notify subscribersEventBusProvider.getEventBus().post(new SettingsChangeEvent());return "home";}}
}

• 事件生产者和事件观察者彼此分离。
• 观察者可以指定“选择器”的组合来缩小他们将接收的事件通知的范围。
• 可以立即或延迟通知观察者，直到当前事务结束为止。
• 使用条件观察者方法进行作用域定义时不会感到头痛（还记得作用域bean和Mediator / EventBus的问题吗？）。

public MyBean implements Serializable {public void onLocaleChangeEvent(@Observes Locale locale) {...}
}

如果观察者方法仅对限定的事件感兴趣，则事件参数也可以指定限定符-这些是具有那些限定符的事件。

public void onLocaleChangeEvent(@Observes @Updated Locale locale) {...
}

事件限定符只是使用@Qualifier定义的普通限定符。 这是一个例子：

@Qualifier
@Target({FIELD, PARAMETER})
@Retention(RUNTIME)
public @interface Updated {}

事件生产者使用参数化Event接口的实例来触发事件。 该接口的实例通过注入获得。 生产者通过调用Event接口的fire（）方法并传递事件对象来引发事件。

public class UserSettingsForm implements Serializable {@Inject @Any Event<Locale> localeEvent;public void localeChangeListener(ValueChangeEvent e) {// notify all observerslocaleEvent.fire((Locale)e.getNewValue());}
}

// this will raise events to observers having parameter @Observes @Updated Locale
@Inject @Updated Event<Locale> localeEvent;

public void onLocaleChangeEvent(@Observes @Updated Locale locale, User user) {...
}

动态指定限定符怎么办？ CDI允许通过AnnotationLiteral获得适当的限定符实例。 这样，我们可以将限定符传递给Event的select（）方法。 例：

public class DocumentController implements Serializable {Document document;@Inject @Updated @Deleted Event<Document> documentEvent;public void updateDocument() {...// notify observers with @Updated annotationdocumentEvent.select(new AnnotationLiteral<Updated>(){}).fire(document);}public void deleteDocument() {...// notify observers with @Deleted annotationdocumentEvent.select(new AnnotationLiteral<Deleted>(){}).fire(document);}
}

public void onLocaleChangeEvent(@Observes(receive = IF_EXISTS) @Updated Locale locale) {...
}