美文网首页Android知识Android开发Android技术知识
Rx实现事件总线(类似于EventBus)总结

Rx实现事件总线(类似于EventBus)总结

作者: 菜鸟_一枚 | 来源:发表于2017-01-06 11:49 被阅读172次

RxBus demo解析

标签(空格分隔): RxJava


前言

这里使用的是Rx实现的事件总线,类似于EventBus和Otto,使用rx实现,有效的减少jar大小,并且使用和EventBus差不多,也是发送事件,然后被观察者订阅事件并在接收到事件之后做响应的处理。

例子(用在这里不是很好(毕竟就两个activity,更好的可以通过回调))

这里使用的是登录,如果登录成功,就在LoginActivity里面发送一个UserEvent事件,然后在MAinActivity里面进行注册事件,并对注册之后接收到的事件进行处理。
LoginActivity.class里面逻辑

                                mDataBean = user.getData();
                                if (mDataBean != null){
                                    String username = mDataBean.getUsername();
                                    String imageUrl = mDataBean.getLogo_url();
                                    String useremail = mDataBean.getEmail();
                                    UserEvent event = new UserEvent(username,imageUrl,useremail);
                                    RxBus.getDefault().post(event);
                                    new Handler().postDelayed(new Runnable() {
                                        @Override
                                        public void run() {
                                            mBuilder.build().dismiss();
                                            LoginActivity.this.finish();
                                        }
                                    },500);
                                }
                       

MainActivity.class里面逻辑

 /**
     * 接受到事件并做相关处理
     */
    private void subscribeEvent(){
        RxSubscriptions.remove(mRxSub);
        mRxSub = RxBus.getDefault().toObservable(UserEvent.class)
                .map(new Func1<UserEvent, UserEvent>() {
                    @Override
                    public UserEvent call(UserEvent userEvent) {
                        return userEvent;
                    }
                })
                .subscribe(new RxBusSubscriber<UserEvent>() {
                    @Override
                    public void onEvent(UserEvent userEvent) {
                        if (userEvent != null){
                            mTvEmail.setText(userEvent.mUserEmail);
                            mTvName.setText(userEvent.mUserName);
                            Glide.with(MainActivity.this)
                                    .load(userEvent.mImageUrl).asBitmap()
                            .into(mIvAvator);
                        }
                    }

                    @Override
                    public void onError(Throwable e) {
                        super.onError(e);
                    }
                });
    }

当然了,不要忘记注册事件监听

  /*注册订阅RxBus事件*/
        subscribeEvent();

这个时候就可以实现,当登录成功之后返回,用户名和头像等详情信息就会更新.其实这个逻辑还是很适合的,毕竟如果左侧有用户名和头像,而且主页的title的左侧也是一个头像的话,利用这个逻辑,还是很合适的。并且同一个被观察者可以被多个观察者订阅。逻辑代码是一样的,注册订阅同一个被观察者就行。

待续(粘性事件)

有的时候我们可能会在注册观察者之前就去发送了事件,但是如果我们直接发送了一般的事件,那么由于我们没有注册接收事件,这个时候我们即使后来注册了接收事件,那么也是接收不到的,这个时候我们就想到了粘性事件。

粘性事件就好比我们在任何时候发送,发送之后如果没有注册者去接收,那么就会缓存到一个cache中,等待观察者接收,等到观察者注册之后接收并且去消费。当然了RxBus的粘性事件只会被消费最后一个被保存的事件。

我们先来看下如下的一个例子。

这里我们先发送一个粘性事件,当然例子当中为了对比,我们的一般事件和粘性事件都在点击的时候触发

 mTest.setOnClickListener(new View.OnClickListener() {
            @Override
            public void onClick(View v) {
                RxBus.getDefault().post(new TestEvent("Normal Ceshi"));
                RxBus.getDefault().postSticky(new TestEvent("Sticky Ceshi"));
                startActivity(new Intent(MainActivity.this,TestActivity.class));
            }
        });

