写作原因:没有EventBus之前,Android中各组件之间的通信常常基于广播或者接口等等,写法繁杂而且容易使代码混乱。而事件总线的出现及时地解决了这个问题。下面跟着我的思路一起看看EventBus和Otto的使用吧,两者类似自行取其一,不过一起学习有利于更好地理解事件总线的思想。如果对于Square其他框架有兴趣了解可以点击:
https://github.com/square/otto
https://github.com/greenrobot/EventBus
事件总线是一个发布 / 订阅的事件总线。包含4个成分:发布者,订阅者,事件,总线。订阅者订阅事件到总线,发送者发布事件。(来自鸿洋大神的博客)官网上面的图片很好地展示了它的原理:
说白了是观察者模式的一种应用,关于观察者模式可以联系RxJava进行理解: Square全家桶前传——RxJava函数式编程入门(一) ,个人感觉还是直接把步骤放出来,读者可以结合步骤自行操作更容易理解使用。下面开始讲述EventBus和Otto的使用,导入依赖这里就不再讲述了。
下面以实现在SecondActivity向MainActivity发送信息为例讲解EventBus的使用:
1.创建事件类(理解为用于通信的数据),如:
public class Event {
private String message;
public Event(String s){
message = s;
}
public String getMessage() {
return message;
}
}
2.在接收信息方(观察者)注册和反注册,代码如下:
注册: EventBus.getDefault().register(this);
反注册: EventBus.getDefault().unregister(this);
3.在接收信息方重写回调函数,这里有四种函数供选择,注意 @Subscribe
注解,代码如下:
onEventMainThread//代表这个方法会在UI线程执行
onEventPostThread//代表这个方法会在当前发布事件的线程执行
onEventBackgroundThread//这个方法,如果在非UI线程发布的事件,则直接执行,和发布在同一个线程中。如果在UI线程发布的事件,则加入后台任务队列,使用线程池一个接一个调用。
onEventAsync //加入后台任务队列,使用线程池调用,注意没有BackgroundThread中的一个接一个。
4.根据需要发送消息,代码如下:
EventBus.getDefault().post(new Event(“Message”));
就是这么简单的操作即可完成各组件之间通信的问题。
下面附上详细的代码:
布局:MainActivity中一个TextView和一个Button,SecondActivity中一个Button
Java:
MainActivity.java:
public class MainActivity extends AppCompatActivity {
private Button mBtJump;
private TextView mTvMessage;
@Override
protected void onCreate(Bundle savedInstanceState) {
super.onCreate(savedInstanceState);
setContentView(R.layout.activity_main);
EventBus.getDefault().register(this);
mBtJump = (Button) findViewById(R.id.bt_jump);
mTvMessage = (TextView) findViewById(R.id.tv_receiver);
mBtJump.setOnClickListener(new View.OnClickListener() {
@Override
public void onClick(View v) {
Intent intent = new Intent(MainActivity.this,SecondActivity.class);
startActivity(intent);
}
});
}
@Subscribe
public void onEventMainThread(Event event){
mTvMessage.setText(event.getMessage());
}
@Override
protected void onDestroy() {
super.onDestroy();
EventBus.getDefault().unregister(this);
}
}
SecondActivity.java:
public class SecondActivity extends AppCompatActivity {
private Button mBtSender;
@Override
public void onCreate(Bundle savedInstanceState) {
super.onCreate(savedInstanceState);
setContentView(R.layout.activity_second);
mBtSender = (Button) findViewById(R.id.bt_send);
mBtSender.setOnClickListener(new View.OnClickListener() {
@Override
public void onClick(View v) {
EventBus.getDefault().post(new Event("Hello EventBus!"));
}
});
}
@Override
protected void onDestroy() {
super.onDestroy();
}
}
除了EventBus以外,Otto也是实现事件总线的优秀的框架,是Square的亲儿子(由于我先看了EventBus,所以亲儿子就只能放在后面了)其用法与EventBus类似,下面给出Otto的用法:
1.定义一个AppBus类继承Bus类,采用单例模式方便以后调用:
public class AppBus extends Bus {
private static AppBus bus;
public static AppBus getInstance() {
if (bus == null) {
bus = new AppBus();
}
return bus;
}
}
2.创建事件类(与EventBus一样),如:
public class Event {
private String message;
public Event(String s){
message = s;
}
public String getMessage() {
return message;
}
}
3.在接收信息方(观察者)注册和反注册,代码如下:
AppBus.getInstance().register(this);
AppBus.getInstance().unregister(this);
4.在接收信息方重写回调函数,注意@Subscribe注解,代码如下:
public void customName(Event event) {
textView.setText(event.getMessage());
}
5.根据需要发送消息,代码如下:AppBus.getInstance().post(new Event(“message”));
补充:Otto可以使用@Produce注解实现事件的产生,下面的例子正是使用@Produce注解事件产生方法。
BusProvider.getInstance().post(produceEvent());
@Produce
public MessageEvent produceEvent() {
return new MessageEvent("message");
}
(来自非著名程序员)从事件订阅的处理差别来看:
EventBus和Otto用起来差不多,至于选择哪一个看个人感觉吧,不过既然是Square全家桶,那么使用Otto在兼容性上更有优势。如果会用Rx的话,建议尝试使用Rx来实现通信。