了解了解RxBus

骑猪看日落 2022-09-30 10:56 15阅读 0赞

# 1.前言 #

今天在网上突然看到说EventBus已经过时了，现在基本上没有人用了，都在有RxBus。看到这，吓了我一跳（心里万只草泥马狂奔，前一阵子才刚刚学完EventBus，现在竟然告诉lz过时了不用了！！！）但是作为一个有强烈求知欲的猿，我马上开始搜索了下RxBus并开始学习，于是有了这一篇文章。

# 2.简介 #

RxBus并不是一个库，而是一种模式(刚开始时以为有统一的标准，后来才发现不是绝对的，只是通过RxJava实现的一种模式)。它跟EventBus一样，都是作为事件总线间通信的桥梁。如果你的项目已经加入RxJava和EventBus，不妨用RxBus代替EventBus，以减少库的依赖。哦，原来并不是EventBus过时了，这个RxBus也是有一定限制的，只不过是2016年的RxJava太火了，才会出现上面的言论。

# 3.具体实现 #

## 1.添加依赖库 ##

compile 'io.reactivex:rxjava:1.1.6'
     compile 'io.reactivex:rxandroid:1.2.1'

## 2.编写RxBus类 ##

public class RxBus { 
        private final Subject<Object, Object> subject = new SerializedSubject<>(PublishSubject.create());
        private final Map<String, Object> tags = new HashMap<>();
    
        private static RxBus rxbus;
    
        public static RxBus getInstance()
        {
            if(rxbus == null)
            {
                synchronized (RxBus.class) {
                    if(rxbus == null) {
                        rxbus = new RxBus();
                    }
                }
            }
            return rxbus;
        }
    
        /** * 发送事件消息 * @param tag 用于区分事件 * @param object 事件的参数 */
        public void post(String tag, Object object)
        {
            subject.onNext(object);
            if(!tags.containsKey(tag))
            {
                tags.put(tag, object);
            }
        }
    
    
        /** * 主线程中执行 * @param tag * @param rxBusResult */
        public void toObserverableOnMainThread(final String tag, final RxBusResult rxBusResult) {
    
            subject.observeOn(AndroidSchedulers.mainThread()).subscribe(new Action1<Object>() {
                @Override
                public void call(Object o) {
                    if (tags.containsKey(tag)) {
                        rxBusResult.onRxBusResult(o);
                    }
                }
            });
        }
    
        /** * 子线程中执行 * @param tag * @param rxBusResult */
        public void toObserverableChildThread(final String tag, final RxBusResult rxBusResult) {
    
            subject.observeOn(Schedulers.io()).subscribe(new Action1<Object>() {
                @Override
                public void call(Object o) {
                    if (tags.containsKey(tag)) {
                        rxBusResult.onRxBusResult(o);
                    }
                }
            });
        }
    
        /** * 移除tag * @param tag */
        public void removeObserverable(String tag)
        {
            if(tags.containsKey(tag))
            {
                tags.remove(tag);
            }
        }
    
        /** * 退出应用时，清空资源 */
        public void release()
        {
            tags.clear();
            rxbus = null;
        }
    }

## 3.使用实例 ##

public class MainActivity extends Activity { 
    
        @BindView(R.id.bt_sendmsg)
        Button bt_sendmsg;
        @BindView(R.id.bt_startactivity)
        Button btStartactivity;
        @BindView(R.id.tv_result)
        TextView tvResult;
    
        private RxBus rxBus = RxBus.getInstance();
        @Override
        protected void onCreate(Bundle savedInstanceState) {
            super.onCreate(savedInstanceState);
            setContentView(R.layout.activity_main);
            ButterKnife.bind(this);
    
            rxBus.toObserverableOnMainThread("first", new RxBusResult() {
                @Override
                public void onRxBusResult(Object o) {
                    final String msg = (String)o;
                    tvResult.setText("first收到消息;" + msg);
                    Toast.makeText(MainActivity.this, "收到消息;" + msg, Toast.LENGTH_SHORT).show();
                }
            });
    
            rxBus.toObserverableOnMainThread("second", new RxBusResult() {
                @Override
                public void onRxBusResult(Object o) {
                    String msg = (String)o;
                    tvResult.setText("second收到消息;" + msg);
                    Toast.makeText(MainActivity.this, "second收到消息;" + msg, Toast.LENGTH_SHORT).show();
                }
            });
    
        }
        发送消息
        @OnClick(R.id.bt_sendmsg)
        public void bt_sendmsg(View view){
            rxBus.post("first", new String("hello rxbus"));
        }
    
