翻译：通过 RxJava 实现一个 Event Bus －RxBus
原文： Implementing an Event Bus With RxJava – RxBus
这篇文章有三个部分：
- 关于什么是 Event Bus（事件总线）的快速指引（不译）
- 通过 RxJava 实现一个 RxBus
- 对于文章所题的这种方式的一些疑惑和回答
一、什么是 Event Bus（事件总线）
这部分由于篇幅太长，并且不是关键，所以略去，关于这部分，我假设你已经懂得了，如果不懂，可以看看 Square 的 Otto 或者 GreenRobot 的 EventBus，再或者你可以看看 妹纸&gank.io 的源代码，这个项目使用到了 Otto 和 RxJava。
二、通过 RxJava 实现一个 RxBus
我已经发布了这个 使用 RxJava 的例子了： 一个使用 RxJava for Android 的教程 ，所以我在这里继续来解释 RxBus 的完整实现。这是其中有趣部分的实现：
// 这是作为中间人调用的对象 public class RxBus { private final Subject<Object, Object> _bus = new SerializedSubject<>(PublishSubject.create()); public void send(Object o) { _bus.onNext(o); } public Observable<Object> toObserverable() { return _bus; } }这样就可以了，看得出我们已经有一个 Event Bus 可以使用啦，接下来就是使用方式的介绍：
通过这个 bus 发布一个事件：
@OnClick(R.id.btn_demo_rxbus_tap) public void onTapButtonClicked() { _rxBus.send(new TapEvent()); }在其他 Fragment 或者 Service 等地方监听这个事件：
// 注意 要使用原本发布这个事件的那个 bus 实例才行 _rxBus.toObserverable() .subscribe(new Action1<Object>() { @Override public void call(Object event) { if(event instanceof TapEvent) { _showTapText(); }else if(event instanceof SomeOtherEvent) { _doSomethingElse(); } } });在这个例子中，我们在绿色部分的 Frgament 中发布了一个点击事件，然后在蓝色部分的 Fragment 中监听响应这个事件。
三、对文章所题的这种方式的一些疑惑和回答
关于 Dead events，以及 RxBus 要怎么实现这点？
我们如果能够知道是否有观察者目前订阅了我们的 bus，在有些情况下是很有用的。例如，你使用一个 Event Bus 来处理 GCM 的推送通知，当你的 App 当前正在前台运行的时候，你不想发送通知栏通知，这时监听这个 “ DeadEvent ” 就很重要了。（译者注：来源于 Otto 中对于 DeadEvent 的用处解释：用来包装一个没有订阅者的事件，它不会被交付。）
例如，在我们最新发布的一个 App 中，我们增加了一个“发送中”的功能。当用户打开我们的 App 在使用，这时会有许多监听器正在监听这个 bus，我们不需要发送 通知栏消息，当我们的 App 在后台的时候，我们需要发送 通知栏消息 让用户获得一些聊天信息。当一个事件发布，如果没有订阅者在监听（注：如果应用或页面到了后台或者关闭，一些和生命周期挂钩的订阅，都会解除对事件的监听，所以这时可以说没有订阅者在监听啦），就发布一个 dead event。如果我们发出一个 dead event，推送通知栏消息就可以出现了。
那么 RxBus 要怎么实现这点？
事实上十分简单，在 1.x 版本的 RxJava 中有了一个很有用的方法：hasObservers()，使用这个方法就可以做到啦。
那么我是否应该使用 RxBus 来替代 Otto/EventBus？
如果你只是想简单地使用一个 Event Bus，你最好还是使用 Otto（特别推荐）或者 EventBus。Otto 通过注解可以有很清爽的 API，并且它使用起来也比较简单。
而如果你对 Rx 很熟悉，并且已经在你的项目中使用了 RxJava，同时你又想避免使用更多的依赖库，那么肯定说要试试我们的 RxBus 了！