Android 中Volley二次封装并实现网络请求缓存
发布时间 - 2026-01-11 03:08:06 点击率：次Android 中Volley二次封装并实现网络请求缓存
Android目前很多同学使用Volley请求网络数据，但是Volley没有对请求过得数据进行缓存，因此需要我们自己手动缓存。 一下就是我的一种思路，仅供参考
具体使用方法为：
HashMap<String,String> params = new HashMap<>();
params.put("id", "1");
params.put("user", "mcoy");
new NetWorkHelper(getActivity()).jacksonMethodRequest
("method_id", params, new TypeReference<ReturnTemple<FirstCategories>>(){}, handler, msgId);
NetWorkHelper---对Volley的封装，首先调用CacheManager.get(methodName, params);方法获取缓存中的数据，如果数据为null，
则继续发送网络请求。
/**
* @version V1.0 网络请求帮助类
* @author: mcoy
*/
public final class NetWorkHelper {
private NetWorkManager netWorkUtils;
public NetWorkHelper(Context context){
netWorkUtils = new NetWorkManager(context);
}
public static final String COMMON_ERROR_MSG = "连接超时，请稍后重试";
public static final int COMMON_ERROR_CODE = 2;
/**
* 使用Jackson请求的方法
* @param methodName
* @param params
* @param handler
* @param msgId
*/
public void jacksonMethodRequest(final String methodName,final HashMap<String,String> params,TypeReference javaType, final Handler handler,final int msgId){
ResponseListener listener = new ResponseListener(){
@Override
public void onResponse(Object response, boolean isCache) {
PrintLog.log(response.toString());
if (isCache){
CacheManager.put(methodName, params, response);
}
if (handler != null) {
Message message = handler.obtainMessage();
message.what = msgId;
message.obj = response;
handler.sendMessage(message);
}
}
};
Object respone = CacheManager.get(methodName, params);
if(respone != null){
listener.onResponse(respone,false);
return;
}
HashMap<String,String> allParams = Config.setSign(true);
allParams.putAll(params);
Response.ErrorListener errorListener = new Response.ErrorListener() {
@Override
public void onErrorResponse(VolleyError error) {
error.printStackTrace();
if (handler != null) {
Message message = handler.obtainMessage();
message.what = msgId;
message.obj = COMMON_ERROR_MSG;
handler.sendMessage(message);
}
}
};
netWorkUtils.jacksonRequest(getUrl(methodName), allParams,javaType, listener, errorListener);
}
/**
* Url直接请求
* @param url
* @param params
* @param handler
* @param msgId
*/
public void urlRequest(String url,HashMap<String,String> params,JsonParser jsonParser,final Handler handler,final int msgId){
request(url, true, params, jsonParser, handler, msgId);
}
/**
* 通过方法请求
* @param methodName 方法名
* @param params 请求参数
* @param jsonParser Json解析器
* @param handler 回调通知
* @param msgId 通知的Id
*/
public void methodRequest(String methodName, final HashMap<String,String> params,final JsonParser jsonParser,final Handler handler,final int msgId){
request(getUrl(methodName),true,params,jsonParser,handler,msgId);
}
/**
* 通过方法请求
* @param methodName 方法名
* @param params 请求参数
* @param jsonParser Json解析器
* @param handler 回调通知
* @param msgId 通知的Id
*/
public void methodRequest(String methodName, boolean isLogin,final HashMap<String,String> params,final JsonParser jsonParser,final Handler handler,final int msgId){
request(getUrl(methodName),isLogin,params,jsonParser,handler,msgId);
}
private void request(final String url, boolean isLogin,final HashMap<String,String> params,final JsonParser jsonParser,final Handler handler,final int msgId){
final HashMap<String,String> allParams = Config.setSign(isLogin);
allParams.putAll(params);
Response.Listener listener = new Response.Listener<String>() {
@Override
public void onResponse(String response) {
/**
* 有些请求默认是没有parser传过来的，出参只求String，譬如联合登录等
* 所以加了一个else if
*/
Object result;
PrintLog.log(response);
if (jsonParser != null ) {
jsonParser.json2Obj(response);
jsonParser.temple.description = jsonParser.temple.getResultDescription();
result = jsonParser.temple;
} else {
ReturnTemple temple = new ReturnTemple();
temple.issuccessful = false;
temple.description = COMMON_ERROR_MSG;
temple.result = -100;
result = temple;
}
if (handler != null) {
Message message = handler.obtainMessage();
message.what = msgId;
message.obj = result;
handler.sendMessage(message);
}
}
};
Response.ErrorListener errorListener = new Response.ErrorListener() {
@Override
public void onErrorResponse(VolleyError error) {
Object result;
if (jsonParser != null) {
ReturnTemple temple = new ReturnTemple();
temple.issuccessful = false;
temple.description = COMMON_ERROR_MSG;
temple.result = COMMON_ERROR_CODE;
result = temple;
} else {
result = COMMON_ERROR_MSG;
}
if (handler != null) {
Message message = handler.obtainMessage();
message.what = msgId;
message.obj = result;
handler.sendMessage(message);
}
}
};
netWorkUtils.request(url, allParams, listener, errorListener);
}
/**
* 根据访求名拼装请求的Url
* @param methodName
* @return
*/
private String getUrl(String methodName){
String url = Config.getUrl();
if (!StringUtil.isNullOrEmpty(methodName)) {
url = url + "?method=" + methodName;
}
return url;
}
}
CacheManager---将针对某一method所请求的数据缓存到本地文件当中，主要是将CacheRule写到本地文件当中
/**
* @version V1.0 <缓存管理>
* @author: mcoy
*/
public final class CacheManager {
/**
* 一个方法对应的多个Key，比如分类都是同一个方法，但是请求会不一样，可能都要缓存
*/
private static HashMap<String, ArrayList<String>> methodKeys;
private static final String keyFileName = "keys.pro";
/**
* 读取缓存的Key
*/
public static void readCacheKey() {
methodKeys = (HashMap<String, ArrayList<String>>) readObject(keyFileName);
if (methodKeys == null) {
methodKeys = new HashMap<String, ArrayList<String>>();
}
}
/**
* 保存缓存
*/
public static void put(String method, HashMap<String, String> params, Object object) {
long expireTime = CacheConfig.getExpireTime(method);
if (expireTime <= 0 || methodKeys == null) {//有效时间小于0，则不需要缓存
return;
}
String key = createKey(method, params);
if (methodKeys.containsKey(method)) {
ArrayList<String> keys = methodKeys.get(method);
keys.add(key);
} else {
ArrayList<String> keys = new ArrayList<>();
keys.add(key);
methodKeys.put(method, keys);
}
writeObject(methodKeys, keyFileName);
String fileName = key + ".pro";
CacheRule cacheRule = new CacheRule(expireTime, object);
LogModel.log(" put " + method + " " + key + " " + cacheRule);
writeObject(cacheRule, fileName);
}
public static Object get(String method, HashMap<String, String> params) {
long expireTime = CacheConfig.getExpireTime(method);
if (expireTime <= 0 || methodKeys == null || !methodKeys.containsKey(method)) {//有效时间小于0，则不需要缓存
return null;
}
ArrayList<String> keys = methodKeys.get(method);
// String saveKey = keys.get(method);
String key = createKey(method, params);
String fileName = key + ".pro";
// LogModel.log("get"+method+" "+(saveKey.equals(key))+" path:"+fileName);
CacheRule cacheRule = null;
try {
if (keys.contains(key)) {
cacheRule = (CacheRule) readObject(fileName);
}
} catch (Exception e) {
e.printStackTrace();
}
LogModel.log("get :" + method + " " + key + " " + cacheRule);
if (cacheRule != null && cacheRule.isExpire()) {
return cacheRule.getData();
} else {
return null;
}
}
public static void main(String[] args) {
String method = "category.getCategory";
HashMap<String, String> params = new HashMap<>();
params.put("categoryId", "-3");
System.out.println(createKey(method, params));
System.out.println(CacheRule.getCurrentTime());
}
/**
* 生成Key
*
* @param method 请求的方法名
* @param params 私有参数(除公共参数以外的参数)
* @return
*/
private static String createKey(String method, HashMap<String, String> params) {
try {
MessageDigest digest = MessageDigest.getInstance("md5");
digest.digest(method.getBytes("UTF-8"));
StringBuilder builder = new StringBuilder(method);
if (params != null && params.size() > 0) {
Iterator<Map.Entry<String, String>> iterator = params.entrySet().iterator();
while (iterator.hasNext()) {
Map.Entry<String, String> entry = iterator.next();
builder.append(entry.getKey()).append("=").append(entry.getValue());
}
}
byte[] tempArray = digest.digest(builder.toString().getBytes("UTF-8"));
StringBuffer keys = new StringBuffer();
for (byte b : tempArray) {
// 与运算
int number = b & 0xff;// 加盐
String str = Integer.toHexString(number);
// System.out.println(str);
if (str.length() == 1) {
keys.append("0");
}
keys.append(str);
}
return keys.toString().toUpperCase();
} catch (Exception e) {
e.printStackTrace();
}
return method.toUpperCase();
}
/**
* 将对象写到文件中
*
* @param object
* @param fileName
*/
private static void writeObject(Object object, String fileName) {
try {
ObjectOutputStream oo = new ObjectOutputStream(new FileOutputStream(new File(CacheConfig.getCachePath() + fileName)));
oo.writeObject(object);
oo.close();
} catch (IOException e) {
e.printStackTrace();
}
}
/**
* 读取对象
*
* @param fileName
* @return
*/
private static Object readObject(String fileName) {
Object result = null;
try {
File file = new File(CacheConfig.getCachePath() + fileName);
if (file.exists()) {
ObjectInputStream oi = new ObjectInputStream(new FileInputStream(file));
result = oi.readObject();
oi.close();
}
} catch (Exception e) {
e.printStackTrace();
}
return result;
}
}
CacheConfig---初始化哪些方法需要做缓存处理，以及缓存的有效时间
/**
* @version V1.0 <设置哪些类数据需要缓存>
* @author: mcoy
*/
public final class CacheConfig {
/**方法对应的缓存有效时间，时间是毫秒*/
private static HashMap<String,Long> methodExpireTimes = new HashMap<String, Long>();
private static String cachePath = null;
static {
methodExpireTimes.put(ConstMethod.GET_CATEGORY_LIST,30 * 60 * 1000L);
methodExpireTimes.put(ConstMethod.GET_NEW_CATEGORY_LIST,30 * 60 * 1000L);
}
/**
* 初始化缓存路径
* @param context
*/
public static void init(Context context){
cachePath = context.getFilesDir().getPath()+ File.separator+"cache"+File.separator;
File file = new File(cachePath);
if(!file.exists()){
file.mkdirs();
}
CacheManager.readCacheKey();
}
/**缓存路径*/
public static String getCachePath() {
return cachePath;
}
/**
* 获取有方法对应的有效时间，如果方法没有添加缓存或者缓存时间小于0，则不添加缓存
* @param method
* @return
*/
public static long getExpireTime(String method){
if(methodExpireTimes.containsKey(method)){
return methodExpireTimes.get(method);
}else {
return -1;
}
}
}
CacheRule---主要有两个参数，expireTime需要缓存的时间， data需要缓存的数据
public class CacheRule implements Serializable{
/** 有效时间 */
public long expireTime;
/** 缓存时间*/
public long cacheTime;
/** 缓存数据 */
private Object data;
public CacheRule(long expireTime,Object data){
cacheTime = getCurrentTime();
this.expireTime = expireTime;
this.data = data;
}
public Object getData() {
return data;
}
public void setData(Object data) {
this.data = data;
}
@Override
public int hashCode() {
return BeanTools.createHashcode(expireTime, cacheTime, data);
}
@Override
public String toString() {
StringBuilder builder = new StringBuilder();
builder.append("expireTime:").append(expireTime).append(" cacheTime:").append(cacheTime)
.append(" curTime:").append(getCurrentTime())
.append(" isExpire:").append(isExpire()).append(" data:").append(data==null?"null":data.toString());
return builder.toString();
}
/**
* 数据是否有效
* @return
*/
public boolean isExpire(){
long curTime = getCurrentTime();
return curTime>(expireTime+cacheTime)?false:true;
}
/**
* 获取当前时间
* @return
*/
public static long getCurrentTime(){
// if (Build.VERSION_CODES.JELLY_BEAN_MR1 <= Build.VERSION.SDK_INT) {
// return SystemClock.elapsedRealtimeNanos();
// } else {
return System.currentTimeMillis();
// }
}
}
NetWorkManager---往RequestQueue中添加JacksonRequest请求，然后Volley会去请求数据
/**
* 网络请求的工具类
*/
public final class NetWorkManager {
private RequestQueue requestQueue ;
public NetWorkManager(Context context){
requestQueue = Volley.newRequestQueue(context);
}
/**
* 使用Jackson解析请求的方法
* @param url
* @param params
* @param javaType 成功时返回的Java类型
* @param listener
* @param errorListener
*/
public void jacksonRequest(final String url,final HashMap<String,String> params,TypeReference javaType, ResponseListener listener, Response.ErrorListener errorListener){
JacksonRequest jacksonRequest = new JacksonRequest(url,javaType,params,listener,errorListener);
requestQueue.add(jacksonRequest);
}
/**
* 普通的网络请求，返回的Json
* @param url
* @param params
* @param listener
* @param errorListener
*/
public void request(final String url,final HashMap<String,String> params,Response.Listener listener,Response.ErrorListener errorListener){
StringRequest stringRequest = new StringRequest(Request.Method.POST,url,listener,errorListener){
@Override
protected Map<String, String> getParams() throws AuthFailureError {
if (PrintLog.DEBUG) {
Iterator<Map.Entry<String,String>> iterator = params.entrySet().iterator();
StringBuilder builder = new StringBuilder(url+" ");
while (iterator.hasNext()){
Map.Entry<String,String> entry = iterator.next();
builder.append(entry.getKey()+":"+entry.getValue()).append("; ");
}
PrintLog.log(builder.toString());
}
return params;
}
};
requestQueue.add(stringRequest);
}
}
JacksonRequest---继承Request，重写deliverResponse方法，并调用ResponseListener的onResponse方法，并通过CacheManager.put(methodName, params, response);将获取的response缓存到CacheManager中。这一步很重要，调用我们自己的listener，而不是Volley提供给我们的Response.Listener
/**
* Created by mcoy
*/
public class JacksonRequest extends Request {
private final HashMap<String,String> params;
private final ResponseListener listener;
private final ObjectMapper mapper;
private final TypeReference javaType;
public JacksonRequest(String url,TypeReference javaType,HashMap<String,String> params,ResponseListener listener,Response.ErrorListener errorListener){
super(Method.POST,url,errorListener);
mapper = new ObjectMapper();
mapper.configure(JsonParser.Feature.ALLOW_SINGLE_QUOTES,true);
mapper.configure(DeserializationFeature.FAIL_ON_UNKNOWN_PROPERTIES, false);
this.params = params;
this.listener = listener;
this.javaType = javaType;
}
@Override
protected Map<String, String> getParams() throws AuthFailureError {
return params;
}
@Override
protected Response parseNetworkResponse(NetworkResponse response) {
String json;
try {
json = new String(response.data, HttpHeaderParser.parseCharset(response.headers));
PrintLog.log("返回的json:" + json);
return Response.success(mapper.readValue(json,javaType), HttpHeaderParser.parseCacheHeaders(response));
}catch (UnsupportedEncodingException e){
json = new String(response.data);
PrintLog.log("json:"+json);
try {
return Response.success(mapper.readValue(json,javaType),HttpHeaderParser.parseCacheHeaders(response));
} catch (IOException e1) {
return Response.error(new ParseError(e));
}
} catch (JsonParseException e) {
PrintLog.log(e.toString());
return Response.error(new ParseError(e));
} catch (JsonMappingException e) {PrintLog.log(e.toString());
return Response.error(new ParseError(e));
} catch (IOException e) {PrintLog.log(e.toString());
return Response.error(new ParseError(e));
}
}
@Override
protected void deliverResponse(Object response) {
listener.onResponse(response,true);
}
}
ResponseListener---自定义的一个listener接口， 在发送请求时，需要将其实现。其中才参数中比Volley的提供的listener过了一个isCache的Boolean值，根据此值来决定是否要缓存。
/**
* @version V1.0 <描述当前版本功能>
* @author: mcoy
*/
public interface ResponseListener<T> {
public void onResponse(T response, boolean isCache);
}
如有疑问请留言或者到本站社区交流讨论，感谢阅读，希望能帮助到大家，谢谢大家对本站的支持！
# Android
# Volley
# Volley网络请求及缓存
# Volley二次封装
# Android中网络框架简单封装的实例方法
# Android基于OkHttpUtils网络请求的二次封装
# Android Xutils3网络请求的封装详解及实例代码
# 初学Android之网络封装实例
# 不需要
# 写到
# 回调
# 自己的
# 都是
# 过了
# 都要
# 多个
# 如有
# 给我们
# 将其
# 希望能
# 很重要
# 自定义
# 重写
# 过得
# 谢谢大家
# 会去
# 重试
# 请稍后
相关栏目：
【
网站优化151355 】
【
网络推广146373 】
【
网络技术251813 】
【
AI营销90571 】
相关推荐：
如何在宝塔面板中修改默认建站目录？
如何在沈阳梯子盘古建站优化SEO排名与功能模块？
北京企业网站设计制作公司,北京铁路集团官方网站？
重庆市网站制作公司,重庆招聘网站哪个好？
HTML5空格和nbsp有啥关系_nbsp的作用及使用场景【说明】
如何使用 Go 正则表达式精准提取括号内首个纯字母标识符（忽略数字与嵌套）
浅谈Javascript中的Label语句
php8.4header发送头信息失败怎么办_php8.4header函数问题解决【解答】
php增删改查怎么学_零基础入门php数据库操作必知基础【教程】
Laravel如何发送系统通知？（Notification渠道示例）
Laravel如何实现全文搜索_Laravel Scout集成Algolia或Meilisearch教程
百度输入法ai组件怎么删除 百度输入法ai组件移除工具
Laravel如何实现用户角色和权限系统_Laravel角色权限管理机制
湖南网站制作公司,湖南上善若水科技有限公司做什么的？
网页设计与网站制作内容,怎样注册网站？
Laravel怎么实现一对多关联查询_Laravel Eloquent模型关系定义与预加载【实战】
利用 Google AI 进行 YouTube 视频 SEO 描述优化
jQuery validate插件功能与用法详解
如何在VPS电脑上快速搭建网站？
如何生成腾讯云建站专用兑换码？
如何快速生成专业多端适配建站电话？
如何在阿里云虚拟主机上快速搭建个人网站？
东莞市网站制作公司有哪些,东莞找工作用什么网站好？
网站图片在线制作软件,怎么在图片上做链接？
微博html5版本怎么弄发超话_超话进入入口及发帖格式要求【教程】
免费的流程图制作网站有哪些,2025年教师初级职称申报网上流程？
香港服务器网站推广：SEO优化与外贸独立站搭建策略
宙斯浏览器视频悬浮窗怎么开启 边看视频边操作其他应用教程
Laravel如何使用Telescope进行调试？（安装和使用教程）
,网页ppt怎么弄成自己的ppt？
香港网站服务器数量如何影响SEO优化效果？
*服务器网站为何频现安全漏洞？
武汉网站设计制作公司,武汉有哪些比较大的同城网站或论坛，就是里面都是武汉人的？
公司网站制作需要多少钱,找人做公司网站需要多少钱？
Python函数文档自动校验_规范解析【教程】
高防服务器租用首荐平台，企业级优惠套餐快速部署
Laravel Blade模板引擎语法_Laravel Blade布局继承用法
Laravel如何编写单元测试和功能测试？（PHPUnit示例）
HTML5建模怎么导出为FBX格式_FBX格式兼容性及导出步骤【指南】
Swift中swift中的switch 语句
javascript中的数组方法有哪些_如何利用数组方法简化数据处理
Laravel如何发送邮件和通知_Laravel邮件与通知系统发送步骤
Laravel如何集成Inertia.js与Vue/React？（安装配置）
如何用5美元大硬盘VPS安全高效搭建个人网站？
java中使用zxing批量生成二维码立牌
Laravel如何实现邮件验证激活账户_Laravel内置MustVerifyEmail接口配置【步骤】
网页制作模板网站推荐,网页设计海报之类的素材哪里好？
今日头条微视频如何找选题 今日头条微视频找选题技巧【指南】
Python文件异常处理策略_健壮性说明【指导】
如何快速选择适合个人网站的云服务器配置？
最新文章
Sublime怎么一键压缩JS代码 Su
sublime如何在搜索中使用正则表达式
Sublime如何设置透明窗口效果 Su
mysql如何设计商品表结构_mysql
css属性背景图不显示怎么办_通过检查路
如何使用Golang实现排序_Golan
农历闰月是怎么回事_为合回归年加一月调整
塑造《刺客信条》艾吉奥传奇的编剧离开育碧
1英里等于多少公里 1mile和km的换
css grid布局中行和列是如何定义的
PS批量旋转和翻转图片，快速校正图片方向
C# Swagger UI自定义方法 C
OPPO手机九宫格和全键盘怎么切换_OP
Go语言如何实现用户登录注册_Golan
1节飞行速度多少公里每小时 1节是多少公
纸嫁衣8千子树第五章庙门怎么开启 庙门
Laravel 多行数据编辑表单中实现逐
明日之后如何提升钓鱼等级 明日之后提升钓
支付宝怎样查年度账单_支付宝年度账单查看
C# 多线程UI更新Dispatcher