        //跳转界面
        @OnClick(R.id.bt_startactivity)
        public void bt_startActivity(View view){
            Intent intent = new Intent(MainActivity.this, SecondActivity.class);
            MainActivity.this.startActivity(intent);
        }
    
        /** * 退出时，释放rxbus */
        @Override
        protected void onDestroy() {
            super.onDestroy();
            rxBus.release();
        }
    
    
    }

## 4.运行效果 ##

![这里写图片描述][SouthEast]

## 5.总结 ##

1、首先创建一个可同时充当Observer和Observable的Subject（单例模式，并且是SerializedSubject）；

2、在需要接收事件的地方，订阅该Subject（此时Subject是作为Observable），在这之后，一旦Subject接收到事件，立即发射给该订阅者；

3、在我们需要发送事件的地方，将事件post至Subject，此时Subject作为Observer接收到事件（onNext），然后会发射给所有订阅该Subject的订阅者。

demo下载：  
[https://github.com/GaoJunGuang/RxBusDemo][https_github.com_GaoJunGuang_RxBusDemo]

参考：  
[http://blog.csdn.net/ywl5320/article/details/51481103][http_blog.csdn.net_ywl5320_article_details_51481103]  
[http://www.jianshu.com/p/ca090f6e2fe2][http_www.jianshu.com_p_ca090f6e2fe2]

[SouthEast]: /images/20220706/6ed3e80ec09a4cbca8891a3e70875c8c.png
[https_github.com_GaoJunGuang_RxBusDemo]: https://github.com/GaoJunGuang/RxBusDemo
[http_blog.csdn.net_ywl5320_article_details_51481103]: http://blog.csdn.net/ywl5320/article/details/51481103
[http_www.jianshu.com_p_ca090f6e2fe2]: http://www.jianshu.com/p/ca090f6e2fe2

发表评论取消回复

表情：

评论列表（有 0 条评论，15人围观）

还没有评论，来说两句吧...

相关阅读

相关 JavaMelody 了解

文章目录一个监控服务器各个参数的工具，比如: SQL.http请求，内存，可以按照天日月等进行统计: [https://blog.csdn.net/hux

墨蓝/ 2022年12月13日 09:59/ 0 赞/ 116 阅读

相关 TypeScript了解

简介 TypeScript是一种由微软开发的开源、跨平台的编程语言。它是JavaScript的超集，最终会被编译为JavaScript代码。 2012年10月，微软发布

我会带着你远行/ 2022年10月18日 01:28/ 0 赞/ 109 阅读

相关了解了解RxBus

1.前言今天在网上突然看到说EventBus已经过时了，现在基本上没有人用了，都在有RxBus。看到这，吓了我一跳（心里万只草泥马狂奔，前一阵子才刚刚学完EventBu

骑猪看日落/ 2022年09月30日 10:56/ 0 赞/ 16 阅读

相关了解-KVM

研究了很久的KVM，感觉是我用过的最快的虚拟机。对比常用的虚拟机，Vmware的功能全面，设置简单，但其速度不是很好；VirtualBox的效率虽然比Vmware高一些，但是存

一时失言乱红尘/ 2022年08月13日 12:42/ 0 赞/ 176 阅读

相关 OAuth了解

只是一个简单的了解。原文章链接 [http://kb.cnblogs.com/page/189153/][http_kb.cnblogs.com_page_189153]

╰+攻爆jí腚メ/ 2022年06月11日 08:26/ 0 赞/ 145 阅读

相关 EDAS 了解

EDAS：Enterprise Distributed Application Service，企业级分布式应用服务。 [阿里 EDAS][EDAS]、但阿里这个是[收费的]

ゝ一世哀愁。/ 2022年05月23日 13:15/ 0 赞/ 135 阅读

相关了解intern(),了解字符串常量池

intern()是String一个api，平时不常用，但是面试可能会考，掌握intern可避免被面试官问到时大眼瞪小眼的尴尬局面。当一个String对象调用intern()

╰半橙微兮°/ 2022年04月22日 13:44/ 0 赞/ 190 阅读

相关了解jdpm

[https://blog.csdn.net/hejingyuan6/article/category/5192917/1][https_blog.csdn.net_hejin

柔情只为你懂/ 2022年04月10日 03:27/ 0 赞/ 212 阅读

相关了解Spring

SSH struts2(servlet) spring(new对象) hibernate(dao) SSM springMVC(servlet) spring(new对象)

r囧r小猫/ 2022年02月03日 11:39/ 0 赞/ 170 阅读

相关了解Hbase

1. 什么是Hbase? Hbase是一款数据库,mysql也是数据库，但是mysql是关系型数据库。Hbases是适合大数据分析的

旧城等待，/ 2021年11月23日 07:10/ 0 赞/ 296 阅读