首页 > 编程语言> 文章详细

RxJava再学习系列一，在线面试指南

2022-03-02 23:57:59 阅读：278 来源： 互联网

标签：指南 Override bitmap 面试 RxJava new android progressDialog public

// 预备开始要分发

// TODO 第一步

progressDialog = new ProgressDialog(DownloadActivity.this);

progressDialog.setTitle(“download run”);

progressDialog.show();

}

// TODO 第四步

// 拿到事件

@Override

public void onNext(@NotNull Bitmap bitmap) {

Log.i(TAG, "onNext: ");

ivGlide.setImageBitmap(bitmap);

}

@Override

public void one rror(@NotNull Throwable e) {

}

// TODO 第五步

// 完成事件

@Override

public void onComplete() {

Log.i(TAG, "onComplete: ");

if (progressDialog != null)

progressDialog.dismiss();

}

});

}

1.4、布局

<?xml version="1.0" encoding="utf-8"?>

<LinearLayout xmlns:android=“http://schemas.android.com/apk/res/android”

xmlns:app=“http://schemas.android.com/apk/res-auto”

xmlns:tools=“http://schemas.android.com/tools”

android:layout_width=“match_parent”

android:layout_height=“match_parent”

android:orientation=“vertical”>

<Button

android:layout_width=“wrap_content”

android:layout_height=“wrap_content”

android:onClick=“downloadImageAction”

android:text=“传统方式下载图片功能” />

<Button

android:layout_width=“wrap_content”

android:layout_height=“wrap_content”

android:onClick=“rxJavaDownloadImageAction”

android:text=“RxJava方式下载图片功能” />

<ImageView

android:id="@+id/image"

android:layout_width=“match_parent”

android:layout_height=“200dp” />

<ImageView

android:id="@+id/iv_glide"

android:layout_width=“match_parent”

android:layout_height=“200dp” />

2、代码实战：封转线程切换

