1.RX思维

为什么要学习RxJava:

• 改变思维（响应式编程思维：reactivex），编程效率提升

响应式编程：https://wiki.jikexueyuan.com/project/android-weekly/issue-145/introduction-to-RP.html

学习经典框架：
Github：https://github.com/ReactiveX/RxJava

Author：JakeWharton 被誉为Android之神

Rx系列：
官网：http://reactivex.io/#

Rx思维图：

2.RxJava实现下载图片

RxJava操作符知识参考：链接
实现思路：

代码示例：

// TODO 第二步
        // 起点
        Observable.just(PATH)

                // TODO 第三步
                // 需求：001 图片下载需求  PATH ---》 Bitmap
                .map(new Function<String, Bitmap>() {
                    @NonNull
                    @Override
                    public Bitmap apply(@NonNull String path) throws Exception {
                        try {
                            //Thread.sleep(2000); // 睡眠2秒钟

                            URL url = new URL(path);
                            HttpURLConnection httpURLConnection = (HttpURLConnection) url.openConnection();
                            httpURLConnection.setConnectTimeout(5000); // 设置请求连接时长 5秒
                            int responseCode = httpURLConnection.getResponseCode();

                            // 才开始 request    拿到服务器的响应  200成功  404有问题 ...
                            Log.d("MainActivity",String.valueOf(responseCode));
                            if (responseCode == HttpURLConnection.HTTP_OK) {
                                InputStream inputStream = httpURLConnection.getInputStream();
                                Bitmap bitmap = BitmapFactory.decodeStream(inputStream);
                                return bitmap;
                            }
                        } catch (Exception e) {
                            e.printStackTrace();
                        }
                        return null;
                    }
                })

                // 需求：002 加水印
                .map(new Function<Bitmap, Bitmap>() {
                    @NonNull
                    @Override
                    public Bitmap apply(@NonNull Bitmap bitmap) throws Exception {
                        Paint paint = new Paint();
                        paint.setColor(Color.RED);
                        paint.setTextSize(88);
                        Bitmap shuiyingBitmap = drawTextToBitmap(bitmap, "哈哈哈", paint, 88, 88);
                        return shuiyingBitmap;
                    }
                })

                // 需求：003 日志记录需求
                .map(new Function<Bitmap, Bitmap>() {
                    @NonNull
                    @Override
                    public Bitmap apply(@NonNull Bitmap bitmap) throws Exception {
                        Log.e(TAG, "什么时候下载了图片 apply: " + System.currentTimeMillis() );
                        return bitmap;
                    }
                })


                // 给上面的分配异步线程（图片下载操作）
                .subscribeOn(Schedulers.io())


                // 终点分配 Android主线程
                .observeOn(AndroidSchedulers.mainThread())

                // TODO 导火索 点燃了  开始执行
                // 关联：观察者设计模式   关联 起点 和 终点  ==  订阅
                .subscribe(

                        // 终点
                        new Observer<Bitmap>() {

                            // TODO 第一步
                            // 订阅成功
                            @Override
                            public void onSubscribe(Disposable d) {
                                // 显示加载框
                                progressDialog = new ProgressDialog(MainActivity.this);
                                progressDialog.setTitle("RXJava Derry run 正在加载中..");
                                progressDialog.show();
                            }

                            // TODO 第四步 显示图片   水印的Bitmap
                            // 上一层给我的响应
                            @Override
                            public void onNext(Bitmap bitmap) {
                                image.setImageBitmap(bitmap); // 显示到控件上
                            }

                            // 链条思维发生了异常
                            @Override
                            public void one rror(Throwable e) {

                            }

                            // TODO 第五步 整个链条思维全部结束
                            // 整个链条全部结束
                            @Override
                            public void onComplete() {
                                // 隐藏加载框
                                if (progressDialog != null)
                                    progressDialog.dismiss();
                            }
                        });

    }

    // 图片上绘制文字 加水印
    private final Bitmap drawTextToBitmap(Bitmap bitmap, String text, Paint paint, int paddingLeft, int paddingTop) {
        Bitmap.Config bitmapConfig = bitmap.getConfig();

        paint.setDither(true); // 获取跟清晰的图像采样
        paint.setFilterBitmap(true);// 过滤一些
        if (bitmapConfig == null) {
            bitmapConfig = Bitmap.Config.ARGB_8888;
        }
        bitmap = bitmap.copy(bitmapConfig, true);
        Canvas canvas = new Canvas(bitmap);

        canvas.drawText(text, paddingLeft, paddingTop, paint);
        return bitmap;
    }

