EventBus的小小Demo EventBus的小小Demo

前言# 之前我们聊了观察者模式，那肯定要说说EventBus，我这几天也在看EventBus的源码，整体的流程都已经看过了，也发现了EventBus的优点，但是还有一些小细节还没缕清楚，现在处于一种不知道怎么用语言表达的阶段，所以关于EventBus的源码解析就稍微推迟一下，非常的sorry。
所以就先简单的写一个demo，最后在这个demo的基础上，先简单的说一下EventBus对于几点功能的性能优化。
正文# 首先我们来思考一个问题：是用Java的Obserable和Obsever，还是我们自己来定义观察者和被观察者呢?
我是这么认为的：

1、Obserable和Obsever在语义上，我觉得稍微差了点，并且和一些开源库，例如RxJava，在类的命名上有重复，容易弄混。
2、如果使用Obserable，每一次定义被观察者都得实现一些内部的小细节，也就是要新定义类，而我们往往都是通过String或者int来区分更加方便管理。

所以我觉得还是自己实现整个流程比较方便，那就不废话了，代码走起：
先定义回调函数，观察者来实现此接口。

/** * Created by li.zhipeng on 2017/8/4. * *EventBus的通知回调函数 */public interface EventListener {void onEvent(int eventCode, Object object); }

再定义观察者：

/** * Created by li.zhipeng on 2017/8/4. * * EventBus主体类，实现被观察者分发的主要逻辑 */public class EventBus {/** * 使用单例模式 */ private static EventBus instance; private EventBus() { }public synchronized static EventBus getInstance() { if (instance == null) { instance = new EventBus(); } return instance; }/** * 保存所有的观察者，按照被观察者分类 * * 这里我们使用int类型，作为被观察者的标识,主要是为了使用高效的SparseArray * * 每一个中被观察者，对应的是HashSet，里面保存了对应的所有观察者 */ private SparseArray> observables = new SparseArray<>(); /** * 注册观察者方法 * * 添加同步锁，防止注册，通知，移除等操作同时进行引起的异常 */ public synchronized void registerEvent(int eventCode, EventListener listener) { // 首先在所有的被观察者中找到对一个的集合 HashSet observers = observables.get(eventCode); // 如果没有这个集合，新建集合，并放到里面去 if (observers == null) { observers = new HashSet<>(); observables.put(eventCode, observers); } // 添加观察者 observers.add(listener); }/** * 解绑观察者 * 【EventBus的小小Demo】* 添加同步锁，防止注册，通知，移除等操作同时进行引起的异常 */ public synchronized void unregisterEvent(int eventCode, EventListener listener) { // 首先在所有的被观察者中找到对一个的集合 HashSet observers = observables.get(eventCode); // 从集合中移除这个观察者 if (observers != null) { observers.remove(listener); } }/** * 通知对应的观察者，被观察者发生变化的事件 * * 这里我们模仿Observable的做法 */ public void sendEvent(int eventCode, Object object) { // 先定义一个临时Set集合 EventListener[] arrLocal; // 这里添加同步锁，避免多线程或者是，多操作同时引起的问题 synchronized (this) { arrLocal = toArray(observables.get(eventCode)); } // 开发分发事件 for (int i = arrLocal.length - 1; i >= 0; i--) { arrLocal[i].onEvent(eventCode, object); } }/** * HashSet转数组 * */ private EventListener[] toArray(HashSet set){ EventListener[] r = new EventListener[set.size()]; Iterator it = set.iterator(); for (int i = 0; i < r.length; i++) { r[i] = it.next(); } return r; }/** * 清除所有的观察者 * */ public void clear(){ observables.clear(); }}

我们把所有的被观察者和对应的观察者，作为键值对保存在Map中，这样就方便获取和保存，然后注册和解绑去添加或移除观察者，通知实际上就是一个遍历对应的观察者的操作。
使用起来也和之前没有什么太大的区别:

public class MainActivity extends AppCompatActivity implements EventListener{private TextView textView; private int count; @Override protected void onCreate(Bundle savedInstanceState) { super.onCreate(savedInstanceState); setContentView(R.layout.activity_main); textView = (TextView) findViewById(R.id.textView)； // 点击发送一个通知变化的事件 findViewById(R.id.button).setOnClickListener(new View.OnClickListener() { @Override public void onClick(View v) { EventBus.getInstance().sendEvent(1, "test" + count++); } }); // 注册 EventBus.getInstance().registerEvent(1, this); }@Override protected void onDestroy() { super.onDestroy(); // 解绑 EventBus.getInstance().unregisterEvent(1, this); }// 实现的回调函数 @Override public void onEvent(int eventCode, Object object) { textView.setText((String) object); } }

EventBus的优化
实现的中心思想是没有差别的，但是在性能上，肯定还是很粗糙的，例如所有所有的操作都是主线程中，所以并发和耗时都有潜在的问题，那么EventBus是如何优化这些问题的呢？