移动架构----EventBus

EventBus可以代替Android传统的Intent,Handler,Broadcast或接口函数,在Fragment,Activity,Service线程之间传递数据，执行方法。

EventBus注册

image.png

Event发送消息

image.png

EventBus源码分析

EventBus涉及到的内容大致可以分为五大块：

• Subscribe
• ThreadMode
• register
• post
• unregister

1、Subscribe

Subscribe采用运行时注解,且注解只能用在函数上,默认的threadmode为posting

2、ThreadMode

ThreadMode包含的内容有：

1. POSTING
   默认的模式,开销最小的模式,因为声明为POSTING的订阅者会在发布的同一个线程调用，发布者在主线程那么订阅者也就在主线程,反之亦,避免了线程切换,如果不确定是否有耗时操作，谨慎使用，因为可能是在主线程发布
2. MAIN
   主线程调用，发布线程不同处理不同,如果发布者在主线程那么直接调用(非阻塞式),如果发布者不在主线程那么阻塞式调用
3. MAIN_ORDERED
   和MAIN差不多,主线程调用，和MAIN不同的是他保证了post是非阻塞式的(默认走MAIN的非主线程的逻辑，所以可以做到非阻塞)
4. BACKGROUND
   在子线程调用,如果发布在子线程那么直接在发布线程调用,如果发布在主线程那么将开启一个子线程来调用,这个子线程是阻塞式的,按顺序交付所有事件,所以也不适合做耗时任务,因为多个事件共用这一个后台线程
5. ASYNC
   在子线程调用,总是开启一个新的线程来调用,适用于做耗时任务,比如数据库操作,网络请求等，不适合做计算任务,会导致开启大量线程

3、register

1. 通过getDefault获取EventBus实例，这是一条默认的事件总线,通过单例模式实现,其构造函数是Public的也可以通过new的形式来创建多条事件总线
2. 从缓存中获取订阅方法列表,如果缓存中不存在则通过反射获取到订阅者所有的函数,遍历再通过权限修饰符.参数长度(只允许一个参数).注解(@Subscribe)来判断是否是具备成为订阅函数的前提,具备则构建一个SubscriberMethod(订阅方法，其相当于一个数据实体类,包含方法,threadmode,参数类型,优先级,是否粘性事件这些参数),循环结束订阅函数列表构建完成添加进入缓存
3. 对subscriptionsByEventType.typesBySubscriber完成数据初始化,subscriptionsByEventType根据参数类型存储订阅者和订阅方法,typesBySubscriber根据订阅者存储了所有的参数类型，subscriptionsByEventType主要是post时使用,因为其存储了订阅者和订阅事件这两个参数在反射时要用到,typesBySubscriber在反注册时可以根据订阅者获取到存储的事件类型就可以从subscriptionsByEventType中获取到对应的订阅者和订阅方法释放资源,还可以用来判断是否注册,这些最后会分析到

4、post

1. 使用ThreadLocal来存储事件,他可以隔离多个线程对数据的访问冲突
2. 根据事件类型(也就是Post参数的类型)为key从subscriptionsByEventType获取订阅方法和订阅者,这个容器不了解的可以看下注册的总结
3. 根据线程和threadmode来判断

5、unregister

1. 根据订阅者从typesBySubscriber中获取到所有的事件类型
2. 有了事件类型列表就可以遍历事件类型从subscriptionsByEventType获取到对应的订阅者包括订阅函数来释放
3. 根据订阅者删除掉typesBySubscriber中的事件类型 此时订阅者已经被释放不再持有该订阅者引用

EventBus简单使用

MainActivity:

public class MainActivity extends AppCompatActivity {

private TextView textView;

@Override
protected void onCreate(Bundle savedInstanceState) {
    super.onCreate(savedInstanceState);
    setContentView(R.layout.activity_main);
    textView = findViewById(R.id.tv_text);

    EventBus.getDefault().register(this);
}

@Subscribe
public void receive(Friend friend) {
    textView.setText(friend.toString());
}

@Override
protected void onDestroy() {
    super.onDestroy();
    EventBus.getDefault().unregister(this);
}

public void click(View view) {
    startActivity(new Intent(this, SecondActivity.class));
}
}

SecondActivity：

public class SecondActivity extends AppCompatActivity {

@Override
protected void onCreate(Bundle savedInstanceState) {
    super.onCreate(savedInstanceState);
    setContentView(R.layout.activity_second);
}

public void send(View view) {
    EventBus.getDefault().post(new Friend("哈哈哈", 12));
}
}

现象描述：
在SecondActivity点击send按钮后，回到MainActivity，textview的内容改为"name:哈哈哈,age:12"
这里需要注意的时，EventBus发送消息后，遍历订阅者，符合条件的都会执行，跟activity的生命周期没啥关系，比如在MainActivity中的Subscribe加上threadmode=ASYNC，依然不会报错，即textview内容的修改发生在生命周期之前。