前言

1. 代码如下：

/**

* Email: 2185134304@qq.com

* Created by Novate 2018/6/23 12:11

* Version 1.0

* Params:

* Description:

*/

public class MainActivity1 extends AppCompatActivity {

private ImageView iv;

@Override

protected void onCreate(Bundle savedInstanceState) {

super.onCreate(savedInstanceState);

setContentView(R.layout.activity_main);

iv = (ImageView) findViewById(R.id.iv);

// 需求：给网络上的一张图片添加水印，显示到 ImageView 控件上

// 1. 开启线程下载图片；

// 2. 添加水印；

// 3. 切换到主线程显示图片；

Observable.just("http://img.taopic.com/uploads/allimg/130331/240460-13033106243430.jpg")

.map(new Function() { // 事件变换：把 String - Bitmap

@Override

public Bitmap apply(@NonNull String urlPath) throws Exception {

URL url = new URL(urlPath);

HttpURLConnection urlConnection = (HttpURLConnection) url.openConnection();

InputStream inputStream = urlConnection.getInputStream();

Bitmap bitmap = BitmapFactory.decodeStream(inputStream);

return bitmap;

}

})

.map(new Function() { // 事件变换：把 Bitmap - Bitmap 添加水印

@Override

public Bitmap apply(@NonNull Bitmap bitmap) throws Exception {

bitmap = createWatermark(bitmap, "RxJava2.0");

return bitmap;

}

})

.subscribeOn(Schedulers.io()) // subscribeOn以上所有操作全部在子线程中执行

.observeOn(AndroidSchedulers.mainThread()) // observeOn以下操作全部在主线程中执行

.subscribe(new Consumer() {

@Override

public void accept(Bitmap bitmap) throws Exception {

iv.setImageBitmap(bitmap);

}

});

}

private Bitmap createWatermark(Bitmap bitmap, String mark) {

int w = bitmap.getWidth();

int h = bitmap.getHeight();

Bitmap bmp = Bitmap.createBitmap(w, h, Bitmap.Config.ARGB_8888);

Canvas canvas = new Canvas(bmp);

Paint p = new Paint();

// 水印颜色

p.setColor(Color.parseColor("#C5FF0000"));

// 水印字体大小

p.setTextSize(150);

//抗锯齿

p.setAntiAlias(true);

//绘制图像

canvas.drawBitmap(bitmap, 0, 0, p);

//绘制文字

canvas.drawText(mark, 0, h / 2, p);

canvas.save(Canvas.ALL_SAVE_FLAG);

canvas.restore();

return bmp;

}

}

分析以上代码可知：

1>：首先 用 map操作符：把 String类型url转为 Bitmap；

2>：然后 用 map操作符：把 Bitmap类型 转为 Bitmap；

3>：用 subscribeOn(Schedulers.io()) ：表示 subscribeOn(Schedulers.io()) 以上操作全部执行在子线程中；

4>：用 observeOn(AndroidSchedulers.mainThread())：表示 observeOn(AndroidSchedulers.mainThread()) 以下操作切换到 主线程，全部在主线程中执行；

5>：用 subscribe(new Consumer(){}：显示图片即可；

2. RxJava特点

1>：优点：一条链子下来的，可读性比较高、扩展性、维护性；

2>：缺点：学习成本高，思想难以转换(基于事件流的思想)