当前位置:首页 > 安卓源码 > 技术博客 >

Android的网络请求中的一些基础知识及缓存的应用

时间:2019-07-23 23:24 来源:互联网 作者:源码搜藏 浏览: 收藏 挑错 推荐 打印

HTTP请求和响应相关知识 okhttp和拦截 改造+ okhttp + rxjava的缓存实现 HTTP相关知识 直接贴上裘德的图,犹是我的好老师 请求包巴纽 例子巴纽 响应包巴纽 例子巴纽 请求头描述了客户端向服务器发送请求时使用的HTTP协议类型,所使用的编码,以及发送内容的
  • HTTP请求和响应相关知识
  • okhttp和拦截
  • 改造+ okhttp + rxjava的缓存实现

HTTP相关知识

直接贴上裘德的图,犹是我的好老师

Android的网络请求中的一些基础知识及缓存的应用
请求包巴纽
Android的网络请求中的一些基础知识及缓存的应用
例子巴纽
Android的网络请求中的一些基础知识及缓存的应用
响应包巴纽
Android的网络请求中的一些基础知识及缓存的应用
例子巴纽

请求头描述了客户端向服务器发送请求时使用的HTTP协议类型,所使用的编码,以及发送内容的长度,等等。

相应的响应头用来描述服务器回给你对所返回的内容的一些描述,服务器类型,我返回的编码,我返回的内容有多长等等。

okhttp

okhttp是现在开发中相对成熟的网络请求框架,对比HttpURLConnection类有更易用的API和更优良的性能。

在这里对于常规的get / post同步/异步的方法就不提了,主要是对应上面的介绍写一些高级用法。

请求和响应的报头部分

这部分为了下文缓存部分如何添加报头做介绍

请求包对应okhttp中的Request,响应包对应Response

当写请求头的时候,使用头(名称,值)可以设置唯一的名称,值。如果已经有值,旧的将被移除,然后添加新的。使用addHeader(name,value)
可以添加多值(添加,不移除已有的)。当读取响应头时,使用报头(名称)
返回最后出现的名称,值。通常情况这也是唯一的名称,值。如果没有值,那么报头(名称)将返回空值。如果想读取字段对应的所有值,使用头文件(名称)会返回一个列表。

拦截器

拦截器,就像他的翻译一样“拦截器”,拦截你的请求,做一些想做的事情再发送出去。

改写请求和响应
Interceptor interceptor = new Interceptor() {  
            public Response intercept(Chain chain) throws IOException {
                return null;
            }
        };

可以通过以下代码获取被拦截的Request

Request request = chain.request();

然后可以对这个请求进行newBuilder()重新产生一个请求发送出去

调用以下代码产生一个满足请求的响应

Response response = chain.proceed(request);

当我们执行到继续进行,就会去判断是否有拦截器,有的话先执行拦截器里的截距,而在拦截里一般会进行一些自定义操作并且调用procced去判断是否要继续执行拦截器操作还是直接去获取网络请求

public Response proceed(Request request) throws IOException {
//判断还有拦截器需要执行不,生成新的ApplicationInterceptorChain并调用它的intercept去执行用户定义的操作
           if(this.index < Call.this.client.interceptors().size()) {
               Call.ApplicationInterceptorChain chain = Call.this.new ApplicationInterceptorChain(this.index + 1, request, this.forWebSocket);
               return ((Interceptor)Call.this.client.interceptors().get(this.index)).intercept(chain);
           } else {
               return Call.this.getResponse(request, this.forWebSocket);
           }
       }

缓存(改型+ okhttp + rxjava)

应用网络数据的离线缓存实现有很多种办法,例如存进数据库(保存JSON使用时拿出来解析),存专有文件,或者SharedPreference等等,也可以自己实现LruCache和
DiskLruCache这两种缓存策略构成二级缓存(内存和磁盘)

缓存对于移动端是非常重要的存在。

  • 减少请求次数,减小服务器压力。
  • 本地数据读取速度更快,让页面不会空白几百毫秒。
  • 在无网络的情况下提供数据。

okhttp的缓存设计和浏览器的缓存设计差不多,可以通过添加响应头的形式进行缓存处理。

关于添加响应头和其他缓存知识请看这个链接web缓存相关概念
(笔者还没看完= =)

改造是依赖okhttp的一套基于REST架构的安卓(JAVA)端的客户实现
通过构造改造时的.client()方法更改其中的okhttp的实现,从而达到缓存的效果,在这里不介绍改造的具体用法。

下面是一个例子实现了有网缓存,无网络只读取缓存

File cacheFile = new File(APP.getContext().getExternalCacheDir(),"ZhiBookCache");
        Cache cache = new Cache(cacheFile,1024*1024*50);
        Interceptor interceptor = new Interceptor() {
            @Override
            public Response intercept(Chain chain) throws IOException {
                Request request = chain.request();
                if (!HttpUtils.isNetworkConnected(APP.getContext())) {
                    request = request.newBuilder()
                            .cacheControl(CacheControl.FORCE_CACHE)
                            .build();
                }
                Response response = chain.proceed(request);
                if (HttpUtils.isNetworkConnected(APP.getContext())) {
                    int maxAge = 0 * 60;
                    // 有网络时 设置缓存超时时间0个小时
                    response.newBuilder()
                            .header("Cache-Control", "public, max-age=" + maxAge)
                            .removeHeader("Pragma")// 清除头信息,因为服务器如果不支持,会返回一些干扰信息,不清除下面无法生效
                            .build();
                } else {
                    // 无网络时,设置超时为4周
                    int maxStale = 60 * 60 * 24 * 28;
                    response.newBuilder()
                            .header("Cache-Control", "public, only-if-cached, max-stale=" + maxStale)
                            .removeHeader("Pragma")
                            .build();
                }
                return response;
            }
        };
        client = new OkHttpClient.Builder().cache(cache)
                .addInterceptor(interceptor)
                .build();
        retrofit = new Retrofit.Builder()
                .baseUrl(RetrofitAPI.BASIC_DAILY)
                .addConverterFactory(GsonConverterFactory.create())
                .addCallAdapterFactory(RxJavaCallAdapterFactory.create())
                .client(client)
                .build();
        retrofitAPI = retrofit.create(RetrofitAPI.class);

之后调用下面代码获取请求后的序列化对象

retrofitAPI.getDaily()
                .subscribeOn(Schedulers.io())
                .observeOn(AndroidSchedulers.mainThread())
                .subscribe(new Observer<DailyBean>() {
                    @Override
                    public void onCompleted() {

                    }

                    @Override
                    public void onError(Throwable e) {
                        Log.d(TAG,e.getMessage());
                    }

                    @Override
                    public void onNext(DailyBean bean) {
                        listener.onGetDailySuccess(bean);
                    }
                });

最后附上改装接口部分

@GET("news/latest")
Observable<DailyBean> getDaily();
Android的网络请求中的一些基础知识及缓存的应用 转载https://www.codesocang.com/appboke/40978.html

技术博客阅读排行

最新文章