运行结果：

3.自定义Observer解决项目中服务器响应的问题

请求服务器的结果Bean：

public class ResponseResult {

    // 登录成功
    private SuccessBean data; // 成功Bean
    private int code;
    private String message;

    public ResponseResult(SuccessBean data, int code, String message) {
        this.data = data;
        this.code = code;
        this.message = message;
    }

    public ResponseResult() {
    }

    public SuccessBean getData() {
        return data;
    }

    public void setData(SuccessBean data) {
        this.data = data;
    }

    public int getCode() {
        return code;
    }

    public void setCode(int code) {
        this.code = code;
    }

    public String getMessage() {
        return message;
    }

    public void setMessage(String message) {
        this.message = message;
    }

    @Override
    public String toString() {
        return "ResponseResult{" +
                "data=" + data +
                ", code=" + code +
                ", message='" + message + '\'' +
                '}';
    }
}

成功Bean：

// 登录 注册 成功的 Bean 信息
public class SuccessBean {

    private int id;
    private String name;

    public SuccessBean() {
    }

    public SuccessBean(int id, String name) {
        this.id = id;
        this.name = name;
    }

    public int getId() {
        return id;
    }

    public void setId(int id) {
        this.id = id;
    }

    public String getName() {
        return name;
    }

    public void setName(String name) {
        this.name = name;
    }

    @Override
    public String toString() {
        return "SuccessBean{" +
                "id=" + id +
                ", name='" + name + '\'' +
                '}';
    }

登陆引擎代码（模拟）：

public class LoginEngine {

    // 返回 起点
    public static Observable<ResponseResult> login(String name, String pwd) {

        // 最终返回 总Bean
        ResponseResult responseResult = new ResponseResult();

        if ("Derry".equals(name) && "123456".equals(pwd)) { // 登录成功

            // 创建 成功 Bean
            SuccessBean successBean = new SuccessBean();
            successBean.setId(45674565);
            successBean.setName("Derry登录成功");

            /**
             * {
             *   data:{ xxxxxxx 登录成功的Bean xxxxxxx  SuccesBean   成功Bean }
             *   code:200
             *   message:"登录成功"
             * }
             */
            responseResult.setData(successBean);
            responseResult.setCode(200);
            responseResult.setMessage("登录成功");

        } else { // 登录失败

            /**
             * {
             *   data:null
             *   code:404
             *   message:"登录错误"
             * }
             */
            responseResult.setData(null);
            responseResult.setCode(404);
            responseResult.setMessage("登录错误");
        }

        // 起点
        return Observable.just(responseResult);
    }

}

自定义Observer：

public abstract class CustomObserver implements Observer<ResponseResult> {

    public abstract void success(SuccessBean successBean);
    public abstract void error(String message);

    @Override
    public void onSubscribe(Disposable d) {

    }

    @Override
    public void onNext(ResponseResult responseResult) {
        if (responseResult.getData() == null) {
            error(responseResult.getMessage() + "请求失败，请Derry老师检查日志..");
        } else {
            success(responseResult.getData());
        }
    }

    @Override
    public void one rror(Throwable e) {
        error(e.getMessage() + "请Derry老师检查日志，错误详情");
    }

    @Override
    public void onComplete() {

    }
}

需求： 如果登录成功 我只想拿到 SuccessBean
如果登录失败 我只想拿到 message String类型

MainActivity代码：

         LoginEngine.login("Derry", "123456")
            // 起点<总Bean>

        .subscribe(new CustomObserver() {
            @Override
            public void success(SuccessBean successBean) {
                Log.d("Derry", "成功的Bean 详情 success: SuccessBean: " + successBean.toString());
            }

            @Override
            public void error(String message) {
                Log.d("Derry", "String类型 error: message:" + message);
            }
        });

本文demo:https://github.com/gujunhe/RxJavaStudy.git