public class DownloadActivity extends AppCompatActivity {

// 打印logcat日志的标签

private static final String TAG = “DownloadActivity”;

// 网络图片的链接地址

private final static String PATH = “http://bpic.588ku.com/element_origin_min_pic/16/10/29/2ac8e99273bc079e40a8dc079ca11b1f.jpg”;

private final static String PATH_RX = “http://bpic.588ku.com/element_origin_min_pic/17/06/13/5c5a1442f0ec72e59829ee10d891f224.jpg%21r650”;

// 弹出加载框

private ProgressDialog progressDialog;

// ImageView控件，用来显示结果图像

private ImageView image;

private ImageView ivGlide;

@Override

protected void onCreate(Bundle savedInstanceState) {

super.onCreate(savedInstanceState);

setContentView(R.layout.activity_download);

image = findViewById(R.id.image);

ivGlide = findViewById(R.id.iv_glide);

// Glide.with(this).load(PATH).into(ivGlide);

}

// 零零散散麻烦思维

public void downloadImageAction(View view) {

progressDialog = new ProgressDialog(this);

progressDialog.setTitle(“下载图片中…”);

progressDialog.show();

new Thread(() -> {

try {

URL url = new URL(PATH);

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

httpURLConnection.setConnectTimeout(5000);

//设置请求方法

httpURLConnection.setRequestMethod(“GET”);

int responseCode = httpURLConnection.getResponseCode(); // 才开始 request

if (responseCode == HttpURLConnection.HTTP_OK) {

InputStream inputStream = httpURLConnection.getInputStream();

Bitmap bitmap = BitmapFactory.decodeStream(inputStream);

Message message = handler.obtainMessage();

message.obj = bitmap;

handler.sendMessage(message);

}

} catch (Exception e) {

e.printStackTrace();

}

}).start();

}

private final Handler handler = new Handler(new Handler.Callback() {

@Override

public boolean handleMessage(@NonNull Message msg) {

Bitmap bitmap = (Bitmap) msg.obj;

image.setImageBitmap(bitmap);

if (progressDialog != null) progressDialog.dismiss();

return false;

}

});

/**

封装我们的操作
Upstream 上游
Downstream 下游

public final static ObservableTransformer<UD, UD> rxud() {

return new ObservableTransformer<UD, UD>() {

@Override

public ObservableSource apply(Observable upstream) {

return upstream.subscribeOn(Schedulers.io()) // 给上面代码分配异步线程

.observeOn(AndroidSchedulers.mainThread()) // 给下面代码分配主线程;

.map(new Function<UD, UD>() {

@Override

public UD apply(UD ud) throws Exception {

Log.d(TAG, “apply: 我监听到你了，居然在执行”);

return ud;

}

});

// …

}

};

}

public void rxJavaDownloadImageAction(View view) {

// 起点

Observable.just(PATH) // 内部会分发 PATH Stirng // TODO 第二步

// TODO 第三步

.map(new Function<String, Bitmap>() {

@Override

public Bitmap apply(@NotNull String s) throws Exception {

Log.i(TAG, "apply: ");

URL url = new URL(PATH_RX);

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

httpURLConnection.setConnectTimeout(5000);

//设置请求方法

httpURLConnection.setRequestMethod(“GET”);

int responseCode = httpURLConnection.getResponseCode(); // 才开始 request

if (responseCode == HttpURLConnection.HTTP_OK) {

InputStream inputStream = httpURLConnection.getInputStream();

Bitmap bitmap = BitmapFactory.decodeStream(inputStream);

return bitmap;

}

return null;

}

})

// 图片上绘制文字加水印

.map(new Function<Bitmap, Bitmap>() {

@Override

public Bitmap apply(Bitmap bitmap) throws Exception {

Paint paint = new Paint();

paint.setTextSize(88);

paint.setColor(Color.RED);

return drawTextToBitmap(bitmap, “同学们大家好”, paint, 88, 88);

}

})

// 每次都写这个线程切换比较麻烦，可以考虑进行封装

// .subscribeOn(Schedulers.io()) //给上面代码分配异步线程

// .observeOn(AndroidSchedulers.mainThread()) //给下面代码分配主线程

// 替代上面两行代码

.compose(rxud())

// 订阅起点和终点订阅起来

.subscribe(new Observer() {

@Override

public void onSubscribe(@NotNull Disposable d) {

Log.i(TAG, "onSubscribe: ");

// 预备开始要分发

// TODO 第一步

progressDialog = new ProgressDialog(DownloadActivity.this);

progressDialog.setTitle(“download run”);

progressDialog.show();

}

// TODO 第四步

// 拿到事件

@Override

public void onNext(@NotNull Bitmap bitmap) {

Log.i(TAG, "onNext: ");

ivGlide.setImageBitmap(bitmap);

}

@Override

public void one rror(@NotNull Throwable e) {

}

// TODO 第五步

// 完成事件

@Override

public void onComplete() {

Log.i(TAG, "onComplete: ");

if (progressDialog != null)

progressDialog.dismiss();

}

});

}

// 图片上绘制文字加水印

写在最后

在技术领域内，没有任何一门课程可以让你学完后一劳永逸，再好的课程也只能是“师傅领进门，修行靠个人”。“学无止境”这句话，在任何技术领域，都不只是良好的习惯，更是程序员和工程师们不被时代淘汰、获得更好机会和发展的必要前提。

如果你觉得自己学习效率低，缺乏正确的指导，可以加入资源丰富，学习氛围浓厚的技术圈一起学习交流吧！

加入我们吧！群内有许多来自一线的技术大牛，也有在小厂或外包公司奋斗的码农，我们致力打造一个平等，高质量的Android交流圈子，不一定能短期就让每个人的技术突飞猛进，但从长远来说，眼光，格局，长远发展的方向才是最重要的。

35岁中年危机大多是因为被短期的利益牵着走，过早压榨掉了价值，如果能一开始就树立一个正确的长远的职业规划。35岁后的你只会比周围的人更值钱。

标签：指南,Override,bitmap,面试,RxJava,new,android,progressDialog,public
来源： https://blog.csdn.net/m0_66685251/article/details/123243438

本站声明： 1. iCode9 技术分享网（下文简称本站）提供的所有内容，仅供技术学习、探讨和分享；
2. 关于本站的所有留言、评论、转载及引用，纯属内容发起人的个人观点，与本站观点和立场无关；
3. 关于本站的所有言论和文字，纯属内容发起人的个人观点，与本站观点和立场无关；
4. 本站文章均是网友提供，不完全保证技术分享内容的完整性、准确性、时效性、风险性和版权归属；如您发现该文章侵犯了您的权益，可联系我们第一时间进行删除；
5. 本站为非盈利性的个人网站，所有内容不会用来进行牟利，也不会利用任何形式的广告来间接获益，纯粹是为了广大技术爱好者提供技术内容和技术思想的分享性交流网站。

ICode9

RxJava再学习系列一，在线面试指南

写在最后