Android事件总线设计（一）

我们通常在进行安卓设计的时候，不同的Activity，Fragment，Service等之间通讯一直是个不小的问题，用Intent以及Handler都觉得有一点麻烦，于是，为了简化以及更加高质量的完成通信，同时解决组件之间高耦合的前提下仍能高效的进行通信，事件总线设计出现了，提到事件总线，我们就会想到EventBus以及otto，这篇博客我们就先来讲解一下EventBus的用法；

初识EventBus

EventBus是一款针对Android优化的发布-订阅事件总线，它简化了应用程序内各组件之间以及组件与后台线程之间的通讯，开销小，代码看着更舒服一点。对于Activity之间的通讯，我们一般采用Intent的方法，对于Fragment与Activity之间的通讯，基本上就需要使用接口了，而Fragment之间的通讯，我们一般会采用广播，简单来说，这个通讯就是越来越麻烦的，而且效率也很低，那接下来我们就开始正式介绍一下这个EventBus。

EventBus的三要素

在学会使用之前，首先要理解一下这个本质上来说是个什么东西以及他的基本规则，刚才我们说过，EventBus的一种发布-订阅事件总线，那么基本上就可以知道三要素是什么了：

1.事件：Event，可以是任意类型的对象；

2.事件发布者：Publisher，可以在任意线程任意位置发送事件，直接调用EventBus的post()方法，一般直接使用EventBus.getDefault()进行调用，根据post函数参数的类型，会自动调用订阅相应类型事件的函数；

3.事件订阅者：Subscriber，在使用时需要添加@Subscriber，并且要指定线程模型，默认为POSTING，马上我们就会讲到EventBus的线程模型。

EventBus的四种线程模型

1.POSTING(默认)：这个事件在哪个线程发出来的，就会在哪个线程执行，发布事件和接收事件是在同一个线程，尽量避免执行耗时操作，会阻塞时间的传递；

2.MAIN：这个事件的处理会在UI线程中执行，同样事件处理时间不能太长；

3.BACKGROUND：这个事件处理要看是什么线程发出的了，UI线程发出，那就会新开个线程处理，子线程发出，那就直接在子线程处理，因此禁止进行UI更新操作；

4.ASYNC：这个事件处理就不管是什么线程发布的了，直接新开线程，同样禁止进行UI更新操作。

EventBus的基本使用

首先定义一个事件类

我们选择定义一个事件类MessageEvent，来进行消息的传递：

public class MessageEvent {private String message;public MessageEvent(String message) {this.message = message;}public String getMessage() {return message;}public void setMessage(String message) {this.message = message;}
}

定义完成，我们可以看到这也就是相当于是定义了一个String变量的收发。

第二注册事件

在需要订阅事件的地方进行事件的注册，基本语句就下面这句：

EventBus.getDefault().register(this);

第三发送事件

在发送事件的地方直接输入下面的代码即可：

EventBus.getDefault().post(messageEvent);

第四处理事件

事件发送过来后我们需要对发过来的信息进行接收处理：

@Subscribe(threadMode = ThreadMode.MAIN)
public void ReturnMessage(MessageEvent MessageEvent){***
}

第五取消事件订阅

在onDestroy()方法中进行EventBus的订阅取消：

EventBus.getDefault().unregister(this);

基本就是这样了，接下来我们来实际应用一遍加深印象：

EventBus实际应用进行通讯

我们就使用Activity之间的通讯作为例子，所有的大体上都是一样的：

配置消息事件类

public class MessageEvent {private String message;public MessageEvent(String message) {this.message = message;}public String getMessage() {return message;}public void setMessage(String message) {this.message = message;}
}

和之前的一样，没啥好说的；

新建两个Activity同时进行布局

第一个布局需要一个textView两个Button：

第二个布局只需要一个Button：

第一个Activity进行事件的订阅处理以及取消订阅

public class NoticeActivity extends AppCompatActivity implements View.OnClickListener {private TextView testView;private Button eventBusRegister, jumpActivity;@Overrideprotected void onCreate(Bundle savedInstanceState) {super.onCreate(savedInstanceState);setContentView(R.layout.activity_notice);initView();eventBusRegister.setOnClickListener(this);jumpActivity.setOnClickListener(this);}public void initView() {testView = findViewById(R.id.testView);eventBusRegister = findViewById(R.id.eventBusRegister);jumpActivity = findViewById(R.id.jumpActivity);}@Overridepublic void onClick(View v) {switch (v.getId()) {//点击注册EventBuscase R.id.eventBusRegister:EventBus.getDefault().register(NoticeActivity.this);break;case R.id.jumpActivity:startActivity(new Intent(NoticeActivity.this, ReturnActivity.class));break;}}//进行事件处理@Subscribe(threadMode= ThreadMode.MAIN)public void returnMessageEvent(MessageEvent messageEvent){testView.setText(messageEvent.getMessage());}@Overrideprotected void onDestroy() {super.onDestroy();//进行事件取消订阅EventBus.getDefault().unregister(this);}
}

注释里面都写了，接下来看第二个：

第二个Activity中进行事件的发送

public class ReturnActivity extends AppCompatActivity implements View.OnClickListener {private Button finishWithNotice;@Overrideprotected void onCreate(Bundle savedInstanceState) {super.onCreate(savedInstanceState);setContentView(R.layout.activity_return);initView();finishWithNotice.setOnClickListener(this);}public void initView() {finishWithNotice = findViewById(R.id.finishWithNotice);}@Overridepublic void onClick(View v) {switch(v.getId()){case R.id.finishWithNotice:EventBus.getDefault().post(new MessageEvent("EventBus King"));finish();}}
}

这个finish的意思就是处理完成后自动关闭这个Activity。

我们来看一下实际效果：

我们可以很明显的看到了，在注册EventBus之后，在第二个Activity中进行事件发送后，在第一个Activity中可以完美接收到这个消息，没有问题。

不过还存在一个事情，就像我一开始点击的那样，我先进行事件发送，再进行事件订阅，我们也想要接收到这个事件，应该怎么做呢，这就涉及到EventBus的黏性事件问题：

EventBus黏性事件

上面的属于普通事件，黏性事件其实也就是，在发送事件之后再订阅该事件，那么也能收到该事件，其实很简单，我们修改一下之前的部分代码：

@Subscribe(threadMode = ThreadMode.MAIN, sticky = true)public void returnMessageEvent(MessageEvent messageEvent) {testView.setText(messageEvent.getMessage());}

public void onClick(View v) {switch(v.getId()){case R.id.finishWithNotice:EventBus.getDefault().postSticky(new MessageEvent("EventBus King"));finish();}}

就这两部分，一个是处理，一个是发送，来看一下效果：

成功，就这样吧，下次再看看别的。