一篇RxJava友好的文章（一）

深藏阁楼爱情的钟 2022-07-15 16:37 208阅读 0赞

> 转载请标明出处：  
> [http://blog.csdn.net/forezp/article/details/52886700][http_blog.csdn.net_forezp_article_details_52886700]  
> 本文出自[方志朋的博客][Link 1]

Rxjava在目前的开发中已经是如火如荼，非常的流行，唯一的就是上手不太容易，学习成本高，学习rxjava有一段时间了，也看了[老罗的rxjava视频][rxjava]，决定自己总结下。

另外欢迎star我的另一个项目,[瓣呀，一个基于豆瓣API模仿网易云音乐的开源app][API_app]

### 准备 ###

在android工程中的gradle.build中配置，为了更好的理解，所以导入java8 的lambda 表达式。

compile 'io.reactivex:rxjava:1.2.1'
    compile 'io.reactivex:rxandroid:1.2.1'

### 基础 ###

rxjava 中有两个核心的对象Observable（被观察者，它会发出一系列的事件源）和Subscribers（观察者，接受事件源），Observable发出事件后，中间可以有一系列的操作、变化，可以精确的控制事件，最终被观察者所接收。其中Observable每发出一个事件就会，就会调用他的subscriber 的onext()，直到发生错误onerror()或onComplete()结束。

1.用Observable.create去创建一个Observable对象，并发射一个"hi Rxjava"，就结束。

Observable<String> observable= Observable.create(
          new Observable.OnSubscribe<String>() {    
       @Override   
       public void call(Subscriber<? super String>    subscriber)
       {  
          subscriber.onNext("hi RxJava");           
          subscriber.onCompleted();   
      }});

然后，我们需要去创建一个subscriber去处理observable发射过来的数据。

Subscriber<String> subscriber=new Subscriber<String>() {
       @Override  
       public void onCompleted() {     
          Log.e(TAG,"onCompleted"); 
       }   
      @Override  
       public void onError(Throwable e) {                    
          Log.e(TAG,e.getMessage());   
       }    
      @Override
      public void onNext(String s) {     
          Log.e(TAG,s);   
      }};

最后需要，subscribe函数把observable对象和subscriber对象关联起来，这样就完成了subscriber对observable的订阅。

observable.subscribe(subscriber);

程序运行一下：  
![在这里插入图片描述][20190601123715800.png]  
可能你觉得这样太复杂了，但是涉及到了与之前不一样的变成思想，即响应式编程。

2.用just去创建observable，just英语意思是仅仅的意思，如果只发出一个事件可以用这种方式。另外在创建Subscriber的时候，如果仅仅关心onNext()，这时可以用Action1这个对象。

Observable.just("hi Rxjava2").subscribe(new Action1<String>() {    
       @Override 
       public void call(String s) {       
          Log.e(TAG,s);  
      }});

运行程序：

![在这里插入图片描述][2019060112372911.png]

3.用from创建observable，这种方式创建，需要传入一个集合，它会一个一个的发射，在subscriber上它会一个一个的接收。

String [] strs={"1","2","3","4"};
    Observable.from(Arrays.asList(strs))
    .subscribe(new Action1<String>() {   
       @Override   
        public void call(String s) {       
            Log.e(TAG,s);    
     }});

运行程序：

![在这里插入图片描述][20190601123743279.png]

是不是有点像高级for循环－.－ 。

4.操作符map，是用在observable和subcriber中间，是为了操作observable发射的数据，操作之后的数据，会被subcriber 接收。rxjava有很多操作符，map操作符是将一个事件转换为另一个事件的。

Observable.just("hi rxjava")
    .map(new Func1<String, String>() {  
      @Override    
      public String call(String s) {    
        return s+" ,你好rxjava";   
       }})
    .subscribe(new Action1<String>() {    
         @Override    
         public void call(String s) {    
            Log.e(TAG,s);   
      }});

运行程序：

![在这里插入图片描述][20190601123800843.png]

另外,map操作符可以将转换类型，比如string 转int .

Observable.just("hi rxjava")
    .map(new Func1<String, Integer>() { 
       @Override    
        public Integer call(String s) { 
           return s.hashCode();    
       }})
    .subscribe(new Action1<Object>() { 
       @Override  
        public void call(Object s) {    
           Log.e(TAG,s+"");   
     }});

5.flatmap操作符  
flatMap操作符接收一个Observable的输出作为输入，同时输出另外一个Observable。在flatMap操作符中，我们可以做一系列的事情，然后输出的新的Observable，这个Observable是我们在Subscriber想要接收的。

首先Observable发出一个list , 然后经过flatmap 将其变成from创建的Observable，这个Observable将list中的元素一个一个的发射，然后，subcriber 中接收。

运行程序：

![在这里插入图片描述][20190601123819345.png]

6.filter 操作符，对Observable发射的数据进行过滤操作，哪有subcriber接收 ，哪些不接收。

Observable.create(new Observable.OnSubscribe<List<String>>() {    
       @Override 
       public void call(Subscriber<? super List<String>> subscriber) {        
          String [] strs={"1","2","3","4","5","6","7"};          
          subscriber.onNext(Arrays.asList(strs));   
       }})
    .flatMap(new Func1<List<String>, Observable<?>>() {    
       @Override 
       public Observable<?> call(List<String> list) {   
         return Observable.from(list);  
      }})
    .filter(new Func1<Object, Boolean>() {//filter 操作符，去掉“1”;    
       @Override 
       public Boolean call(Object o) {        
         if(o.toString().equals("1"))return false;   
         return true;    
    }})
    .subscribe(new Action1<Object>() {
      @Override    
      public void call(Object o) {        
        Log.e(TAG,o.toString()); 
     }});

运行程序：

![在这里插入图片描述][20190601123832185.png]

7.take操作符，固定返回数量。take(2)，返回2个结果。

Observable.create(new Observable.OnSubscribe<List<String>>() {    
      @Override  
      public void call(Subscriber<? super List<String>> subscriber) {        
        String [] strs={"1","2","3","4","5","6","7"};        
        subscriber.onNext(Arrays.asList(strs));    
     }})
    .flatMap(new Func1<List<String>, Observable<?>>() {    
      @Override   
       public Observable<?> call(List<String> list) {  
          return Observable.from(list);  
      }})
    .filter(new Func1<Object, Boolean>() {//filter 操作符，去掉“1”;    
       @Override   
       public Boolean call(Object o) {        
         if(o.toString().equals("1"))return false;     
         return true;    
     }})
    .take(2)
    .subscribe(new Action1<Object>() {//take 操作符，最多输出的数量    
       @Override  
       public void call(Object o) {     
           Log.e(TAG,o.toString());  
      }});

运行程序：

![在这里插入图片描述][20190601123849403.png]

rxjava中还有很多操作符，具体见[官网文档][Link 2]和[中文文档][Link 3]，操作符可以让你对数据流做任何操作。多个操作符配合起来，可以让很复杂的逻辑变得简单，同时，在操作数据的过程中，subcriber并不需要知道中间做了那些操作，只需要知道返回的结果，操作数据也变的简单。

[源码下载][Link 4]

### 优秀文章推荐： ###

*  [史上最简单的 SpringCloud 教程 | 终章][SpringCloud _ _]
 *  [史上最简单的 SpringCloud 教程 | 第一篇: 服务的注册与发现（Eureka）][SpringCloud _ _ _ _Eureka]
 *  [史上最简单的SpringCloud教程 | 第七篇: 高可用的分布式配置中心(Spring Cloud Config)][SpringCloud_ _ _ _Spring Cloud Config]

[http_blog.csdn.net_forezp_article_details_52886700]: http://blog.csdn.net/forezp/article/details/52886700
[Link 1]: http://blog.csdn.net/forezp
[rxjava]: http://www.apkbus.com/forum.php?mod=viewthread&tid=257703&extra=page%3D1%26filter%3Dauthor%26orderby%3Ddateline&_dsign=43e9b95f
[API_app]: https://github.com/forezp/banya
[20190601123715800.png]: /images/20220715/ed0b4a8e5d5d4bcf9447500a6c088e2a.png
[2019060112372911.png]: /images/20220715/dc229c2f9089458787479c5f1d570ef2.png
[20190601123743279.png]: /images/20220715/0a465b299581400e866b5622ac587b97.png
[20190601123800843.png]: /images/20220715/4d850e758f524fe1ba6283f41ecc6551.png
[20190601123819345.png]: /images/20220715/dc36e60e582f4fe5a2434ce0575ef759.png
[20190601123832185.png]: /images/20220715/730f4c896bda4a47aca237271782dbfa.png
[20190601123849403.png]: /images/20220715/23509e96ab0647b5b77c34520a78218b.png
[Link 2]: http://reactivex.io/RxJava/javadoc/
[Link 3]: https://mcxiaoke.gitbooks.io/rxdocs/content/
[Link 4]: https://github.com/forezp/RxJavaDemo
[SpringCloud _ _]: http://blog.csdn.net/forezp/article/details/70148833
[SpringCloud _ _ _ _Eureka]: http://blog.csdn.net/forezp/article/details/69696915
[SpringCloud_ _ _ _Spring Cloud Config]: http://blog.csdn.net/forezp/article/details/70037513