转载

Square全家桶正传——事件总线介绍及EventBus、Otto使用教程

写作原因:没有EventBus之前,Android中各组件之间的通信常常基于广播或者接口等等,写法繁杂而且容易使代码混乱。而事件总线的出现及时地解决了这个问题。下面跟着我的思路一起看看EventBus和Otto的使用吧,两者类似自行取其一,不过一起学习有利于更好地理解事件总线的思想。如果对于Square其他框架有兴趣了解可以点击:

https://github.com/square/otto

https://github.com/greenrobot/EventBus

事件总线定义

事件总线是一个发布 / 订阅的事件总线。包含4个成分:发布者,订阅者,事件,总线。订阅者订阅事件到总线,发送者发布事件。(来自鸿洋大神的博客)官网上面的图片很好地展示了它的原理:
Square全家桶正传——事件总线介绍及EventBus、Otto使用教程
说白了是观察者模式的一种应用,关于观察者模式可以联系RxJava进行理解: Square全家桶前传——RxJava函数式编程入门(一) ,个人感觉还是直接把步骤放出来,读者可以结合步骤自行操作更容易理解使用。下面开始讲述EventBus和Otto的使用,导入依赖这里就不再讲述了。

EventBus的使用

下面以实现在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();

}
}

Otto的使用

除了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");
}

Otto与EventBus的对比

(来自非著名程序员)从事件订阅的处理差别来看:

  1. eventbus是采用反射的方式对整个注册的类的所有方法进行扫描来完成注册;
  2. otto采用了注解的方式完成注册;
  3. 共同的地方缓存所有注册并有可用性的检测。同时可以移除注册;
  4. 注册的共同点都是采用method方法进行一个集成。

总结

EventBus和Otto用起来差不多,至于选择哪一个看个人感觉吧,不过既然是Square全家桶,那么使用Otto在兼容性上更有优势。如果会用Rx的话,建议尝试使用Rx来实现通信。

原文  http://roadtogeek.cn/2016/07/12/Square全家桶正传——事件总线介绍及EventBus、Otto使用教程/
正文到此结束
Loading...