*/
@Override
public void onProgress(long transferredBytes, long totalSize){
}
}
new RxVolley.Builder()
.url(“http://www.kymjs.com/rss.xml”) //接口地址
//请求类型，如果不加，默认为 GET 可选项：
//POST/PUT/DELETE/HEAD/OPTIONS/TRACE/PATCH
.httpMethod(RxVolley.Method.GET)
//设置缓存时间: 默认是 get 请求 5 分钟, post 请求不缓存
.cacheTime(6)
//内容参数传递形式，如果不加，默认为 FORM 表单提交，可选项 JSON 内容
.contentType(RxVolley.ContentType.FORM)
.params(params) //上文创建的HttpParams请求参数集
//是否缓存，默认是 get 请求 5 缓存分钟, post 请求不缓存
.shouldCache(true)
.progressListener(listener) //上传进度
.callback(callback) //响应回调
.encoding(“UTF-8”) //编码格式，默认为utf-8
.doTask(); //执行请求操作
对 RxJava 的支持
RxVolley 支持返回一个 Observable<Result> 类型的数据，如下是 Result 类的原型
public class Result {
public String url;
public byte[] data;
public VolleyError error;
public Map<String, String> headers;
public int errorCode;
}
执行一次请求，并返回 Observable
Observable observable = new RxVolley.Builder()
.url(“http://www.kymjs.com/rss.xml”)
//default GET or POST/PUT/DELETE/HEAD/OPTIONS/TRACE/PATCH
.httpMethod(RxVolley.Method.POST)
.cacheTime(6) //default: get 5min, post 0min
.params(params)
.contentType(RxVolley.ContentType.JSON)
.getResult(); // 使用getResult()来返回RxJava数据类型
//当拿到 observable 对象后，你可以设置你自己的 subscriber
observable.subscribe(subscriber);
完整的使用示例
public class MainActivity extends AppCompatActivity {
private Subscription subscription;
@Override
protected void onCreate(Bundle savedInstanceState) {
super.onCreate(savedInstanceState);
setContentView(R.layout.activity_main);
Observable observable = new RxVolley.Builder()
.url(“http://kymjs.com/feed.xml”)
.contentType(RxVolley.ContentType.FORM)
.getResult();
subscription = observable
.map(new Func1<Result, String>() {
@Override
public String call(Result result) {
return new String(result.data);
}
})
.subscribeOn(Schedulers.io())
.observeOn(AndroidSchedulers.mainThread())
.subscribe(new Subscriber() {
@Override
public void onCompleted() {
Log.i(“kymjs”, “======网络请求结束”);
}
@Override
public void onError(Throwable e) {
Log.i(“kymjs”, “======网络请求失败” + e.getMessage());
}
@Override
public void onNext(String s) {
Log.i(“kymjs”, “======网络请求” + s);
}
});
}
@Override
protected void onDestroy() {
super.onDestroy();
if (subscription != null && subscription.isUnsubscribed()) {
subscription.unsubscribe();
}
}
}
自定义请求
也许你是 Volley 的重度使用者(就像我)，那么你一定是因为 Volley 自由的扩展性而爱上它的。
你可以通过创建一个Request<?>的子类，自由配置请求策略，缓存策略，数据传输加密，重试策略等。
最后通过
RxVolley.Builder().setRequest(yourRequest).doTask();
去执行你的自定义 Request
一个典型自定义Request的示例：
/**
- Form表单形式的Http请求
*/
public class FormRequest extends Request<byte[]> {
private final HttpParams mParams;
public FormRequest(RequestConfig config, HttpParams params, HttpCallback callback) {
super(config, callback);
if (params == null) {
params = new HttpParams();
}
this.mParams = params;
}
@Override
public String getCacheKey() {
if (getMethod() == RxVolley.Method.POST) {
return getUrl() + mParams.getUrlParams();
} else {
return getUrl();
}
}
@Override
public String getBodyContentType() {
if (mParams.getContentType() != null) {
return mParams.getContentType();
} else {
return super.getBodyContentType();
}
}
@Override
public ArrayList getHeaders() {
return mParams.getHeaders();
}
@Override
public byte[] getBody() {
ByteArrayOutputStream bos = new ByteArrayOutputStream();
try {
mParams.writeTo(bos);
} catch (IOException e) {
Loger.debug(“FormRequest#getBody()—>IOException writing to ByteArrayOutputStream”);
}
return bos.toByteArray();
}
@Override
public Response<byte[]> parseNetworkResponse(NetworkResponse response) {
return Response.success(response.data, response.headers,
HttpHeaderParser.parseCacheHeaders(getUseServerControl(), getCacheTime(),
response));
}
@Override
protected void deliverResponse(ArrayList headers, final byte[] response) {
if (mCallback != null) {
HashMap<String, String> map = new HashMap<>(headers.size());
for (HttpParamsEntry entry : headers) {
map.put(entry.k, entry.v);
}
mCallback.onSuccess(map, response);
}
}
@Override
public Priority getPriority() {
return Priority.IMMEDIATE;
}
}
文件(图片)下载
利用 RxVolley 的自定义请求，在库中内置了文件下载功能。你可以使用
//下载进度(可选参数，不需要可不传)
listener = new ProgressListener() {
@Override
public void onProgress(long transferredBytes, long totalSize) {
Loger.debug(transferredBytes + “======” + totalSize);
}
}
//下载回调，内置了很多方法，详细请查看源码
//包括在异步响应的onSuccessInAsync():注不能做UI操作
//下载成功时的回调onSuccess()
//下载失败时的回调onFailure():例如无网络，服务器异常等
HttpCallback callback = new HttpCallback(){
@Override
public void onSuccessInAsync(byte[] t) {
}
@Override
public void onSuccess(String t) {
}
@Override
public void onFailure(int errorNo, String strMsg) {
}
}
RxVolley.download(FileUtils.getSDCardPath() + “/a.apk”,
“https://www.oschina.net/uploads/osc-android-app-2.4.apk”,
listener, callback);
Android开发除了flutter还有什么是必须掌握的吗？
相信大多数从事Android开发的朋友们越来越发现，找工作越来越难了，面试的要求越来越高了
除了基础扎实的java知识，数据结构算法，设计模式还要求会底层源码，NDK技术，性能调优，还有会些小程序和跨平台，比如说flutter，以思维脑图的方式展示在下图；
点击文档前往获取面试资料与视频教程；【阿里P7级别Android架构师技术脑图+全套视频】
stener, callback);
Android开发除了flutter还有什么是必须掌握的吗？
相信大多数从事Android开发的朋友们越来越发现，找工作越来越难了，面试的要求越来越高了
除了基础扎实的java知识，数据结构算法，设计模式还要求会底层源码，NDK技术，性能调优，还有会些小程序和跨平台，比如说flutter，以思维脑图的方式展示在下图；
点击文档前往获取面试资料与视频教程；【阿里P7级别Android架构师技术脑图+全套视频】
[外链图片转存中…(img-Drg6XOLd-1643960945953)]
