A股上市公司传智教育(股票代码 003032)旗下技术交流社区北京昌平校区

 找回密码
 加入黑马

QQ登录

只需一步,快速开始

© 胡焱老师 中级黑马   /  2016-3-28 19:55  /  7266 人查看  /  1 人回复  /   0 人收藏 转载请遵从CC协议 禁止商业使用本文

本帖最后由 胡焱老师 于 2016-3-28 19:56 编辑

哥们,还在用AsyncTask执行异步任务?Rxjava你造吗?

注:最近一些同学出去面试,有的问到了Rxjava和RxAndroid的使用,其实我在最近的项目中开始用RxAndroid,发现确实不错;

下面我抛砖引玉介绍Rxjava 和RxAndroid ,后面有时间会出详细的使用帖子,请大家保持关注,谢谢

什么是Rxjava

RxJava 在 GitHub 主页上的自我介绍是 "a library for composing asynchronous and event-based programs using observable sequences for the Java VM"(一个在 Java VM 上使用可观测的序列来组成异步的、基于事件的程序的库)。这就是 RxJava ,概括得非常精准。

         然而,对初学菜鸟,这个太抽象 难懂了。因为它是一个概括,而初学者要的是一个详细的说明和应用场景

RxJava 好在哪



              换句话说,『同样是做异步,为什么人们用它,而不用现成的 AsyncTask / Handler / XXX / ... ?』
             一个词:简洁。

           异步操作很关键的一点是程序的简洁性,因为在调度过程比较复杂的情况下,异步代码经常会既难写也难被读懂。 Android 创造的AsyncTask 和Handler ,其实都是为了让异步代码更加简洁。RxJava 的优势也是简洁,但它的简洁的与众不同之处在于,随着程序逻辑变得越来越复杂,它依然能够保持简洁。


          最后一句很关键,往往我们在使用异步任务的时候,使用AsyncTask,但是后面业务变得复杂后,整个代码要改的很复杂,各种判断,头昏脑胀,但是有了Rxjava我们就能很简洁的实现代码逻辑了;

举个例子

有这样一个需求:界面上有一个自定义的视图ScanImageView,它的作用是显示多张图片,并能使用 addImage(Bitmap) 方法来任意增加显示的图片。现在需要程序将一个给出的目录数组 File[] folders 中每个目录下的 png 图片都加载出来并显示在ScanImageView中。需要注意的是,由于读取图片的这一过程较为耗时,需要放在后台执行,而图片的显示则必须在 UI 线程执行。常用的实现方式有多种,我这里贴出其中一种:

new Thread() {
    @Override
    public void run() {
        super.run();
        for (File folder : folders) {
            File[] files = folder.listFiles();
            for (File file : files) {
                if (file.getName().endsWith(".png")) {
                    final Bitmap bitmap = getBitmapFromFile(file);

                    getActivity().runOnUiThread(new Runnable() {
                        @Override
                        public void run() {
                            ScanImageView.addImage(bitmap);//在主线程中刷新UI(添加bitmap到方法中)
                        }
                    });
                }
            }
        }
    }}.start();

使用 RxJava的话 ,实现方式是这样的:
Observable.from(folders)
        .flatMap(new Func1<File, Observable<File>>() {
            @Override
            public Observable<File> call(File file) {
                return Observable.from(file.listFiles());
            }
        })
        .filter(new Func1<File, Boolean>() {
            @Override
            public Boolean call(File file) {
                return file.getName().endsWith(".png");
            }
        })
        .map(new Func1<File, Bitmap>() {
            @Override
            public Bitmap call(File file) {
                return getBitmapFromFile(file);
            }
        })
        .subscribeOn(Schedulers.io())
        .observeOn(AndroidSchedulers.mainThread())//在主线程运行
        .subscribe(new Action1<Bitmap>() {
            @Override
            public void call(Bitmap bitmap) {
                ScanImageView.addImage(bitmap);
            }
        });有个毛啊,明明代码多了,哪简介了?我的回答是:
代码多了,并不代表业务变复杂了
代码多一点点 但是业务逻辑变得很简单,很容易懂的话,这也值得肯定的
         观察一下你会发现, RxJava 的这个实现,是一条从上到下的链式调用,没有任何嵌套,这在逻辑的简洁性上是具有优势的。当需求变得复杂时,这种优势将更加明显(试想如果还要求只选取前 10 张图片,常规方式要怎么办?如果有更多这样那样的要求呢?再试想,在这一大堆需求实现完两个月之后需要改功能,当你翻回这里看到自己当初写下的那一片迷之缩进,你能保证自己将迅速看懂,而不是对着代码重新捋一遍思路?)。

          如果有一段逻辑非常复杂,包含了多次内存操作、本地文件操作和网络操作,对象分分合合,线程间相互配合相互等待,一会儿排成人字,一会儿排成一字。如果使用常规的方法来实现,肯定是要写得欲仙欲死,然而在使用 RxJava 的情况下,依然只是一条链式调用就完成了。它很长,但很清晰。

所以, RxJava 好在哪?就好在简洁,好在那把什么复杂逻辑都能穿成一条线的简洁。

RxJava 的观察者模式


          RxJava 有四个基本概念:Observable (可观察者,即被观察者)、 Observer (观察者)、 subscribe (订阅)、事件。Observable 和Observer 通过 subscribe() 方法实现订阅关系,从而 Observable 可以在需要的时候发出事件来通知 Observer。

          与传统观察者模式不同, RxJava 的事件回调方法除了普通事件 onNext() (相当于 onClick() / onEvent())之外,还定义了两个特殊的事件:onCompleted() 和 onError()。
onCompleted(): 事件队列完结。RxJava 不仅把每个事件单独处理,还会把它们看做一个队列。RxJava 规定,当不会再有新的onNext() 发出时,需要触发 onCompleted() 方法作为标志。
onError(): 事件队列异常。在事件处理过程中出异常时,onError() 会被触发,同时队列自动终止,不允许再有事件发出。
         在一个正确运行的事件序列中, onCompleted() 和 onError() 有且只有一个,并且是事件序列中的最后一个。需要注意的是,onCompleted() 和 onError() 二者也是互斥的,即在队列中调用了其中一个,就不应该再调用另一个。

上面写的很简单,只是起一个抛砖引玉的作用,后面我会在RxAndroid用具体的业务逻辑来展示Rx的妙用,当然,关于rxjava的介绍使用,我会写一个专题来介绍,请保持持续关注,谢谢!!





1 个回复

倒序浏览
学习了,赞一个,写的很好
回复 使用道具 举报
您需要登录后才可以回帖 登录 | 加入黑马