在android 上 使用 rxjava 入门篇

时间:2022-01-31 17:46:08

什么是 rxJava?

RxJava is a Java VM implementation of Reactive Extensions: a library for composing asynchronous and event-based programs by using observable sequences.

简单来说,rxJava 是一种 基于事件的,使用了可被观察序列 的异步 响应 扩展 的类库。

这句话有这几个意思:

  rxJava 是解决 异步问题的。

  rxJava 是基于事件机制的。

  rxJava 是处理响应扩展的,解决 事件的响应问题(比如事件的响应在哪个线程?)。

  rxJava 是序列的。它是个有顺序的队列,按顺序的,先进后出的。它对集合对象的支持很好。 

 

 

rxJava 使用了 设计模式里的 观察者模式 来实现。

 

引用类库

   compile 'io.reactivex:rxjava:1.0.14'
    compile 'io.reactivex:rxandroid:1.0.1'

 

代码里如何使用

rxJava的代码长这样:

Observable.from(userBeans)
                .map(new Func1<UserBean, String>() {
                    @Override
                    public String call(UserBean userBean) {
              
                        return String.format("%s(%s)", userBean.name, userBean.age);
                    }
                })
                .subscribeOn(Schedulers.io())
                .observeOn(AndroidSchedulers.mainThread())
                .subscribe(new Action1<String>() {
                    @Override
                    public void call(String str) {
                       
                        alert(str);
                    }
                });

 

这段代码告诉了我们: 

  Observable.from ()  创建了一个被观察的对象。

  .map() 方法执行了转换,将对象转成字符串

  .subscribeOn() 指示了 在哪个线程里执行 上面的转换操作。

  .observeOn() 指示了 在哪个线程里执行 对结果的响应操作,比如后面的 alert 方法。

  .subscribe() 传递了具体的响应处理,即执行了 alert方法。

 

代码很优雅,链式的写法,很清晰的表达了代码的行为。

 

从单个对象创建被观察对象的演示

使用 just() 方法,指定单个对象来创建被观察对象实例。

    private void doSomeOne() {
        Observable.just("Hello, world!").subscribe(new Action1<String>() {
            @Override
            public void call(String str) {
                alert(str);
            }
        });
    }

 

从一个集合创建被观察对象的演示

使用 from() 方法,指定一个集合来创建被观察对象实例。

    private void doSomeArray() {
        Observable.from(new String[]{"A", "B", "C"}).subscribe(new Action1<String>() {
            @Override
            public void call(String str) {
                alert(str);
            }
        });
    }

 

对象转换的演示

我们使用 map() 方法进行转换。下面的代码演示了 从 UserBean数组创建被观察对象,然后使用map()方法转换成 字符串。

    private void doSomeEntity() {
        UserBean[] userBeans = new UserBean[3];
        userBeans[0] = new UserBean("jo", 18);
        userBeans[1] = new UserBean("ken", 9);
        userBeans[2] = new UserBean("hack", 30);

        //增加了map方法,转出 实体到字符串
        Observable.from(userBeans).map(new Func1<UserBean, String>() {
            @Override
            public String call(UserBean userBean) {
                return String.format("%s(%s)", userBean.name, userBean.age);
            }
        }).subscribe(new Action1<String>() {
            @Override
            public void call(String str) {
                alert(str);
            }
        });
    }

 

 

参考:

https://github.com/ReactiveX/RxJava

http://gank.io/post/560e15be2dca930e00da1083