RxJava和EventBus的区别

Posted

tags:

篇首语：本文由小常识网(cha138.com)小编为大家整理，主要介绍了RxJava和EventBus的区别相关的知识，希望对你有一定的参考价值。

参考技术A RxJava和EventBus的区别可分为以下几点：
1、RxJava要比EventBus的应用更广泛，EventBus仅仅是作为一种消息的传递工具，但是RxJava里面几乎可以做任何事情。
2、如果是android开发的话，可以使用RxAndroid，这是对RxJava的一个扩展，结合sqare公司的retrofit可以很轻松的完成网络的访问。
3、在Android中异步操作一般使用AsycTask来完成，但是AsycTask有很多缺点，如不能方便的终止任务的执行等。
4、RxAndroid完全可以替代AsycTask来完成各种异步操作，而且还有BindActivity和BindFragment方法，你根本不需要考虑异步操作时的Activity和Fragment的生命周期问题，还有更加强大的的链式调用，可以使程序很简洁。
两者之间的联系：RxJava和EventBus一样也是基于观察者模式，但是使用的场景确实异步数据流的处理。 参考技术B RxJava和EventBus的区别如下：
1、EventBus是一个时间响应总线，它提供了事件的订阅和发布模式，用户不用关心布线是如何完成的，这就是总线模式的特点
2、RxJava可以允许用户订阅和发布活动，但必须对过程更多的控制权比如，频率，哪个线程的一些活动。
总结：如果用户只关心发布一些事件和表演时收到一些动作 - 可能会更好用最简单的两种，即某种总线，甚至普通的BroadcastReceivers的。如果用户将受益转换数据，处理线程或简化错误处理 - 去为RxJava方法。只要记住这RxJava通常有一个陡峭的学习曲线，所以它需要一些时间来适应它的概念。

RxJava 和 RxAndroid 四（RxBinding的使用）

对Rxjava不熟悉的同学可以先看我之前写的几篇文章

RxJava 和 RxAndroid 一 (基础)
RxJava 和 RxAndroid 二（操作符的使用）
RxJava 和 RxAndroid 三（生命周期控制和内存优化）

另外推荐几篇比较好的文章，有助于理解Rxjava
安卓客户端是如何使用 RxJava 的
通过 RxJava 实现一个 Event Bus – RxBus
玩透RxJava（一）基础知识
RxJava 教程第二部分：事件流基础之 过滤数据
Meizhi Android之RxJava & Retrofit最佳实践

前言：RxBinding 是 Jake Wharton 的一个开源库，它提供了一套在 Android 平台上的基于 RxJava的 Binding API。所谓 Binding，就是类似设置 OnClickListener 、设置 TextWatcher 这样的注册绑定对象的 API。

一：git地址

https://github.com/JakeWharton/RxBinding

二、androidStudio 使用

一般的包下面就用

compile \'com.jakewharton.rxbinding:rxbinding:0.4.0\'

v4\'support-v4\' library bindings:

compile \'com.jakewharton.rxbinding:rxbinding-support-v4:0.4.0\'

\'appcompat-v7\' library bindings:

compile \'com.jakewharton.rxbinding:rxbinding-appcompat-v7:0.4.0\'

\'design\' library bindings:

compile \'com.jakewharton.rxbinding:rxbinding-design:0.4.0\'

三、代码示例

  • Button 防抖处理

     button = (Button) findViewById( R.id.bt ) ;

     RxView.clicks( button )
             .throttleFirst( 2 , TimeUnit.SECONDS )   //两秒钟之内只取一个点击事件，防抖操作
             .subscribe(new Action1<Void>() {
                 @Override
                 public void call(Void aVoid) {
                     Toast.makeText(MainActivity.this, "点击了", Toast.LENGTH_SHORT).show();
                 }
             }) ;

  • 按钮的长按时间监听

     button = (Button) findViewById( R.id.bt ) ;

 //监听长按时间
 RxView.longClicks( button)
      .subscribe(new Action1<Void>() {
          @Override
         public void call(Void aVoid) {
         Toast.makeText(MainActivity.this, "long click  ！！", Toast.LENGTH_SHORT).show();
         }
     }) ;

  • listView 的点击事件、长按事件处理

    listView = (ListView) findViewById( R.id.listview );

 List<String> list = new ArrayList<>() ;
     for ( int i = 0 ; i < 40 ; i++ ){
         list.add( "sss" + i ) ;
     }

 final ArrayAdapter<String> adapter = new ArrayAdapter<String>(this, android.R.layout.simple_expandable_list_item_1 );
     adapter.addAll( list );

 listView.setAdapter( adapter );

 //item click event
 RxAdapterView.itemClicks( listView )
     .subscribe(new Action1<Integer>() {
         @Override
         public void call(Integer integer) {
         Toast.makeText(ListActivity.this, "item click " + integer , Toast.LENGTH_SHORT).show();
             }
         }) ;

 //item long click
 RxAdapterView.itemLongClicks( listView)
     .subscribe(new Action1<Integer>() {
         @Override
         public void call(Integer integer) {
             Toast.makeText(ListActivity.this, "item long click " + integer , Toast.LENGTH_SHORT).show();
             }
         }) ;

- 用户登录界面，勾选同意隐私协议，登录按钮就变高亮

button = (Button) findViewById( R.id.login_bt );
checkBox = (CheckBox) findViewById( R.id.checkbox );

RxCompoundButton.checkedChanges( checkBox )
    .subscribe(new Action1<Boolean>() {
        @Override
        public void call(Boolean aBoolean) {
            button.setEnabled( aBoolean );
            button.setBackgroundResource( aBoolean ? R.color.button_yes : R.color.button_no );
            }
        }) ;
```

效果图

  • 搜索的时候，关键词联想功能 。debounce()在一定的时间内没有操作就会发送事件。

     editText = (EditText) findViewById( R.id.editText );
 listView = (ListView) findViewById( R.id.listview );

 final ArrayAdapter<String> adapter = new ArrayAdapter<String>(this, android.R.layout.simple_expandable_list_item_1 );
 listView.setAdapter( adapter );

 RxTextView.textChanges( editText )
             .debounce( 600 , TimeUnit.MILLISECONDS )
             .map(new Func1<CharSequence, String>() {
                 @Override
                 public String call(CharSequence charSequence) {
                     //get the keyword
                     String key = charSequence.toString() ;
                     return key ;
                 }
             })
             .observeOn( Schedulers.io() )
             .map(new Func1<String, List<String>>() {
                 @Override
                 public List<String> call(String keyWord ) {
                     //get list
                     List<String> dataList = new ArrayList<String>() ;
                     if ( ! TextUtils.isEmpty( keyWord )){
                         for ( String s : getData()  ) {
                             if (s != null) {
                                 if (s.contains(keyWord)) {
                                     dataList.add(s);
                                 }
                             }
                         }
                     }
                     return dataList ;
                 }
             })
             .observeOn( AndroidSchedulers.mainThread() )
             .subscribe(new Action1<List<String>>() {
                 @Override
                 public void call(List<String> strings) {
                     adapter.clear();
                     adapter.addAll( strings );
                     adapter.notifyDataSetChanged();
                 }
             }) ;

    运行效果

总结：

以上是关于RxJava和EventBus的区别的主要内容，如果未能解决你的问题，请参考以下文章

当EventBus遇上RxJava

EventBus设计之禅

EventBus

Android消息传递之基于RxJava实现一个EventBus - RxBus

（转)Android框架之路——EventBus的使用

（转)Android框架之路——EventBus的使用