RxJava系列之一 初识Rxjava

1.简介

基础知识

响应式代码的基本组成部分是Observables和Subscribers（事实上Observer才是最小的构建块，但实践中使用最多的是Subscriber，因为Subscriber才是和Observables的对应的。）。
Observable发送消息，而Subscriber则用于消费消息。消息的发送是有固定模式的。Observable可以发送任意数量的消息（包括空消息），
当消息被成功处理或者出错时，流程结束。Observable会调用它的每个Subscriber的Subscriber.onNext()函数，并最终以Subscriber.onComplete()或者Subscriber.onError()结束。
这看起来像标准的观察者模式， 但不同的一个关键点是：Observables一般只有等到有Subscriber订阅它，
才会开始发送消息（术语上讲就是热启动Observable和冷启动Observable。热启动Observable任何时候都会发送消息，
即使没有任何观察者监听它。冷启动Observable只有在至少有一个订阅者的时候才会发送消息（我的例子中都是只有一个订阅者）。这个区别对于开始学习RxJava来说并不重要。）。
换句话说，如果没有订阅者观察它，那么将不会起什么作用。

2.第一个Rxjava 程序

好了，想要在项目中使用rxjava， 只需要通过在gradle中添加如下：
compile’io.reactivex:rxjava:1.0.13’ 目前最新版本 (本人使用的是gradle，大家可以通过github查看rxjava的其他部署)

先来写个小实例：

(这里只粘贴了部分代码全部代码请看文章底部)通过RxJava给TextView 设置内容。(这里只是做个演示，并没什么卵用)
先创建Observable

 private Observable<String> cerateObserver() {
        return Observable.create(new Observable.OnSubscribe<String>() {
            @Override
            public void call(Subscriber<? super String> subscriber) {
                subscriber.onNext("第一个RxJava");
                subscriber.onCompleted();
            }
        });


    }
再创建一个 Subscriber
private Subscriber<String> createSubscriber() {
        return new Subscriber<String>() {

            @Override
            public void onCompleted() {
                Log.i(TAG, "on completed");
            }

            @Override
            public void onError(Throwable e) {
                Log.i(TAG, "on error");
            }

            @Override
            public void onNext(String s) {
                Log.i(TAG, "next Value = " + s);
                mTextView.setText(s);
            }
        };
    }

  //最后把他两绑定一下。
 observable.subscribe(subscriber);

OK，效果图出来了。

为了打印那几个字写那么多代码也是醉了。
好吧， 下面看看更简洁的代码。

 //下面的代码乍一看可能难以接受， 慢慢来
        Observable.just("第二个RxjavaDemo").subscribe(new Action1<String>() {
            @Override
            public void call(String s) {
                    mTextView.setText(s);
            }
        });

从上面的代码中，我们用到了两个新的东西
1. Observer的just 和 Action1

其实 Observer为我们提供了很多便捷的快速操作。而just的作用是只发送一次任务，然后结束。而Action我们可以理解为Subscriber的其中一个子部分。
比如： Subscriber里有三个函数 onCompleted onError onNext我们可以把它们理解为三个Action
而Action1代表的是只有一个参数， 类似推理： 会不会有Action2， Action3 等等呢， 等待着大家去发掘
当然，如果大家用的jdk是1.8 的话，可以通过lambdas表达式来优化代码：

Observable.just("第二个RxJavaDemo lambdas").subscribe(t -> mTextView.setText(t));

是不是瞬间感觉碉堡了。

好了，我们已经学会了just的用法。

其实 Observable提供了大量的Operators来简化我们代码的写法。
操作符的作用是在Observable和最终的Subscriber之间修改Observable发出的事件。

下面我们将介绍到：map操作符的简单用法map操作符的作用就是将一个事件转换成另一个事件。
举个例子， 比如说: 服务器现在返回了一段字符串，我需要将字符串重新拼接成新的字符串，并加载数据。
这时，我们就可以通过map操作。

Observable.just(url).map(new Func1<String, String>() {
            @Override
            public String call(String s) {
                return "http://www.baidu.com/" + s;
            }
        }).subscribe(new Action1<String>() {
            @Override
            public void call(String s) {
                mTextView.setText(s);
            }
        });
        //如果你有lamdba
        Observable.just(url).map(f -> "http://www.baidu.com/" + f).subscribe(t -> mTextView.setText(t));

map操作符的特点是： 你传递一个Observable对象给他， 他返回你一个Observable对象， 但是不需要对应Observable的返回类型。下一节我们将详细的介绍map的操作，并且顺带着会通过RxJava的衍伸版RxAndroid来写一个最简单的网络请求。敬请期待。。。
(文章内容参考了官方，以及其他几位大神的作品)

源码地址：点击进入

欢迎关注我的微信公众号：androidesigner
通过微信扫描二维码即可关注。