RxBus基于RxJava2.x实现消息事务总线

立即下载用AI写一个

发布时间：2019-12-18

2人 | 浏览：1904次 | 收藏 |

技术：android7.0+jdk1.8

概述

基于RxJava2.x封装RxBus，实现消息传递事务总线

详细

###前言
在Android开发过程中，消息传递是一个非常重要的知识点。消息传递方式很多，最初我们是用 Handler，intent，activity/fragment 回调，偶尔也用SharedPreferences等。基于Rxjava的风靡，后来又有了 RxBus。那么今天就讲讲基于 RxJava2 而作的RxBus的消息传递知识吧。

今天涉及的内容有：
1. RxBus 依赖
2. RxBus的使用
3. RxBus在MainActivity中的使用
4. 效果图和项目结构图

先来波效果图
![](/contentImages/image/20191218/10hbqDeY7pbv44sJuhy.gif)

####一. RxBus 依赖
在你app_module对应的build.gradle中添加如下依赖：
```
dependencies {

//rxandroid2.x
    implementation 'io.reactivex.rxjava2:rxandroid:2.0.1'
    //rxjava2.x
    implementation 'io.reactivex.rxjava2:rxjava:2.1.5'

//其他代码在此省略
    //......

}
```
####二.RxBus的使用
RxBus的使用有以下几个步骤：
1. 注册
2. 传值
3. 注销
- 你可以在你需要接收传值的地方像下面这样注册一个RxBus：
```
        //注册RxBus
        RxBus.getInstance().register(MainActivity.class, new RxBus.OnCallBack() {
            @Override
            public void callBack(Object obj) {
                //接收传过来的值
                //......
            }
        });
```
这里需要注意的是，register第一个传的值是String类型，我们一般传class 的name(全路径)作为String，不一定要是Activity或Fragment哟，只要是一个class的全路径name就行。
- 在你需要传值的时候，你可以像下面这样：
```
//RxBus传值
RxBus.getInstance().post(rxData);
```
post的时候可以传Object，但是在一个app项目中会有多个值传来传去，为了防止消息传递中混淆，我将要传值的数据封装到RxData实体类中(后面会给出RxData代码)，这时RxBus传值则变成(以传一个字符串为例)：
```
                RxData rxData=new RxData();
                rxData.setCode(1);
                rxData.setData("我是rx传值");
                RxBus.getInstance().post(rxData);
```
然后在接收值的时候则这样处理：
```
        //注册RxBus
        RxBus.getInstance().register(MainActivity.class, new RxBus.OnCallBack() {
            @Override
            public void callBack(Object obj) {
                if(obj!=null&&obj instanceof RxData){
                    int code=((RxData) obj).getCode();
                    LogUtil.i("=======code=="+code);
                    
                    switch (code) {
                        case 1:
                            String data=((RxData) obj).getData().toString();
                            
                            break;
                        default:
                            break;
                    }
                }
            }
        });
```
- 最后在使用完RxBus后，要注销RxBus，像下面这样：
```
        //注销RxBus
        RxBus.getInstance().unRegister(MainActivity.class);
```
需要注意的是，注销时传的String要和注册时传的String一 一对应。
####三.RxBus在MainActivity中的使用
下面贴出RxBus在MainActivity中的代码：

```
public class MainActivity extends AppCompatActivity implements View.OnClickListener {

private TextView mTv;
    private Button mBtn;

@Override
    protected void onCreate(@Nullable Bundle savedInstanceState) {
        super.onCreate(savedInstanceState);
        setContentView(R.layout.activity_main);

initData();
        setListener();
    }

private void initData() {
        mTv = findViewById(R.id.tv);
        mBtn = findViewById(R.id.btn);

//注册RxBus
        RxBus.getInstance().register(MainActivity.class, new RxBus.OnCallBack() {
            @Override
            public void callBack(Object obj) {
                if(obj!=null&&obj instanceof RxData){
                    int code=((RxData) obj).getCode();

LogUtil.i("=======code=="+code);

switch (code) {
                        case 1:
                            String data=((RxData) obj).getData().toString();
                            mTv.setText("code="+code+"   data="+data);
                            break;
                        default:
                            break;
                    }

}
            }
        });

}

private void setListener() {
        mBtn.setOnClickListener(this);
    }

@Override
    public void onClick(View v) {
        switch (v.getId()) {
            case R.id.btn:
                test();
                break;
            default:
                break;
        }
    }

private void test() {
        Intent intent=new Intent(MainActivity.this,TestActivity.class);
        startActivity(intent);
    }

@Override
    protected void onDestroy() {
        super.onDestroy();

//注销RxBus
        RxBus.getInstance().unRegister(MainActivity.class);
    }
}
```
在另一个界面TestActivity中传值代码如下：
```
public class TestActivity extends AppCompatActivity {

private TextView mTv;

@Override
    protected void onCreate(@Nullable Bundle savedInstanceState) {
        super.onCreate(savedInstanceState);
        setContentView(R.layout.activity_test);

mTv=findViewById(R.id.tv);

initData();
        setListener();
    }

private void initData(){

}

private void setListener() {
        mTv.setOnClickListener(new View.OnClickListener() {
            @Override
            public void onClick(View v) {
                LogUtil.i("========点击传值====");
                ToastUtil.shortShow("========点击传值====");

RxData rxData=new RxData();
                rxData.setCode(1);
                rxData.setData("我是rx传值");
                RxBus.getInstance().post(rxData);
            }
        });
    }
}
```
####四.效果图和项目结构图
效果图
![](/contentImages/image/20191218/10hbqDeY7pbv44sJuhy.gif)

项目结构图
![](/contentImages/image/20191218/d9RB0hAS7ZInJImPA6h.png)

本实例支付的费用只是购买源码的费用，如有疑问欢迎在文末留言交流，如需作者在线代码指导、定制等，在作者开启付费服务后，可以点击“购买服务”进行实时联系，请知悉，谢谢

感谢

手机上随时阅读、收藏该文章？请扫下方二维码

RxBus基于RxJava2.x实现消息事务总线

概述

详细

相似例子推荐

评论

作者

评分详细

作者例子