Android事件总线之Otto

前言

Otto是一个在Android中的事件总线框架，它是square的一个开源框架，具体介绍点击这里，项目下载点击这里
官方说明：

Otto is an event bus designed to decouple different parts of your application while still allowing them to communicate efficiently.
Forked from Guava, Otto adds unique functionality to an already refined event bus as well as specializing it to the Android platform.

为什么要使用Otto事件总线

通常来说在Android中：
1、Activity与Activity间的传值是通过Intent，值回调是通过startActivityForResult()
2、Activity与Fragment间的传值是通过setArguments，值回调是通过实现onAttach()的Interface方式
3、而Fragment与Fragment间的交互则应该是通过它们关联的Activity作为中间键来交互
4、包括Activity与Service的交互，可能众多同学会采用Binder机制来处理，而其实Binder机制本质也是通过接口回调方式来进行值回调的
5、或者在更复杂的应用场景下，比如：ActivityA跳转到ActivityB，ActivityB跳转到ActivityC，此时需要从ActivityC中获取到用户的操作数据返回到ActivityA和ActivityB中显示，或者在Activity中有多个Fragment，其中一个Fragment里的数据变化需要同步更新其它Fragment的数据变化，这时候如果使用Interface的方式进行它们间的交互则比较复杂，耦合度也高

所以，针对上面这些问题，大多数在处理值交互的问题上类之间都是耦合在一起的，而Otto事件总线框架就是降低各个类间的耦合度的。

Otto事件总线

Otto中真正用到的就只有一个类两个注解三个方法：

  • Bus - 管理注册、注销和发布事件
  • @Produce - 标记该方法是生产者，产生的事件内容为该方法的返回值
  • @Subscribe - 标记该方法是订阅者，表示订阅了一个事件，方法需要修饰符为public，而区分不同的订阅者是通过方法的参数来区分的，且订阅了某事件的所有订阅者都可以收到该事件
  • register(Object obj) - 注册，订阅事件前都需要注册
  • unregister(Object obj) - 注销，放弃之前所有事件的订阅
  • post(Object event) - 发布一个事件，这个事件会被所有标记了@Subscribe注解的方法获得

使用Otto事件总线

首先添加依赖：

1
2
3
4
5
dependencies {
compile 'com.squareup:otto:+'
}

1、为了避免重复创建Bus对象，我们先为Bus创建一个单例对象

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
public class BusProvider {
private volatile static Bus bus = null;
private BusProvider() {
}
public static Bus getInstance() {
if (bus == null) {
synchronized (BusProvider.class) {
bus = new Bus();
}
}
return bus;
}
}

2、创建一个Bean，用来传递各类间的数据

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
public class EventData {
private String content;
public String getContent() {
return content;
}
public void setContent(String content) {
this.content = content;
}
}

3、在MainActivity中注册并且创建订阅者订阅数据

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
public class MainActivity extends AppCompatActivity {
@Override
protected void onCreate(Bundle savedInstanceState) {
super.onCreate(savedInstanceState);
setContentView(R.layout.activity_main);
BusProvider.getInstance().register(this);//订阅事件
Button mButton = (Button) findViewById(R.id.btn);
mButton.setOnClickListener(new View.OnClickListener() {
@Override
public void onClick(View v) {
TestActivity.jumpToTestActivity(MainActivity.this);
}
});
}
@Subscribe
public void subscribeEvent(EventData data){
Log.v("zxy", data.getContent());
}
@Override
protected void onDestroy() {
super.onDestroy();
BusProvider.getInstance().unregister(this);//注销订阅
}
public static void jumpToMainActivity(Context context){
context.startActivity(new Intent(context,MainActivity.class));
}
}

4、在TestActivity中发布事件

发布事件有两种方法：

(1)使用@Produce注解来生产事件，不过它生产事件前它需要注册、生产完事件后需要注销，如果使用这种方法则在跳转到生产者所在的类中则会立即产生事件触发订阅者，即在MainActivity跳转到TestActivity时，会立即产生事件并订阅了该事件的方法会收到该事件，如：

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
public class TestActivity extends AppCompatActivity {
@Override
protected void onCreate(Bundle savedInstanceState) {
super.onCreate(savedInstanceState);
setContentView(R.layout.activity_test);
BusProvider.getInstance().register(this);
}
@Produce
public EventData produceEvent(){
EventData mEventData = new EventData();
mEventData.setContent("hello word!");
return mEventData;
}
@Override
protected void onDestroy() {
super.onDestroy();
BusProvider.getInstance().unregister(this);
}
public static void jumpToTestActivity(Context context){
context.startActivity(new Intent(context, TestActivity.class));
}
}

则在MainActivity跳转到TestActivity时订阅者会马上收到事件，输出的Log信息为：

1
09-06 03:46:16.738 5958-5958/? V/zxy﹕ hello word!

则在MainActivity跳转到TestActivity时订阅者会马上收到事件，输出的Log信息为：

1
09-06 03:46:16.738 5958-5958/? V/zxy﹕ hello word!

(2)通过post()来发布事件，它不需要注册和注销，而且它不会在界面跳转时马上发布事件，而是我们人为的控制该事件什么时候发布，使用如下：

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
public class TestActivity extends AppCompatActivity {
@Override
protected void onCreate(Bundle savedInstanceState) {
super.onCreate(savedInstanceState);
setContentView(R.layout.activity_test);
BusProvider.getInstance().register(this);
}
@Produce
public EventData produceEvent(){
EventData mEventData = new EventData();
mEventData.setContent("hello word!");
return mEventData;
}
@Override
protected void onDestroy() {
super.onDestroy();
BusProvider.getInstance().unregister(this);
}
public static void jumpToTestActivity(Context context){
context.startActivity(new Intent(context, TestActivity.class));
}
}

当我们点击按钮时候，这个事件就发布出去了，而订阅了该事件的方法就会收到，打印的Log为：

1
09-06 03:46:18.738 5958-5958/? V/zxy﹕ hello word!

【注】：发布事件需要发布的是一个Object对象，而且这个对象不能为null，所以在数据量大的时候我们可以创建个Bean类，而传当个数据时候如字符串等则直接传String就好。

可以看到通过Otto事件总线来处理类与类之间的交互，可以使得我们的代码更容易理解，类与类之间也解耦了。

相关文档扩展

可以查看另一篇介绍EventBus的事件总线框架:Android事件总线之EventBus

参考文档

赏

谢谢你请我吃糖果

扫一扫，分享到微信

微信分享二维码

tag:

    缺失模块。
    1、请确保node版本大于6.2
    2、在博客根目录（注意不是yilia根目录）执行以下命令：
    npm i hexo-generator-json-content --save

    3、在根目录_config.yml里添加配置： 

      jsonContent:
    meta: false
    pages: false
    posts:
      title: true
      date: true
      path: true
      text: false
      raw: false
      content: false
      slug: false
      updated: false
      comments: false
      link: false
      permalink: false
      excerpt: false
      categories: false
      tags: true

ARESXIONG 程序猿一枚 爱生活，爱CODING 永远年轻！永远热泪盈眶！