用 RxJava 实现事件总线 - RxBus
此文由 DreamFish 翻译，英语水平有限，请多多包涵！
在此贴出原文出处Implementing an Event Bus With RxJava - RxBus
Leatn RxBus
这篇文章分三部分
- 简单介绍事件总线
- 使用 RxJava 实现事件总线
- 通过 RxBus 拓展思维
"RxBus"并不是一个库，使用 RxJava 实现事件总线是一件非常简单的事并且你不用担心它会像一个库一样显得庞大臃肿。
Part 1 : 什么是事件总线？
我们先来谈谈两个看似相似的概念： 观察者模式 和 发布/订阅 模式。
观察者模式
这是一种行为型模式，当你的类或主对象（称为被观察者）的状态发生改变就会通知所有对此改变感兴趣的类或对象（称为观察者）。
详细了解请移步至 观察者模式 -- 千军万马穿云箭
发布/订阅
发布/订阅 模式的功能和观察者模式是一样的，都是完成特定事件发生后的消息通知。
观察者模式 和 发布/订阅模式 之间还是存在一些差别的，在 发布/订阅 模式 中重点是发布消息，然后由调度中心统一调度，不需要知道具体有哪些订阅者。（这样就可以匿名）
为什么要匿名？
在计算机程序设计中有一个非常棒的思想叫“解耦”。你通常希望在你的设计中保持尽可能低的耦合度。
通常情况下，你希望消息发布商能够直接了解所有需要接收消息的订阅者，这样，一旦“事件”或消息准备好就可以及时通知每一个订阅者。但是使用事件总线，发布者可以免除这种职责并实现独立性，因为消息发布者和消息订阅者可以相互不知道对方，只关心对应的消息，从而接触两者之间的依赖关系。
换句话说，只要你可以，请使你的代码有意义地解耦！
怎么实现匿名？
提到匿名，自然而然你就会问：你是如何真正实现发布者和订阅者之间的匿名？ 很简单，只要找到一个中间人，让这个中间人负责两方的消息调度。事件总线就是一个这样的中间人。
综上所述，事件总线就是这么简单。
Android 中有两个常用的事件总线库，分别是 Otto 和 Green Robot 的 EventBus。网上有很多文章解释了如何在你的应用程序中应用它们。
Part 2 : 使用RxJava实现事件总线
我已经写了一个 demo 展示如何使用 RxJava ： RxJava for Android in this github repo，而且我会继续完善这个 demo。下面看一下一些有趣的实现：
// this is the middleman object
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;
}
}
现在，你有一个事件总线可以使用了。
下面是你如何将事件发布到总线中的方式：
implement_bus_2.java
@OnClick(R.id.btn_demo_rxbus_tap)
public void onTapButtonClicked() {
_rxBus.send(new TapEvent());
}
这里是是你如何监听来自其他组件或服务的事件：
implement_bus_3.java
// note that it is important to subscribe to the exact same _rxBus instance that was used to post the events
_rxBus.toObserverable()
.subscribe(new Action1<Object>() {
@Override
public void call(Object event) {
if(event instanceof TapEvent) {
_showTapText();
}else if(event instanceof SomeOtherEvent) {
_doSomethingElse();
}
}
});
在这个例子中，我们从顶部片段（绿色部分）发布事件，并从底部片段（蓝色部分）监听点击事件（通过事件总线）。
rxbus
Part 3 : 拓展思维
Dead Event
在一些特殊场景下我们需要知道是否有订阅者在监听总线。例如，如果你使用事件总线来处理 GCM 通知推送，那么如果应用程序位于前台，则不希望发送推送通知，那么监听“ dead event ” 就显得很重要了。
例如，在最近发布的模块中，我们在我们的应用程序中添加了聊天功能。如果用户打开了应用程序（因此至少有1个或更多的订阅者监听着总线），我们不会发送推送通知，但是如果应用程序在后台，那么我们发送一个推送通知，让他们知道聊天消息。事件发布到事件总线后，如果没有订阅者正在监听，则返回 dead event 。如果我们收回一个 dead event ，就会发出一个推送通知。
如何使用 RxBus 实现？
实际上很简单，调用 hasObservers() 就可以获取订阅者，这个方法是在RxJava的1.x版本中添加的，因此您必须使用最新版本的RxAndroid（在本文中为0.23.0）才能看到此方法。
应该使用 RxBus 还是 Otto/EventBus ?
如果你只是想使用Android应用程式的事件总线，您可能会喜欢使用
Otto（我非常推荐）或 EventBus的图书馆。Otto 使用注解的方式来识别 订阅者(Subscriber) 和 生产者(Producer)，使用起来可能要简单得多。
如果您熟悉 Rx ，您的应用程序中已经使用了 RxJava ，并想要摆脱附加的库，请务必尝试使用 RxBus 方法！
最后，如果有什么不对的地方或者你有什么建议的话，可以在评论中@我，或者在 GitHub 提 issue 。
