当前位置: 开发笔记 > 前端 > 正文

Android中volley封装实践记录（二）

作者：荒原绿树fy | 来源：互联网 | 2022-10-19 15:56

这篇文章主要给大家介绍了关于Android中volley封装的相关资料，文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值，需要的朋友们下面随着小编来一起学习学习吧

前言

关于android的volley封装之前写过一篇文章，见链接（https://www.jb51.net/article/155875.htm）。这篇文章主要是换种方式进行封装，具体步骤如下所示。

步骤如下

1.创建Request，并设置相应的参数：

public class CommonJsonObjectRequest extends JsonObjectRequest {
 private String TAG = this.getClass().getSimpleName();
 /*
 * code=1:处理成功；
 */
 public static final int CODE_SUCCESS = 100;
 private Context mContext;
 private JSONObject mJsonRequest;

 public CommonJsonObjectRequest(Context context, int method, String url,
     JSONObject jsonRequest, Response.Listener listener,
     Response.ErrorListener errorListener) {
 super(method, url, jsonRequest, listener, errorListener);
 init(context, jsonRequest);
 }

 /**
 * @param context
 * @param url
 * @param jsonRequest
 * @param listener
 * @param errorListener
 */
 public CommonJsonObjectRequest(Context context, String url, JSONObject jsonRequest,
     Response.Listener listener, Response.ErrorListener errorListener) {
 super(url, jsonRequest, listener, errorListener);
 if (jsonRequest != null) {
  Log.d(TAG, jsonRequest.toString());
 }
 init(context, jsonRequest);
 }

 /**
 * @param context
 * @param jsonRequest
 */
 private void init(Context context, JSONObject jsonRequest) {
 this.mCOntext= context.getApplicationContext();
 this.mJsOnRequest= jsonRequest;
 setRetryPolicy(new DefaultRetryPolicy(10 * 1000, 0, 0));
 }

 @Override
 public Map getHeaders() throws AuthFailureError {
 Map headersMap = new HashMap<>();
 //do your business requirement
 return headersMap;
 }

}

所做的工作也很简单，去配置网络访问RetryPolicy,比如超时时间，最大的重试次数。例外也会根据业务要求在请求的头部加入token等标识。

2.通过工厂模式创建请求队列，volley内部会有两种构造方式，同步请求或者异步请求，通过设置ResponseDelivery 可以实现。

public interface ResponseDelivery {
 /**
 * Parses a response from the network or cache and delivers it.
 */
 public void postResponse(Request<&＃63;> request, Response<&＃63;> response);

 /**
 * Parses a response from the network or cache and delivers it. The provided
 * Runnable will be executed after delivery.
 */
 public void postResponse(Request<&＃63;> request, Response<&＃63;> response, Runnable runnable);

 /**
 * Posts an error for the given request.
 */
 public void postError(Request<&＃63;> request, VolleyError error);
}

这个工厂的代码如下：

/**
 * 网络请求队列工厂类
 */
public class RequestQueueFactory {

 private static RequestQueue sRequestQueue;
 private static RequestQueue sAsynRequestQueue;

 private static int ASYN_QUEUE_THREAD_POOL_SIZE = 3;

 private RequestQueueFactory() {

 }

 /**
 * 获取默认RequestQueue，回调是同步到主线程的
 *
 * @param context
 * @return
 */
 public synchronized static RequestQueue getRequestQueue(Context context) {
 if (sRequestQueue == null) {
  OkHttpClient okHttpClient = new OkHttpClient.Builder().build();
  OkHttpStack stack = new OkHttpStack(okHttpClient);
  sRequestQueue = Volley.newRequestQueue(context, stack);
 }
 return sRequestQueue;
 }

 /**
 * 获取异步RequestQueue，回调是在异步线程的
 *
 * @param context
 * @return
 */
 public synchronized static RequestQueue getAsynRequeQueueRespond(
  final Context context) {
 if (sAsynRequestQueue == null) {
  sAsynRequestQueue = getAsynRequeQueueRespond(context,
   ASYN_QUEUE_THREAD_POOL_SIZE);
 }
 return sAsynRequestQueue;
 }

 private static RequestQueue getAsynRequeQueueRespond(final Context context,
        int threadPoolSize) {
 File cacheDir = new File(context.getCacheDir(), "volley_asyn");
 OkHttpClient okHttpClient = new OkHttpClient.Builder().build();
 OkHttpStack stack = new OkHttpStack(okHttpClient);
 Network network = new BasicNetwork(stack);
 RequestQueue queue = new RequestQueue(new DiskBasedCache(cacheDir),
  network, threadPoolSize, new ExecutorDelivery(
  AsyncTask.SERIAL_EXECUTOR));
 queue.start();
 return queue;
 }

}

