Android 事件总线OTTO用法快速入门

一、Otto介绍

OTTO是Square推出的库，地址：https://github.com/square/otto

先来看看otto的官方介绍

An enhanced Guava-based event bus with emphasis on Android support.

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基于Guava项目的Android支持库，如果你在Android程序开发的过程中想要不同的组件之间进行有效的通信可以使用这个库。通过otto库可以

降低程序之间的耦合性。

二、基本使用

一个应用场景：通过Activity修改Fragment里面的数据，或者通过Fragment修改Activity里的数据，这种场景还是比较普遍的，那么用Otto怎么做
先看一下我的程序目录：



首先定义一个AppBus类，通过单例模式创建Bus对象，为以后方便的使用Bus对象。

[java] view
plain copy

public class AppBus extends Bus {  

  

    private static AppBus bus;  

  

    public static AppBus getInstance() {  

        if (bus == null) {  

            bus = new AppBus();  

        }  

        return bus;  

    }  

  

}  

BusEventData是我们需要传递的数据，是一个普通的Java Bean

[java] view
plain copy

public class BusEventData {  

    public String content;  

  

    public BusEventData(String content) {  

        this.content = content;  

    }  

  

    public String getContent() {  

        return content;  

    }  

  

    public void setContent(String content) {  

        this.content = content;  

    }  

  

}  

我们希望在Activity里发布一条数据，在Fragment里接收这条数据，先看看TestFragment的代码

[java] view
plain copy

public class TestFragment extends Fragment {  

  

    private EditText mContentET;  

  

    public static TestFragment getInstance() {  

        TestFragment fragment = new TestFragment();  

        // fragment.setArguments(args);  

        return fragment;  

    }  

  

    @Override  

    public View onCreateView(LayoutInflater inflater, ViewGroup container,  

            Bundle savedInstanceState) {  

        View view = inflater.inflate(R.layout.fragment_test, container, false);  

        mContentET = (EditText) view.findViewById(R.id.content);  

        return view;  

    }  

  

    /** 

     * 接收MyScrollView中onScrollChanged的变化  

     */  

    @Subscribe  

    public void onMyScrollChange(ScrollEventData data) {  

        System.out.println("====" + data);  

    }  

  

    @Override  

    public void onStart() {  

        super.onStart();  

        //注册到bus事件总线中  

        AppBus.getInstance().register(this);  

    }  

  

    @Override  

    public void onStop() {  

        super.onStop();  

        AppBus.getInstance().unregister(this);  

    }  

  

    /** 

     * 定义订阅者，Activity中发布的消息，在此处会接收到，在此之前需要先在程序中register，看 

     * 上面的onStart和onStop函数 

     */  

    @Subscribe  

    public void setContent(BusEventData data) {  

        mContentET.setText(data.getContent());  

    }  

  

    @Subscribe  

    public void onDataChange(String sss) {  

        System.out.println("====" + sss);  

    }  

}  

可以看到在setContent方法用@Subscribe注解标志，表示此方法可以接收到数据的变化，对应的参数是BusEventData类型。再来看看MainActivity中是如何发布消息的

[java] view
plain copy

public class MainActivity extends Activity {  

  

    @Override  

    protected void onCreate(Bundle savedInstanceState) {  

        super.onCreate(savedInstanceState);  

        setContentView(R.layout.activity_main);  

        FragmentManager manager = getFragmentManager();  

        FragmentTransaction transaction = manager.beginTransaction();  

        transaction.replace(R.id.container, TestFragment.getInstance());  

        transaction.commit();  

    }  

  

    public void doOnClick(View view) {  

        switch (view.getId()) {  

        case R.id.btn:  

            AppBus.getInstance().post(new BusEventData("somebody alive"));  

            break;  

        case R.id.btn2:  

            AppBus.getInstance().post("hello");  

            break;  

        default:  

            break;  

        }  

    }  

  

    @Override  

    protected void onPause() {  

        super.onPause();  

//      AppBus.getInstance().unregister(this);  

    }  

  

    @Override  

    protected void onResume() {  

        super.onResume();  

//      AppBus.getInstance().register(this);  

    }  

  

      

//  

//  @Produce  

//  public BusEventData produceFragmentData() {  

//      return new BusEventData("This data com from activity");  

//  }  

}  

通过点击btn按钮，同步Bus发布了一条数据类型是BusEventData的数据，然后Bus在事件总线中查找注册的类，在相应的类中找到@subscrible标志的方法，查看参数是否一致，如果相同，就调用这个方法，这个时候你会发现TestFragment收到这条数据。

上面就是基本用法，你可能会觉得为什么要搞这么麻烦，在Activity里直接调用Frament,然后设置参数就好了？！

有几点原因：
1.假如Activity中有多个Fragment都要接收相应的数据的话，otto很适合

2.降低了Activity和Fragment的耦合性，Activity和Fragment之间相互调用减少了

三、延伸拓展

再举一个典型的用法，我们在开发的时候经常监听用到ScrollView里滑动的变化以满足加载更多或者触发一些操作，那这个通过otto怎么做呢。我们可以在自定义的Scrollview里post消息，在需要的地方监听，比如TestFragment的onMyScrollChange方法。看下自定义的MyScrollView类的定义

[java] view
plain copy

public class MyScrollView extends ScrollView {  

  

    public MyScrollView(Context context, AttributeSet attrs, int defStyleAttr) {  

        super(context, attrs, defStyleAttr);  

    }  

  

    public MyScrollView(Context context, AttributeSet attrs) {  

        super(context, attrs);  

    }  

  

    public MyScrollView(Context context) {  

        super(context);  

    }  

  

    @Override  

    protected void onScrollChanged(int l, int t, int oldl, int oldt) {  

        // TODO Auto-generated method stub  

        super.onScrollChanged(l, t, oldl, oldt);  

        //发布消息，TestFragment中注册了对此事件的监听，它会收到数据  

        AppBus.getInstance().post(new ScrollEventData(l, t, oldl, oldt));  

    }  

  

    @Override  

    protected void onOverScrolled(int scrollX, int scrollY, boolean clampedX,  

            boolean clampedY) {  

        // TODO Auto-generated method stub  

        super.onOverScrolled(scrollX, scrollY, clampedX, clampedY);  

    }  

  

}  

你会发现通过这种方式你的TestFragment和ScrollView简洁了很多。耦合性大大降低。如果用普通的方式你还需要定义一个接口，然后再TestFragment里实现这个接口等等。

四、总结

通过使用设计模式，看上去好像做了很多代码，但是在程序的设计上更加优美。