当然了,虽然都触发,但是我们传递的消息是不通的(便于对比),这个时候我们在跳转之后的TestActivity里面进行观察者注册和接收。
我们看下逻辑写法。(当然一般的注册和以上的代码是一样的,这里就不写了,直接上粘性事件注册)

 /**
     * 接受粘性事件并做相关处理
     */
    public void subscribeStickyEvent(){
        if (mRxStickySub != null && !mRxStickySub.isUnsubscribed()){
            RxSubscriptions.remove(mRxStickySub);  //移除
        } else {
            TestEvent testEvent = RxBus.getDefault().getStickyEvent(TestEvent.class);

            mRxStickySub = RxBus.getDefault().toObservableSticky(TestEvent.class)
                    .map(new Func1<TestEvent, TestEvent>() {
                        @Override
                        public TestEvent call(TestEvent testEvent) {
                            try {
                            //在这里主动进行异常拦截
                            } catch (Exception e){

                            }
                            return testEvent;
                        }
                    }).subscribe(new RxBusSubscriber<TestEvent>() {
                        @Override
                        public void onEvent(TestEvent testEvent) {
                            Toast.makeText(TestActivity.this, testEvent.test, Toast.LENGTH_SHORT).show();
                        }

                        @Override
                        public void onError(Throwable e) {
                            super.onError(e);
                        }
                    });
        }

        RxSubscriptions.add(mRxStickySub);
    }

我们来看下效果图吧。


注意

一定要在activity或者fragment销毁的时候调用

 @Override
    protected void onDestroy() {
        super.onDestroy();
        //这里进行移除  也是可以测试正常的发送事件如果在注册之前发送  是接收不到的
        RxSubscriptions.remove(mRxSub);
        //而这个就是可以的,及时事件发送是在注册之前,但是粘性事件会保留,直到有观察者注册事件并且去接收
        RxSubscriptions.remove(mRxStickySub);
    }

因为在之前我没有去调用这个销毁(防止内存泄漏),当我在此点击跳转的时候,一般事件也出现了弹框,而且粘性事件出现了3次(~~~(>_<)~~~)。
基本上以上就可以满足一般的项目用法。

代码传送门

https://github.com/wuyinlei/RxBus

感谢作者

感谢@YoKey,有兴趣的可以看下http://www.jianshu.com/p/ca090f6e2fe2
再次谢谢作者,这里我只是学习记录。方便于自己以后查找。

相关文章

  • Rx实现事件总线(类似于EventBus)总结

    RxBus demo解析 标签(空格分隔): RxJava 前言 这里使用的是Rx实现的事件总线,类似于Even...

  • EventBus和RxBus的使用

    EventBus介绍: Rx:函数响应式编程,EventBus:事件总线 。EventBus 功能类似handle...

  • [Flutter]EventBus的使用和底层实现分析

    什么是EventBus EventBus是全局事件总线,底层通过Stream来实现;它可以实现不同页面的跨层访问,...

  • EventBus的使用

    什么是EventBus EventBus是全局事件总线,底层通过Stream来实现;它可以实现不同页面的跨层访问,...

  • EventBus

    一、EventBus的原理 EventBus是全局事件总线,底层通过Stream来实现;它可以实现不同页面的跨层访...

  • DDD-事件总线实现架构原理分析

    DDD-事件总线实现架构原理分析(修订版) @大鹏开源:别看我有点萌,我可以秒变大鹏 事件总线(EventBus)...

  • Android搭建应用框架系列之RxBus

    前言 项目中,往往少不了事件总线,以前一般使用EventBus,但现在由于Rx系列的强大,也就投入了RxBus的怀...

  • [Android组件解读] EventBus3.0解析

    记得前段时间讲解过otto事件总线的概念,但是大家习惯用的事件总线应该还是EventBus。 EventBus介绍...

  • eventBus源码解析

    EventBus定义:是一个发布 / 订阅的事件总线。 发布者,订阅者,事件,总线。 EventBus,可以说,就...

  • Vue的事件总线

    事件总线是什么? EventBus 又称为事件总线。在Vue中可以使用 EventBus 来作为沟通桥梁的概念,就...

网友评论

    本文标题:Rx实现事件总线(类似于EventBus)总结

    本文链接:https://www.haomeiwen.com/subject/vkwtbttx.html