在代码中有这样两行代码：

 if (sRequestQueue == null) {
  OkHttpClient okHttpClient = new OkHttpClient.Builder().build();
  OkHttpStack stack = new OkHttpStack(okHttpClient);
  sRequestQueue = Volley.newRequestQueue(context, stack);
 }

这里是使用了okhttpstack,如果不进行设置，内部默认的会设置一个stack;

 if (stack == null) {
  if (Build.VERSION.SDK_INT >= 9) {
  stack = new HurlStack();
  } else {
  // Prior to Gingerbread, HttpUrlConnection was unreliable.
  // See: http://android-developers.blogspot.com/2011/09/androids-http-clients.html
  stack = new HttpClientStack(AndroidHttpClient.newInstance(userAgent));
  }
 }

okhttpstack类如下：

/**
 * 使用OKHttp作为底层的HttpStack
 */
public class OkHttpStack implements HttpStack {
 private final OkHttpClient client;

 public OkHttpStack(OkHttpClient client) {
 this.client = client;
 }

 private static HttpEntity entityFromOkHttpResponse(Response response) throws IOException {
 BasicHttpEntity entity = new BasicHttpEntity();
 ResponseBody body = response.body();

 entity.setContent(body.byteStream());
 entity.setContentLength(body.contentLength());
 entity.setContentEncoding(response.header("Content-Encoding"));

 if (body.contentType() != null) {
  entity.setContentType(body.contentType().type());
 }
 return entity;
 }

 @SuppressWarnings("deprecation")
 private static void setConnectionParametersForRequest
  (okhttp3.Request.Builder builder, Request<&＃63;> request)
  throws IOException, AuthFailureError {
 switch (request.getMethod()) {
  case Request.Method.DEPRECATED_GET_OR_POST:
  byte[] postBody = request.getPostBody();
  if (postBody != null) {
   builder.post(RequestBody.create
    (MediaType.parse(request.getPostBodyContentType()), postBody));
  }
  break;

  case Request.Method.GET:
  builder.get();
  break;

  case Request.Method.DELETE:
  builder.delete();
  break;

  case Request.Method.POST:
  builder.post(createRequestBody(request));
  break;

  case Request.Method.PUT:
  builder.put(createRequestBody(request));
  break;

  case Request.Method.HEAD:
  builder.head();
  break;

  case Request.Method.OPTIONS:
  builder.method("OPTIONS", null);
  break;

  case Request.Method.TRACE:
  builder.method("TRACE", null);
  break;

  case Request.Method.PATCH:
  builder.patch(createRequestBody(request));
  break;

  default:
  throw new IllegalStateException("Unknown method type.");
 }
 }

 private static RequestBody createRequestBody(Request request) throws AuthFailureError {
 final byte[] body = request.getBody();
 if (body == null) return null;

 return RequestBody.create(MediaType.parse(request.getBodyContentType()), body);
 }

 private static ProtocolVersion parseProtocol(final Protocol protocol) {
 switch (protocol) {
  case HTTP_1_0:
  return new ProtocolVersion("HTTP", 1, 0);
  case HTTP_1_1:
  return new ProtocolVersion("HTTP", 1, 1);
  case SPDY_3:
  return new ProtocolVersion("SPDY", 3, 1);
  case HTTP_2:
  return new ProtocolVersion("HTTP", 2, 0);
 }

 throw new IllegalAccessError("Unkwown protocol");
 }

