RxJava 之 Hello World-蒲公英云

原理介绍

什么是RxJava

RxJava 就是异步
RxJava 的异步实现，是通过一种扩展的观察者模式来实现的。
一个响应式编程框架

观察者模式应该不陌生，点这里可以重温一下概念。

RxJava组成

RxJava最核心的两个东西是Observable（被观察者，事件源）和Subscriber（观察者）。
Observable发出一系列事件，Subscriber负责处理这些事件。

一个Observable可以发出零个或者多个事件，直到结束或者出错。每发出一个事件，就会调用它的Subscriber的onNext方法，最后调用Subscriber.onComplete()或者Subscriber.onError()结束。

RxJava相较于传统的观察者模式，还有一个特点，就是没有观察者时，主题是不会发送事件的。也就说是当一个Observable连一个Subscriber都没有时，Observable是不会发送事件的。这点和我们上学时，如果一节课一个学生都没来听课的话，那么老师也不会去讲课的道理是一样的。

RxJava之Hello world

RxJava 是一个方便我们实现异步的框架。同时其“响应式编程”的思路，对于我们也是一种挑战。在加上其各种强大的操作符，调度器也是需要一定的学习成本的，姑且就把他当做一门“新的语言”，这里我们就从输出Hello world说起。

看到网上的许多教程都使用了Lambda语法进行编码，这个Lambda虽然很好，但不想在学习RxJava的过程中，增加无畏的难度，所以暂时不采用，代码暂时能看懂才是最要的，好看后期再说！

工程导入

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

完整版Hello World

/**
     * 被观察者，事件源
     */
    private Observable<String> myObserveable;
    /**
     * 观察者
     */
    private Subscriber<String> mySubscriber;

创建被观察者

/**
     * 创建被观察者Observable
     */
    private void InitObserverr() {
        myObserveable = Observable.create(
                new Observable.OnSubscribe<String>() {
                    @Override
                    public void call(Subscriber<? super String> subscriber) {
                        subscriber.onNext("hello world");
                        subscriber.onCompleted();
                    }
                }
        );
    }

创建观察者

/**
     * 创建观察者Subscribe
     */
    private void InitSubscriber() {
        mySubscriber = new Subscriber<String>() {
            @Override
            public void onCompleted() {
            }
            @Override
            public void onError(Throwable e) {
            }
            @Override
            public void onNext(String s) {
                Log.e(MainActivity.class.getSimpleName(), "onNext--->" + s);
                Toast.makeText(MainActivity.this, s, Toast.LENGTH_SHORT).show();
            }
        };
    }

观察者订阅主题（事件源/被观察者）

myObserveable.subscribe(mySubscriber);

这句代码按照“字面意思”，感觉是被观察者订阅了观察者。但实际上，我们在这里实现的是观察者订阅被观察者（主题）。希望不要混淆，并习惯这个逻辑。

一旦mySubscriber订阅了myObservable，myObservable就会调用mySubscriber对象的onNext和onComplete方法，mySubscriber就会打印出Hello World！这里为了方便测试，同时Toast了一个Hello World！

这个订阅的实现，其实很关键。因为我们前面说过，在RxJava中，没有观察者时，被观察者是不会发布事件的。

用强大的RxJava实现Hello World的打印，当然不是我们的初衷，这里只是从最基本的用法做出介绍。

精简版Hello world

简化Observable

RxJava内置了很多简化创建Observable对象的函数，比如Observable.just就是用来创建只发出一个事件就结束的Observable对象，上面创建Observable对象的代码可以简化为一行

Observable<String> myObservable = Observable.just("Hello, world!");

简化Subscribe

有时候，我们其实并不关心OnComplete和OnError，我们只需要在onNext的时候做一些处理，这时候就可以使用Action1类。

Action1<String> onNextAction = new Action1<String>() {  
    @Override  
    public void call(String s) {  
        System.out.println(s);  
    }  
};

subscribe 方法

subscribe方法有一个重载版本，接受三个Action1类型的参数，分别对应OnNext，OnComplete， OnError函数。

myObservable.subscribe(onNextAction, onErrorAction, onCompleteAction);

这样为了仅仅输出一个Hello World ，我们抛弃不重要的部分，代码就可以简化了：

Observable.just("Hello, world!")  
    .subscribe(new Action1<String>() {  
        @Override  
        public void call(String s) {  
              System.out.println(s);  
        }  
    });