在上篇文章我写了一下基于RxJava2的RxBus简单封装,没看过的同学可以简单看下,我们可以看到对外暴露的注册和解绑接口,用户还需要在调用注册方法后,手动管理RxJava2的Disposable或者CompositeDisposable对象,还是不是太方便开发者使用。那怎么改进呢?这里我借鉴EventBus这个开源库的一些思想,通过Java Annotation Processing Tool (apt)生成辅助代码来帮助用户通过简单的api就能实现消息总线的功能
Github
本项目已经放到Github上,欢迎兴趣的同学fork查看示例和源码,同时也欢迎star
目的
旨在App中使用Rxjava2的同学们可以方便通过这个库,来使用类似于EventBus消息总线的功能,这样就不用额外的引入EventBus,增加App的库臃肿
引入
在你的Android Studio中module的build.gradle文件中引入
dependencies {
annotationProcessor 'com.eggsy:rxbus-processor:0.0.4'
compile 'com.eggsy:rxbus:0.0.4'
// RxJava and RxAndroid is necessary
compile 'io.reactivex.rxjava2:rxandroid:2.0.1'
compile 'io.reactivex.rxjava2:rxjava:2.0.4'
}
需要引入rxjava2和rxandroid,如果你的App中没有用到rxjava,那么不建议你使用RxBus库,因为RxBus是基于rxjava2和rxandroid,如果单纯为了使用RxBus额外引入这两个库,我个人觉得是没必要的,完全可以使用EventBus替换
如何使用
使用主要分为
注册
注解事件方法
发出事件
解绑
注册
在Activity,Fragment或者其他任何你的类中(比如Mvp模式中的Presenter
类),都可以用来注册RxBus事件
RxBus.register(this); // 这里的this是指包含了下面注解事件方法的类实例
注解事件方法
@EventSubscribe
public void testboolean(boolean testParam) { // boolean事件
Toast.makeText(this, testParam, Toast.LENGTH_SHORT).show();
}
// tmode, 指定下面方法接收到事件之后,在哪个线程上运行
@EventSubscribe(tmode = ThreadMode.NewThread)
public void test(String testParam) { // String类型事件
Log.i(TAG,"test IoThread, main thread id="+getMainLooper().getThread().getId()+" , result="+testParam);
Log.i(TAG,"test IoThread, curr thread id="+Thread.currentThread().getId()+" , result="+testParam);
Toast.makeText(this, testParam, Toast.LENGTH_SHORT).show();
}
@EventSubscribe
public void testCustomEvent(TestEvent event) { // 自定义事件
Log.i(TAG, "test custom Event, event=" + event.toString());
}
这里的@EventSubscribe注解有两个属性
tmode:指定事件发出时,注解的方法执行的线程,一共有6种模式
PostThread 与发出事件(调用RxBus.post()方法)所在线程使用同一个线程
MainThread 使用App主线程
IoThread 使用一个自增长的线程池中的线程,适合异步阻塞的IO操作
NewThread 使用一个新的线程
SingleThread 使用一个通用的单线程,支持用于主线程到其他线程的管道数据
ComputationThread 使用一个非主线程来做计算型的工作
bpstrategy:指定上游事件发送很快,次数很多,注解方法来不及处理情况,这里指定一个策略,主要有6种策略
DEFAULT 如果不设置,默认该属性,不做任何处理
MISSING 事件在没有任何缓冲或丢弃的情况下写入。注解方法需要处理所有任何溢出
ERROR 在注解方法处理速度不能跟上事件发出速度时,发出一个Exception
BUFFER 缓存事件,等到注解方法消费掉这个事件
DROP 如果注解方法不能跟上事件发送速度,丢弃最近的事件
LATEST 仅保留最新的事件,如果注解方法处理速度跟不上事件发出速度,则覆盖任何先前的值,保留最新事件。
注意:注解方法限定了参数只能有一个,也就是指定接收一个事件触发
发出事件
RxBus.post("eggsy test"); // 发出String类型的事件
RxBus.post(true); // 发出boolean事件
RxBus.post(new Boolean(false)); // 发出Boolean类使劲
RxBus.post(newTestEvent(1,"post event object")); // 当然,还可以发出自定义的对象事件
这里我支持发送的事件类型有两种,一种是java 8种基础类型以及包装类,另外一种自定义类。其中,如果发出的事件类型是基础类型,那么如果注解方法是对应包装类型的事件,也会跟着触发,反之,如果发出的是包装类型的事件,那么注解方法是对应的基础类型,也会跟着触发,比如,发出如下事件
RxBus.post(true); // 发出boolean事件
RxBus.post(new Boolean(false)); // 发出Boolean类使劲
那么下面方法会被触发两次
@EventSubscribe
public void testboolean(boolean testParam) { // boolean事件
Toast.makeText(this, testParam, Toast.LENGTH_SHORT).show();
}
解绑
RxBus.unRegister(this);
在合适的地方,解绑注册事件,这样就收不到后续发出的事件,比如在Activity的onDestory中解绑,这样就形成了一个完整的生命周期
生成辅助类
在编译时,会生成一个_RxBusProxy后缀的辅助类,例如我例子中,
public class MainActivity_RxBusProxy implements RxBusProxy {
protected CompositeDisposable compositeDisposable;
protected MainActivity sourceInstance;
public CompositeDisposable register(MainActivity source) {
sourceInstance = source;
Disposable test4_disposable = RxBusHelper.getDefault().register(String.class, new Consumer() {
@Override
public void accept(String o) throws Exception {
sourceInstance.test4(o);
}
}, io.reactivex.putation());
if (compositeDisposable == null || compositeDisposable.isDisposed()) {
compositeDisposable = new CompositeDisposable();
}
compositeDisposable.add(test4_disposable);
return compositeDisposable;
}
public void unRegister() {
if (compositeDisposable != null && !compositeDisposable.isDisposed()) {
compositeDisposable.dispose();
}
}
}
栗子
具体栗子请参考我的github上的工程RxBus,欢迎大家fork下来玩玩。
总结
RxBus最基本的还是基于RxJava2和RxAndroid,利用Rxjava2中的支持事件在不同线程之间传递,封装出的一个类似于EventBus功能的库,底层还是调用了我上一篇文章中的RxBus类,把事件与Rxjava2结合起来。然后利用Java APT,识别出@EventSubscribe注解和注解内容,动态的根据注解内容,生成注解方法所在类的一个辅助类,在辅助类里面做了register和unregister方法,实现注册和解绑功能。对外封装了api方便调用者根据传入的类类型,找到对应的辅助类,调用register方法。
最后,谢谢大家查看这篇文章,写的不好的或者有问题的,欢迎大家留言交流~~~
如果觉得《rxbus 源码_基于APT的RxBus库》对你有帮助,请点赞、收藏,并留下你的观点哦!