一、概述
Eventsbus是greenrobot旗下的一个开源框架,旗下还有Android ObjectBox开源数据库。
主要有发布者、订阅者以及事件三大组件组成,其中事件是发布者与订阅者之间的桥梁。
二、环境部署
①首先在gradel中添加依赖:implementation 'org.greenrobot:eventbus:3.1.1'
implementation 'org.greenrobot:eventbus:3.1.1'
②创建“事件”,就是创建一个class,用来传递参数,可以根据自身需求进行定义属性。
public class EventModel {
private int flag;
private String message;
public int getFlag() {
return flag;
}
public void setFlag(int flag) {
this.flag = flag;
}
public String getMessage() {
return message;
}
public void setMessage(String message) {
this.message = message;
}
}
③准备订阅者,下边一共有五中注解类型,每种类型代表不同的用法,下边会详细介绍。
@Subscribe(threadMode = ThreadMode.POSTING)
public void onMessageEvent(EventModel event) {
//进行其他操作
}
@Subscribe(threadMode = ThreadMode.MAIN)
public void onMessageEvent(EventModel event) {
//进行其他操作
}
@Subscribe(threadMode = ThreadMode.MAIN_ORDERED)
public void onMessageEvent(EventModel event) {
//进行其他操作
}
@Subscribe(threadMode = ThreadMode.BACKGROUND)
public void onMessageEvent(EventModel event) {
//进行其他操作
}
@Subscribe(threadMode = ThreadMode.ASYNC)
public void onMessageEvent(EventModel event) {
//进行其他操作
}
同时我们还需要注册和注销。只有在订阅者注册时,才会收到活动。在Android中,在活动和片段中,通常应该根据其生命周期进行。
@Override
public void onStart() {
super.onStart();
EventBus.getDefault().register(this);
}
@Override
public void onStop() {
EventBus.getDefault().unregister(this);
super.onStop();
}
上边已经把事件以及订阅者配置完成,下边需要做的就是配置发布者。
④发布者配置
EventModel model=new EventModel();
model.setFlag(1);
model.setMessage("button1");
EventBus.getDefault().post(model);
这样整个环境已经搭建完成。
三、ThreadMode,分为五类模式
1、ThreadMode.POSTING
订阅者将在发布事件的同一线程中调用,这是默认值。事件传递是同步完成的,一旦发布完成,所有订阅者都将被调用。此ThreadMode意味着开销最小,因为它完全避免了线程切换。因此,对于已知完成的简单任务,这是一个推荐的模式,如果在主线程中使用此模式的事件处理程序应该快速返回以避免ANR。简单来说,如果发布者是在主线程发布事件,那么订阅者在主线程且必须是在主线程中进行事件处理,在这种情况下,订阅者是可以尽心UI操作的;若发布者是在子线程中发布事件,那么订阅者在子线程且必须是在子线程中进行事件处理,例:
①主线程,可以进行UI操作
XML视图文件:
<?xml version="1.0" encoding="utf-8"?>
<LinearLayout xmlns:android="http://schemas.android.com/apk/res/android"
android:layout_width="match_parent"
android:layout_height="match_parent"
android:gravity="center"
android:orientation="vertical">
<TextView
android:id="@+id/textView"
android:textColor="#000"
android:text="默认文本"
android:layout_width="wrap_content"
android:layout_height="wrap_content" />
<Button
android:id="@+id/button1"
android:text="button1"
android:layout_width="wrap_content"
android:layout_height="wrap_content" />
</LinearLayout>
逻辑代码:
import android.support.v7.app.AppCompatActivity;
import android.os.Bundle;
import android.util.Log;
import android.view.View;
import android.widget.Button;
import android.widget.TextView;
import com.example.mvptest.R;
import com.example.mvptest.bean.EventModel;
import org.greenrobot.eventbus.EventBus;
import org.greenrobot.eventbus.Subscribe;
import org.greenrobot.eventbus.ThreadMode;
public class MainActivity extends AppCompatActivity implements View.OnClickListener {
private TextView textView;
private Button button1;
@Override
protected void onStart() {
super.onStart();
EventBus.getDefault().register(this);
}
@Override
protected void onCreate(Bundle savedInstanceState) {
super.onCreate(savedInstanceState);
setContentView(R.layout.activity_main);
textView = findViewById(R.id.textView);
button1 = findViewById(R.id.button1);
button1.setOnClickListener(this);
}
@Override
public void onClick(View v) {
switch (v.getId()) {
case R.id.button1:
EventModel model = new EventModel();
model.setFlag(1);
model.setMessage("button1");
EventBus.getDefault().post(model);
break;
}
}
@Subscribe(threadMode = ThreadMode.POSTING)
public void actionEventBus(EventModel model) {
if (model.getFlag() == 1) {
textView.setText(model.getMessage());
}
}
@Override
protected void onStop() {
super.onStop();
EventBus.getDefault().unregister(this);
}
}
在这种情况下,因为发布在主线程中发布事件,对应的订阅者也是在主线程中进行事件操作的,所以UI可以修改。
②子线程,不能进行UI操作
@Override
public void onClick(View v) {
switch (v.getId()) {
case R.id.button1:
new Thread(new Runnable() {
@Override
public void run() {
EventModel model = new EventModel();
model.setFlag(1);
model.setMessage("button1");
EventBus.getDefault().post(model);
}
}).start();
break;
}
}
可以看出,我们创建了一个子线程,在子线程中进行事件发布,这时候UI界面不能进行修改,说明订阅者处理事件也是在子线程中,充分说明了发布者和订阅者是在同一线程中的。
2、ThreadMode.MAIN
当在主线程中时,直接执行发布者方法,到达订阅者,在子线程中效果和ThreadMode.MAIN_ORDERED一样;如果在子线程中时,则将该发布者通过主线程的Handler post到主线程去执行,然后整个流程就和在主线程中执行一样。
3、ThreadMode.MAIN_ORDERED
和ThreadMode.MAIN不同的是,ThreadMode.MAIN_ORDERED不管发布者是在主线程还是在子线程直接执行发布者方法,直接到达订阅者,然后进行UI操作或者其他操作。
ThreadMode.MAIN_ORDERED的原理就是Handler原理,发布者相当于Message,订阅者相当于Looper,Message(发布者)一个个按照顺序排布在MessageQueue中(相当于进栈出栈),Looper(订阅者)按照顺序一个个取出Message。(可以简单的这样理解,并不完全正确。)
4、ThreadMode.BACKGROUND
ThreadMode.BACKGROUND就很好理解了,就是在后台执行,永远不会在前台执行,也就是永远不会在主线程执行,事件处理方法在后台线程中调用,因此不能进行 UI 操作。如果发布事件的线程是主线程 (UI线程),那么事件处理函数将会开启一个后台线程,如果果发布事件的线程是在后台线程,那么事件处理函数就使用该线程
5、ThreadMode.ASYNC
不论事件发布者在主线程还是子线程,事件处理方法(订阅方法)都会重新创建子线程,在新建的子线程中执行订阅方法。