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 () { @Override public UserEvent call(UserEvent userEvent) { return userEvent; } }) .subscribe(new RxBusSubscriber () { @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();复制代码
粘性事件就好比我们在任何时候发送，发送之后如果没有注册者去接收，那么就会缓存到一个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 () { @Override public TestEvent call(TestEvent testEvent) { try { //在这里主动进行异常拦截 } catch (Exception e){ } return testEvent; } }).subscribe(new RxBusSubscriber () { @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); }复制代码 我们来看下效果图吧。
@Override protected void onDestroy() { super.onDestroy(); //这里进行移除 也是可以测试正常的发送事件如果在注册之前发送 是接收不到的 RxSubscriptions.remove(mRxSub); //而这个就是可以的，及时事件发送是在注册之前，但是粘性事件会保留，直到有观察者注册事件并且去接收 RxSubscriptions.remove(mRxStickySub); }复制代码 因为在之前我没有去调用这个销毁(防止内存泄漏),当我在此点击跳转的时候，一般事件也出现了弹框，而且粘性事件出现了3次((>_<)