 @Override
 public HttpResponse performRequest(Request<&＃63;> request, Map additionalHeaders)
  throws IOException, AuthFailureError {
 int timeoutMs = request.getTimeoutMs();
 OkHttpClient client = this.client.newBuilder()
  .readTimeout(timeoutMs, TimeUnit.MILLISECONDS)
  .connectTimeout(timeoutMs, TimeUnit.MILLISECONDS)
  .writeTimeout(timeoutMs, TimeUnit.MILLISECONDS)
  .build();

 okhttp3.Request.Builder okHttpRequestBuilder = new okhttp3.Request.Builder();
 Map headers = request.getHeaders();

 for (Map.Entry entry : headers.entrySet()) {
  okHttpRequestBuilder.addHeader(entry.getKey(), entry.getValue());
 }

 for (Map.Entry entry : additionalHeaders.entrySet()) {
  okHttpRequestBuilder.addHeader(entry.getKey(), entry.getValue());
 }

// for (final String name : headers.keySet()) { //entrySet的遍历效率比keySet高上一个遍历元素的速度
//  okHttpRequestBuilder.addHeader(name, headers.get(name));
// }

// for (final String name : additionalHeaders.keySet()) {
//  okHttpRequestBuilder.addHeader(name, additionalHeaders.get(name));
// }

 setConnectionParametersForRequest(okHttpRequestBuilder, request);

 okhttp3.Request okhttp3Request = okHttpRequestBuilder.url(request.getUrl()).build();
 Response okHttpRespOnse= client.newCall(okhttp3Request).execute();

 StatusLine respOnseStatus= new BasicStatusLine
  (
   parseProtocol(okHttpResponse.protocol()),
   okHttpResponse.code(),
   okHttpResponse.message()
  );
 BasicHttpResponse respOnse= new BasicHttpResponse(responseStatus);
 response.setEntity(entityFromOkHttpResponse(okHttpResponse));

 Headers respOnseHeaders= okHttpResponse.headers();
 for (int i = 0, len = responseHeaders.size(); i

其中核心代码在performRequest方法中。

3.封装基类。基类使用abstract会更灵活，子类可以选择性的重写方法。

/**
 * 网络处理基类
 */
public abstract class BaseNetModel {

 protected RequestQueue requestQueue;
 protected Context context;
 protected Object mTag;

 protected BaseNetModel(Context context) {
 this.cOntext= context.getApplicationContext();
 requestQueue = RequestQueueFactory.getAsynRequeQueueRespond(this.context);
 }

 protected BaseNetModel(Context context, boolean isAsyn) {
 this.cOntext= context.getApplicationContext();
 requestQueue = isAsyn &＃63; RequestQueueFactory.getAsynRequeQueueRespond(this.context)
  : RequestQueueFactory.getRequestQueue(context);
 }

 /**
 * 推荐用页面ClassName+时间戳
 *
 * @param tag
 */
 public void setTag(Object tag) {
 this.mTag = tag;
 }

 public void destroy() {
 if (mTag != null) {
  cancelTaskByTag(mTag);
 }
 requestQueue = null;
 cOntext= null;
 }

 public void cancelTaskByTag(Object tag) {
 if (requestQueue != null) {
  requestQueue.cancelAll(tag);
 }
 }


 public void addRequest(String path, JSONObject jsonRequest, Response.Listener listener, Response.ErrorListener errorListener) {
 addRequest(path, true, jsonRequest, listener, errorListener);
 }

 /**
 * @param path  不带域名的接口路径
 * @param withTag 是否带上页面的tag
 * @param jsonRequest
 * @param listener
 * @param errorListener
 */
 public void addRequest(String path, boolean withTag, JSONObject jsonRequest, Response.Listener listener, Response.ErrorListener errorListener) {
 addRequestUrl(path, withTag, jsonRequest, listener, errorListener);
 }

 /**
 * @param url  完整接口地址
 * @param withTag
 * @param jsonRequest
 * @param listener
 * @param errorListener
 */
 public void addRequestUrl(String url, boolean withTag, JSONObject jsonRequest, Response.Listener listener, Response.ErrorListener errorListener) {
 if (jsOnRequest== null) {
  jsOnRequest= new JSONObject();
 }
 CommonJsonObjectRequest request = new CommonJsonObjectRequest(context, url, jsonRequest, listener, errorListener);
 if (withTag && mTag != null) {
  request.setTag(mTag);
 }
 requestQueue.add(request);
 }

}

4.逻辑封装。

这里选用的是一个新闻的接口，这种接口可以在聚合数据上申请，有的收费，有的免费。

public class NewsModel extends BaseNetModel {
 public NewsModel(Context context) {
 super(context);
 }

 public NewsModel(Context context, boolean isAsyn) {
 super(context, isAsyn);
 }

 public void getInfo(Response.Listener listener, Response.ErrorListener errorListener) throws Exception {
 JSONObject jsOnObject= new JSONObject();
 addRequest(INetConstant.NEWS, jsonObject, listener, errorListener);
 }
}

接口的地址为：（http://v.juhe.cn/toutiao/index&＃63;type=&key=b2f8e4aeacfa310cabfadd5189bbe4d5）

5.开始使用。

 NewsModel newsModel = new NewsModel(getActivity());
 try {
  newsModel.getInfo(new Response.Listener() {
  @Override
  public void onResponse(final JSONObject response) {
   ThreadUtils.runInUIThread(new Runnable() {
   @Override
   public void run() {
    News news = new Gson().fromJson(response.toString(), News.class);
    mAdapter.setData(news.getResult().getData());
   }
   });
  }
  }, new Response.ErrorListener() {
  @Override
  public void onErrorResponse(VolleyError error) {
  }
  });
 } catch (Exception e) {
  e.printStackTrace();
 }

最后放一张图：

图片发自简书App

分享结束，代码在[github] (https://github.com/daydaydate/sample （本地下载）) 。感谢您的阅读。

总结

以上就是这篇文章的全部内容了，希望本文的内容对大家的学习或者工作具有一定的参考学习价值，如果有疑问大家可以留言交流，谢谢大家对的支持。

推荐阅读

js
Git 分布式版本控制系统：远程仓库的深入探讨

本文详细介绍了Git分布式版本控制系统中远程仓库的概念和操作方法。通过具体案例，帮助读者更好地理解和掌握如何高效管理代码库。 ... [详细]

蜡笔小新 2024-12-25 18:30:21
js
企业级项目中 Webpack 配置优化指南

本文详细介绍了在企业级项目中如何优化 Webpack 配置，特别是在 React 移动端项目中的最佳实践。涵盖资源压缩、代码分割、构建范围缩小、缓存机制以及性能优化等多个方面。 ... [详细]

蜡笔小新 2024-12-24 14:41:48
view
FinOps 与 Serverless 的结合：破解云成本难题

本文探讨了如何通过 FinOps 实践优化 Serverless 应用的成本管理，提出了首个 Serverless 函数总成本估计模型，并分享了多种有效的成本优化策略。 ... [详细]

蜡笔小新 2024-12-24 12:44:26
js
Vue 2 中解决页面刷新和按钮跳转导致导航栏样式失效的问题

本文介绍了如何通过配置路由的 meta 字段，确保 Vue 2 项目中的导航栏在页面刷新或内部按钮跳转时，始终保持正确的 active 样式。具体实现方法包括设置路由的 meta 属性，并在 HTML 模板中动态绑定类名。 ... [详细]

蜡笔小新 2024-12-28 13:45:20
v8
FastJSON解析与数据提取技巧

探讨如何高效使用FastJSON进行JSON数据解析，特别是从复杂嵌套结构中提取特定字段值的方法。 ... [详细]

蜡笔小新 2024-12-27 19:49:07
dom
解析JSON格式文本并处理数据

本文介绍如何使用阿里云的fastjson库解析包含时间戳、IP地址和参数等信息的JSON格式文本，并进行数据处理和保存。 ... [详细]

蜡笔小新 2024-12-26 16:06:09
dom
Composer Registry Manager：PHP的源切换管理工具

本文介绍了一个用于Composer的源切换管理工具——Composer Registry Manager。该项目旨在简化Composer包源的管理和切换，避免与常见的CRM系统混淆，并提供了详细的安装和使用指南。 ... [详细]

蜡笔小新 2024-12-25 19:34:14
dom
深入探讨CPU虚拟化与KVM内存管理

本文详细介绍了现代服务器架构中的CPU虚拟化技术，包括SMP、NUMA和MPP三种多处理器结构，并深入探讨了KVM的内存虚拟化机制。通过对比不同架构的特点和应用场景，帮助读者理解如何选择最适合的架构以优化性能。 ... [详细]

蜡笔小新 2024-12-25 19:15:51
js
使用npm脚本同时启动多个监听服务的技巧

本文介绍了如何利用npm脚本和concurrently工具，实现本地开发环境中多个监听服务的同时启动，包括HTTP服务、自动刷新、Sass和ES6支持。 ... [详细]

蜡笔小新 2024-12-25 18:10:18
view
解析猫鼬 findOne 方法返回 null 的原因

本文探讨了在通过 API 端点调用时，使用猫鼬（Mongoose）的 findOne 方法总是返回 null 的问题，并提供了详细的解决方案和建议。 ... [详细]

蜡笔小新 2024-12-25 17:40:33
js
VSCode 自定义代码片段配置：实现类似IDEA的快捷代码段（如sout或psvm）

本文详细介绍如何在VSCode中配置自定义代码片段，使其具备与IDEA相似的代码生成快捷键功能。通过具体的Java和HTML代码片段示例，展示配置步骤及效果。 ... [详细]

蜡笔小新 2024-12-25 17:10:13
html
优化页面加载性能

在网页开发中，页面加载速度是一个关键的用户体验因素。为了提升加载效率，避免在PageLoad事件中进行大量数据绑定操作，可以采用异步加载和特定控件来优化页面加载过程。 ... [详细]

蜡笔小新 2024-12-25 16:57:49
正则
深入解析JMeter中的JSON提取器及其应用

本文详细介绍了如何在JMeter中使用JSON提取器来获取和处理API响应中的数据。特别是在需要将一个接口返回的数据作为下一个接口的输入时，JSON提取器是一个非常有用的工具。 ... [详细]

蜡笔小新 2024-12-25 16:34:37
dom
掌握Java EE的全面指南

探讨如何真正掌握Java EE，包括所需技能、工具和实践经验。资深软件教学总监李刚分享了对毕业生简历中常见问题的看法，并提供了详尽的标准。 ... [详细]

蜡笔小新 2024-12-25 13:38:29
js
理解在 Ember.js 中加载 JSON 的最佳实践

作为一名 Ember.js 新手，了解如何在路由和模型中正确加载 JSON 数据是至关重要的。本文将探讨两者之间的差异，并提供实用的建议。 ... [详细]

蜡笔小新 2024-12-24 16:26:33

荒原绿树fy

这个家伙很懒，什么也没留下！

Tags | 热门标签

RankList | 热门文章