标签：
AndroidEventBus如果你不知道事件总线是什么，那么没有关系，下面我们先来看这么一个场景：
你是否在开发的过程中遇到过想在Activity-B中回调Activity-A中的某个函数，但Activity又不能手动创建对象来设置一个Listener什么的？ 你是否想在某个Service中想更新Activity或者Fragment中的界面? 等等之类的组件之间的交互问题……
一经思考，你会发现Android中的Activity, Fragment, Service之间的交互是比较麻烦的，可能我们第一想到的是使用广播接收器来在它们之间进行交互。例如上述所说在Activity-B中发一个广播，在Activity-A中注册一个广播接收器来接受该广播。但使用广播接收器稍显麻烦，如果你要将一个实体类当做数据在组件之间传递，那么该实体类还得实现序列化接口，这个成本实在有点高啊！如下所示 :
// ActivityA中注册广播接收器class ActivityA extends Activity {
@Override
protected void onCreate(Bundle savedInstanceState) {
super.onCreate(savedInstanceState);
registerReceiver(new BroadcastReceiver() {
@Override
public void onReceive(Context context, Intent intent) {
User person = intent.getParcelableExtra("user") ;
}
}, new IntentFilter("my_action")) ;
}
// ......
}
// ActivityB中发布广播class ActivityB extends Activity {
@Override
protected void onCreate(Bundle savedInstanceState) {
super.onCreate(savedInstanceState);
Intent intent = new Intent("my_action") ;
intent.putExtra("user", new User("mr.simple")) ;
sendBroadcast(intent);
}
// ......
}
// 实体类实现序列化class User implements Parcelable {
String name ;
public User(String aName) {
name = aName ;
}
// 代码省略
@Override
public void writeToParcel(Parcel dest, int flags) {
dest.writeString(name);
}
}
是不是有很麻烦的感觉！
我们再来看一个示例，在开发过程中，我们经常要在子线程中做一些耗时操作，然后将结果更新到UI线程，除了AsyncTask之外，Thread加Handler是我们经常用的手段。我们看看如下示例:
class MyActivity extends Activity {
Handler mHandler = new Handler () {
public void handleMessage(android.os.Message msg) {
if ( msg.what == 1 ) {
User user = (User)msg.obj ;
// do sth
}
};
} ;
@Override
protected void onCreate(Bundle savedInstanceState) {
super.onCreate(savedInstanceState);
// code ......new Thread(
new Runnable() {
public void run() {
// do sth
User newUser = new User("simple") ;
Message msg = mHandler.obtainMessage() ;
msg.what = 1 ;
msg.obj = newUser ;
mHandler.sendMessage(msg) ;
}
}).start();
}
}是不是又有相当麻烦的感觉！！！此时，你应该冷静下来思考一下，还有哪些情况适合使用事件总线。例如穿透多个类只为一个回调的Listener、……
事件总线框架就是为了简化这些操作而出现的，并且降低组件之间的耦合而出现的，到底如何解决呢？咱们继续看下去吧。
AndroidEventBus是一个Android平台轻量级的事件总线框架, 它简化了Activity、Fragment、Service等组件之间的交互，很大程度上降低了它们之间的耦合，使得我们的代码更加简洁，耦合性更低，提升我们的代码质量。
在往下看之前,你可以考虑这么一个场景,两个Fragment之间的通信你会怎么实现？
按照Android官方给的建议的解决方法如下: Communicating with the Activity,思路就是Activity实现某个接口,然后在Fragment-A关联上Activity之后将Activity强转为接口类型,然后在某个时刻Fragment中回调这个接口,然后再从Activity中调用Fragment-B中方法。这个过程是不是有点复杂呢？ 如果你也这么觉得,那也就是你继续看下去的理由了。
AndroidEventBus类似于观察者模式,通过register函数将需要订阅事件的对象注册到事件总线中,然后根据@Subscriber注解来查找对象中的订阅方法,并且将这些订阅方法和订阅对象存储在map中。当用户在某个地方发布一个事件时,事件总线根据事件的参数类型和tag找到对应的订阅者对象,最后执行订阅者对象中的方法。这些订阅方法会执行在用户指定的线程模型中,比如mode=ThreadMode.ASYNC则表示该订阅方法执行在子线程中,更多细节请看下面的说明。
private void onEventMainThread(User aUser) {
// code
}如果你有两个同参数类型的接收函数，并且都要执行在主线程,那如何命名呢 ？ 即使你有两个符合要求的函数吧,那么我实际上是添加用户的事件,但是由于EventBus只根据事件参数类型来判断接收函数,因此会导致两个函数都会被执行。AndroidEventBus的策略是为每个事件添加一个tag,参数类型和tag共同标识一个事件的唯一性,这样就确保了事件的精确投递。
这就是AndroidEventBus和greenrobot的EventBus的不同,当然greenrobot出于性能的考虑这么处理也可以理解，但是我们在应用中发布的事件数量是很有限的，性能差异可以忽略，但使用体验上却是很直接的。另外由于本人对greenrobot的EventBus并不是很了解,很可能上述我所说的有误,如果是那样,欢迎您指出。
AndroidEventBus起初只是为了学习,但是在学习了EventBus的实现之后,发现它在使用上有些不便之处,我想既然我有这些感觉,应该也是有同感之人,在开发群里交流之后,发现确实有这样的情况。因此才将正式地AndroidEventBus以开源库的形式推出来,希望能够帮助到一些需要的人。当然,这个库的成长需要大家的支持与测试,欢迎大家发 pull request。
你可以按照下面几个步骤来使用AndroidEventBus.
public class YourActivity extends Activity {@Overrideprotected void onCreate(Bundle savedInstanceState) {
super.onCreate(savedInstanceState);
setContentView(R.layout.main_activity);
// 注册对象
EventBus.getDefault().register(this);
}
@Overrideprotected void onDestroy() {
// 不要忘记注销！！！！
EventBus.getDefault().unregister(this);
super.onDestroy();
}
}
public class YourActivity extends Activity {// code ......// 接收方法,默认的tag,执行在UI线程@Subscriberprivate void updateUser(User user) {
Log.e("", "### update user name = " + user.name);
}
// 含有my_tag,当用户post事件时,只有指定了"my_tag"的事件才会触发该函数,执行在UI线程@Subscriber(tag = "my_tag")
private void updateUserWithTag(User user) {
Log.e("", "### update user with my_tag, name = " + user.name);
}
// 含有my_tag,当用户post事件时,只有指定了"my_tag"的事件才会触发该函数,// post函数在哪个线程执行,该函数就执行在哪个线程 @Subscriber(tag = "my_tag", mode=ThreadMode.POST)
private void updateUserWithMode(User user) {
Log.e("", "### update user with my_tag, name = " + user.name);
}
// 含有my_tag,当用户post事件时,只有指定了"my_tag"的事件才会触发该函数,执行在一个独立的线程@Subscriber(tag = "my_tag", mode = ThreadMode.ASYNC)
private void updateUserAsync(User user) {
Log.e("", "### update user async , name = " + user.name + ", thread name = " + Thread.currentThread().getName());
}
}接收函数使用tag来标识可接收的事件类型，与BroadcastReceiver中指定action是一样的,这样可以精准的投递消息。mode可以指定目标函数执行在哪个线程,默认会执行在UI线程,方便用户更新UI。目标方法执行耗时操作时,可以设置mode为ASYNC,使之执行在子线程中。
EventBus.getDefault().post(new User("android"));
// post a event with tag, the tag is like broadcast‘s action
EventBus.getDefault().post(new User("mr.simple"), "my_tag");发布事件之后，注册了该事件类型的对象就会接收到响应的事件.
欢迎star和fork, AndroidEventBus框架 。
标签：
原文地址：http://www.cnblogs.com/ywq-come/p/5926533.html
