RxBus的实现及简单使用

Hancock_Xu 发布于2019-06-24 19:35 / 2168人阅读

摘要：相信大多数开发者都使用过，作为事件总线通信库，如果你的项目已经加入和，不妨用代替，以减少库的依赖。只会把在订阅发生的时间点之后来自原始的数据发射给观察者。

原文链接：http://lingyunzhu.github.io

RxJava目前已经很火了，如果你尚未了解请看这里。对于RxJava这里不多做介绍。
RxBus并不是一个库，而是一种模式。相信大多数开发者都使用过EventBus，作为事件总线通信库，如果你的项目已经加入RxJava和EventBus，不妨用RxBus代替EventBus，以减少库的依赖。

一、添加RxJava和RxAndroid依赖

    //RxJava and RxAndroid
    compile "io.reactivex:rxandroid:1.1.0"
    compile "io.reactivex:rxjava:1.1.0"

二、新建RxBus类

不多说直接上代码：

import rx.Observable;
import rx.subjects.PublishSubject;
import rx.subjects.SerializedSubject;
import rx.subjects.Subject;

/**
 * Created by xialo on 2016/6/28.
 */
public class RxBus {

    private static volatile RxBus mInstance;

    private final Subject bus;


    public RxBus()
    {
        bus = new SerializedSubject<>(PublishSubject.create());
    }

    /**
     * 单例模式RxBus
     *
     * @return
     */
    public static RxBus getInstance()
    {

        RxBus rxBus2 = mInstance;
        if (mInstance == null)
        {
            synchronized (RxBus.class)
            {
                rxBus2 = mInstance;
                if (mInstance == null)
                {
                    rxBus2 = new RxBus();
                    mInstance = rxBus2;
                }
            }
        }

        return rxBus2;
    }


    /**
     * 发送消息
     *
     * @param object
     */
    public void post(Object object)
    {

        bus.onNext(object);

    }

    /**
     * 接收消息
     *
     * @param eventType
     * @param 
     * @return
     */
    public  Observable toObserverable(Class eventType)
    {
        return bus.ofType(eventType);
    }
}

1、Subject同时充当了Observer和Observable的角色，Subject是非线程安全的，要避免该问题，需要将 Subject转换为一个 SerializedSubject，上述RxBus类中把线程非安全的PublishSubject包装成线程安全的Subject。
2、PublishSubject只会把在订阅发生的时间点之后来自原始Observable的数据发射给观察者。
3、ofType操作符只发射指定类型的数据，其内部就是filter+cast

三、创建你需要发送的事件类

我们这里用StudentEvent举例

/**
 * Created by xialo on 2016/6/28.
 */
public class StudentEvent {
    private String id;
    private String name;

    public StudentEvent(String id, String name) {
        this.id = id;
        this.name = name;
    }

    public String getId() {
        return id;
    }

    public void setId(String id) {
        this.id = id;
    }

    public String getName() {
        return name;
    }

    public void setName(String name) {
        this.name = name;
    }
}

四、发送事件

RxBus.getInstance().post(new StudentEvent("007","小明"));

五、接收事件

rxSbscription=RxBus.getInstance().toObserverable(StudentEvent.class)
                .subscribe(new Action1() {
                    @Override
                    public void call(StudentEvent studentEvent) {
                        textView.setText("id:"+ studentEvent.getId()+"  name:"+ studentEvent.getName());
                    }
                });

注：rxSbscription是Sbscription的对象，我们这里把RxBus.getInstance().toObserverable(StudentEvent.class)赋值给rxSbscription以方便生命周期结束时取消订阅事件

六、取消订阅

@Override
    protected void onDestroy() {
        if (!rxSbscription.isUnsubscribed()){
            rxSbscription.unsubscribe();
        }
        super.onDestroy();
    }

参考：
http://wuxiaolong.me/2016/04/...

超融合服务器混合云 linux的安装及使用 js实现的简单特效用c实现简单的shell java实现简单的web服务器

文章版权归作者所有，未经允许请勿转载,若此文章存在违规行为，您可以联系管理员删除。

转载请注明本文地址：https://www.ucloud.cn/yun/12950.html

Rx系列学习 - 收藏集 - 掘金

摘要：最近开始转移到掘金。要解决的问题支持切换网络请求地址，例如实现掘金前言以前在项目中使用，来进行事件通知与订阅。因此精华翻译掘金本人学习完了后，将值得重点注意的变化进行了翻译和归纳，适合正在使用的同学快速了解如果错误欢迎批评指正。收藏安卓开发中非常实用优秀的库! 有图有真相! - Android - 掘金本来是打算收藏工具类的,但转念一想,已经有这么多优秀的库了,就没必要再去重复造轮子...

kidsamong 2019-06-25 11:14 评论0 收藏0
Android动态设置主题（使用RxBus模式）

摘要：之前写过一篇文章的实现及简单使用。今天我们尝试使用动态切换主题。注意，需要变换主题的需继承参考之前写过一篇文章：RxBus的实现及简单使用。今天我们尝试使用RxBus动态切换主题。一、定义主题颜色 color.xml #F44336 #D32F2F #F44336 #E91E63 #C2185B #E91E63 #7955...

geekzhou 2019-06-24 19:36 评论0 收藏0
从 RxBus 这辆兰博基尼深入进去

摘要：今天看到天哥在群里分享了一把，自己也加入了讨论，下来还实践了一把，所以想借此篇进入到源码层，深刻体验下这辆兰博基尼的设计美感和独特魅力。通过类图可以看到有三个标识标识标识标识与回调一致。这辆兰博基尼与车间搭配更好。很早之前有看过别人实现的 RxBus , 当初也只是随意用用而已，没有想过去研究。今天看到 brucezz 天哥在群里分享了一把，自己也加入了讨论，下来还实践了一把，所以想...

acrazing 2019-06-25 10:40 评论0 收藏0
RxJava学习(四利用RxJava打造自己的RxBus)

摘要：前面说过的功能很强大，不仅仅是实现链式的异步操作，它的功能很强大还可以通过实现的消息事件传递功能，我们来看看使用实现继承了类又实现了接口，可以同时担当订阅者和被订阅者的角色一个类产生多个对象，用一存储起来，以进行批量的取消订阅。前面说过Rxjava的功能很强大，不仅仅是实现链式的异步操作，它的功能很强大还可以通过RxBus实现EventBus的消息/事件传递功能，我们来看看 RxBus ...

番茄西红柿 2019-04-23 17:23 评论0 收藏0
Android组件化方案及组件消息总线modular-event实战

摘要：美团其他团队组件化方案调研美团收银美团收银的组件化方案支持接口调用和消息总线两种方式，接口调用的方式需要构建，然后调用，最后在统一的中进行处理。美团美团的组件化方案采用的形式，这是一种典型的接口调用组件通信方式。背景组件化作为Android客户端技术的一个重要分支，近年来一直是业界积极探索和实践的方向。美团内部各个Android开发团队也在尝试和实践不同的组件化方案，并且在组件化通...

msup 2019-06-25 12:33 评论0 收藏0