Android开发——你应该要知道 OkHttp

android机器人.jpg

前言:现在做 Android 开发,应该绝大部分都是用 OkHttp 来做网络请求的。可见 OkHttp 的强大。今天来总结下 OkHttp 的使用,OkHttp 中用到了大量的 Builder 模式,建议看此文章前先阅读 Android开发---Builder 模式必知必会

OkHttp 学习之前,应该对 Http 有一定的了解,可以参考下这里:你需要了解的HTTP知识都在这里了!

开头引用官网的自我介绍:

HTTP是现代应用网络的方式。这是我们如何交换数据和媒体。有效地进行HTTP使您的东西加载更快,并节省带宽。

OkHttp 有以下特点:

  • HTTP / 2支持允许同一主机的所有请求共享套接字。
  • 连接池减少请求延迟(如果HTTP / 2不可用)。
  • 透明GZIP缩小下载大小。
  • 响应缓存可以避免重复请求的网络。

ok,我们开始来探究一下 OkHttp 的使用。

首先添加依赖

compile 'com.squareup.okhttp3:okhttp:3.8.0'

OkHttp 发起网络请求非常简单,具体步骤如下:

  • 构建 OkHttpClient 客户端
  • 构建 Request 请求
  • 创建 Call 对象,发起网络请求
  • 处理 Response 响应结果

这么看来,只要搞懂这几个关键类,跟调用请求的过程。对于 OkHttp 的基本使用就没问题了。

一、Request

Request 对应于 Http 的请求报文,查看源码可以看到,Request 封装了请求报文的一些字段。

发起网络请求必然要配置这些请求报文字段,Request 采用 Builder 模式,通过 Builder 内部类使我们灵活去配置 Request 对象,默认初始化Request request = new Request.Builder().build();是配置了请求头,请求方法GET,也可以在调用build()方法之前调用对应方法进行配置。如果需要对 其中的某个字段做特殊配置,可以Request.Builder builder = request.newBuilder() 拿到 Builder 对象进行 "返厂重建"。

  • Http 请求地址 url
  • 请求方法,例如(GET,POST等等),配置请求方法时调用get()post()等,内部都是调用 method()方法传入请求方法与请求体,并对是否需要请求体进行判断。
  • Headers:维护 Http 消息的头字段,内部也是通过 Builder 模式构建字符串键值对来维护消息头。
  • Request初始化时默认构造了 Headers的 Builder 实例,我们初始化Request可以调用header()方法设置请求头的namevalue字段。其实内部是调用了Headers的 Builder 实例的set()方法设置的,这种方法设置的 head表示name是唯一的。因为设置之前内部调用了removeAll()方法先移除了相同的name对应的value
  • 如果想添加多个name相同的请求头,可以调用addHeader()方法进行设置,其实内部是调用了Headers的 Builder 实例的add()方法设置的
  • 也可以调用 removeHeader()方法移除同一个name的所有请求头
  • 可以通过 Requesthead()方法获得指定请求头,·其实内部也是通过 Headersget()方法通过name获取的valueheaders()方法获得同一个name的所有value值,以list形式返回
  • 请求体 RequestBody(一般用来向服务器提交数据请求时用到)
  • tag,设置请求标签,用于取消网络请求
  • CacheControl 用于控制缓存使用。

二、构建 RequestBody

用于携带数据请求服务器,一般就是在特定的请求才会携带请求头,例如 POSTPUT等。查看 RequestBody源码可以看到有五个 static 方法用于创建 RequestBody实例,第一个参数都是 MediaType 表示数据的 MIME 类型,第二个参数分别可选为:StringFilebyte[]或者ByteString,也就是提交的数据内容。

  • MediaType类封装了三个字段:typesubtypeCharSet 。分别对应 MIME 类型中的 数据类数据类型下的子类编码类型。例如 text/x-markdown; charset=utf-8text 代表文本大类(type),x-markdown代表文本类下的子类(subtype),charset=utf-8则表示采用UTF-8编码,内部封装了一个解析方法parse(),只要传入这些信息就能获得MediaType 实例。可以参考链接Media TypesMIME 参考手册 平时比较常用的 MIME 类型如下:json :application/jsonxml:application/xmlpng:image/pngjpg: image/jpeggif:image/gif

除了直接使用静态方法create() 构建之外, RequestBody 还有两个直接子类FormBodyMultipartBody,分别用于提交 Form 表单中的键值对和构建分块表单请求体(既可以添加表单,又可以也可以添加文件等二进制数据)

FormBody表单创建

通过内部类 Builder 构建 FormBody 实例,同时调用 add() 传入需要传的键值对,例如:

RequestBody formBody = new FormBody.Builder()
        .add("username", "张少林")
        .build();

构建分块表单请求体 MultipartBody

MultipartBody 也是通过内部类 MultipartBody.Builder 动态构建实例,构建实例之前有以下几个方法:

  • setType():设置MultipartBodyMediaType类型,一般会设置为MultipartBody.FORM,也就是multipart/form-data.
  • addFormDataPart(String name, String value):添加字符串键值对
  • addFormDataPart(String name, @Nullable String filename, RequestBody body):添加表单文件
  • 其中三个重载 addPart() 方法,分别添加请求体,其中的addPart(@Nullable Headers headers, RequestBody body)可以在添加RequestBody的时候,同时为其单独设置请求头

源码浅析:查看MultipartBody.Builder源码发现,addFormDataPart(String name, String value)内部其实都是调用了addPart(Part part),而addPart(Part part)内部是往全局实例化好的List<Part>中 add 实例化好的part。而MultipartBody.Part其实就是包含了RequestBody,所以可以说 MultipartBody是一个RequestBody的集合。

三、Response

Response对应于 Http 的响应报文,查看源码可以看到,Request 封装了响应报文的一些字段。

封装的字段有 对应的请求报文Request ,响应码 code,响应消息 message,响应体ResponseBody,网络请求响应结果以及缓存响应结果等字段。同样的,Response 的构建也是通过内部类 Response.Builder 进行动态灵活配置,对其中的一些常用方法做简单介绍:

  • isSuccessful():用来判断请求是否成功
  • body() :返回响应体ResponseBody
  • headers():获取响应头 Headers 对象

四、ResponseBody

通过 Responsebody()方法可以得到响应体ResponseBody,响应体必须最终要被关闭,否则会导致资源泄露、App运行变慢甚至崩溃。

响应体中的数据有可能很大,应该只读取一次响应体的数据。调用ResponseBodybytes()string()方法会将整个响应体数据写入到内存中,可以通过source()byteStream()charStream()进行流式处理。

五、OkHttpClient

OkHttp 网络请求客户端,封装了 一些客户端请求的常用配置,例如请求超时时间、连接超时时间、读取超时时间、缓存目录、代理等等。

同样,OkHttpClient 也是通过内部类 Builder 模式,动态灵活的配置参数,从而构建 OkHttpClient 实例。默认初始化 OkHttpClient client = new OkHttpClient() 内部已经帮我们配置了一系列参数,我们需要自己配置参数的话,只需要通过内部类 Builder 实例,在调用 build()方法之前,调用对应方法动态配置即可。OkHttpClient client = new OkHttpClient.Builder().build();例如我们动态配置读取时间为30秒(默认配置为10秒):

OkHttpClient client = new OkHttpClient.Builder()
        .readTimeout(30, TimeUnit.SECONDS)
        .build();

当配置完成之后,我们需要对特定的请求配置不同的参数,也可以OkHttpClient.Builder builder = okHttpClient.newBuilder();
拿到 Builder 类实例进行"返厂重建"

当然了,还有很多参数可以配置,具体可以查阅文档 OkHttpClient参数配置

注意:在创建 OkHttpClient 时,应当保持全局单例, 每一个 OkHttpClient 实例都保持着自己的连接池和线程池 ,重用连接池和线程池会节省一些内部资源,假如每次请求都去创建新的客户端实例,就会造成一定的资源浪费

六、创建 Call 对象,发起网络请求

查阅 OkHttpClient 源码,我们看到有个 newCall()方法,传入 Request 实例,返回一个 Call 对象。我们暂且不用考虑它的原理,只知道可以用它来发起网络请求,返回 Response 响应报文。点击进去查看 Call 接口,可以看到有两个方法是用来请求网络的。

  • execute():同步的网络请求,返回 Response 响应结果,由于同步请求会阻塞当前线程,我们使用过程还需要开启子线程,所以一般较少使用。
  • enqueue(Callback responseCallback):加入队列,也就是异步网络请求,传入回调接口,发起网络请求时,请求成功会回掉Callback 对象的 onResponse 方法,同时返回 Response 响应报文,对结果进行处理。请求失败则回调Callback对象的onFailure方法,对失败进行处理。由于异步请求不会阻塞当前线程,所以一般使用异步请求,注意:不管是成功还是失败的回调方法都是在子线程,不能直接进行 ui 操作
  • isCanceled() 方法用于判断网络请求是否取消
  • isExecuted()方法用于判断网络请求是否已经执行
  • request()返回发起该请求的 Request 请求报文
  • clone()方法克隆一个 Call 对象

七、实际使用

至此,已经理清了 OkHttp 的关键类以及网络请求步骤,现在对于 OkHttp 的基本使用已经没多大问题了,下面举例几个实际场景使用,滴滴滴,开车~~~

别忘了添加网络权限:

<uses-permission android:name="android.permission.INTERNET"/>

同步 GET 请求

  private void sync_get() throws IOException {
        //构建okHttp客户端
        OkHttpClient okHttpClient = new OkHttpClient();
        //构建请求报文
        Request request = new Request.Builder()
                .url("http://www.baidu.com")//配置请求百度首页地址
                .build();

        //发起同步请求,返回响应报文
        Response response = okHttpClient.newCall(request).execute();
        if (response.isSuccessful()) {
            //获取Headers 请求头对象
            Headers headers = response.headers();
            for (int i = 0; i < headers.size(); i++) {
                //分别获取请求头的name,value值
                String headName = headers.name(i);
                String headValue = headers.value(i);
            }
            //将响应体中的数据转为 String ,读取到内存
            final String string = response.body().string();
        } else {
            //失败处理
        }
    }

注意: 同步请求必须开启子线程,我这里省略部分代码

异步 GET 请求

  private void async_get() {
        //构建okHttp客户端
        OkHttpClient okHttpClient = new OkHttpClient();
        //构建请求报文
        Request request = new Request.Builder()
                .url("http://www.baidu.com")
                .build();
        //发起异步请求,返回响应报文
        okHttpClient.newCall(request)
                .enqueue(new Callback() {
                    @Override
                    public void onFailure(Call call, IOException e) {
                        //失败处理
                        Log.e(TAG, "onFailure: " + Thread.currentThread().getName());
                    }

                    @Override
                    public void onResponse(Call call, Response response) throws IOException {
                        Log.e(TAG, "onResponse: " + Thread.currentThread().getName());
                        //获取Headers 请求头对象
                        Headers headers = response.headers();
                        for (int i = 0; i < headers.size(); i++) {
                            //分别获取请求头的name,value值
                            String headName = headers.name(i);
                            String headValue = headers.value(i);
                        }
                        //将响应体中的数据转为 String ,读取到内存
                        final String string = response.body().string();
                    }
                });
    }

异步请求不需要自己开启子线程,打印回调方法的线程名发现,成功或者失败回调默认都是在子线程

  //06-21 22:52:01.567 30162-30277/com.sunnada.okhttpdemo E/MainActivity: onResponse: OkHttp http://www.baidu.com/...

POST 上传 json 字符串

public void async_post() {
        //解析数据类型为json
        MediaType MEDIA_TYPE_JSON
                = MediaType.parse("application/json; charset=utf-8");
        //构建OkHttp 客户端
        OkHttpClient okHttpClient = new OkHttpClient();
        //构建json数据源
        User user = new User("张少林", "123456");
        String json = new Gson().toJson(user);
        //初始化请求体
        RequestBody requestBody = RequestBody.create(MEDIA_TYPE_JSON, json);
        //初始化请求报文
        Request request = new Request.Builder()
                .url("http://192.168.1.104:8080/users/uploadJson")//配置服务端请求地址
                .post(requestBody)//配置请求方法,传入请求体
                .build();
        //发起异步请求,回调处理结果
        okHttpClient.newCall(request)
                .enqueue(new Callback() {
                    @Override
                    public void onFailure(Call call, IOException e) {
                        //失败回调
                    }

                    @Override
                    public void onResponse(Call call, Response response) throws IOException {
                           if (!response.isSuccessful())
                            throw new IOException("Unexpected code " + response);
                        Log.e(TAG, "onResponse: " + response.body().string());
                    }
                });
    }

POST 上传文件

    public void postFile() {
        //获取手机中的图片文件
        List<File> files = FileUtils.listFilesInDir(SDCardUtils.getSDCardPath() + "/Pictures/Screenshots", false);
        File file = files.get(1);
        String fileName = file.getName();
        //构建OkHttp 客户端
        OkHttpClient okHttpClient = new OkHttpClient();
        if (!file.exists()) {
            ToastUtils.showLong("文件不存在");
        } else {
            //构建文件请求头
            RequestBody requestBody = RequestBody.create(MediaType.parse("application/octet-stream"), file);
            Request request = new Request.Builder()
                    .url("http://192.168.1.104:8080/upload")
                    .post(requestBody)
                    .build();
            okHttpClient.newCall(request)
                    .enqueue(new Callback() {
                        @Override
                        public void onFailure(Call call, IOException e) {

                        }

                        @Override
                        public void onResponse(Call call, Response response) throws IOException {
                              if (!response.isSuccessful())
                            throw new IOException("Unexpected code " + response);
                        Log.e(TAG, "onResponse: " + response.body().string());
                        }
                    });
        }
    }

POST 提交表单

  public void post_form() {
        //构建okHttp客户端
        OkHttpClient okHttpClient = new OkHttpClient();
        RequestBody formBody = new FormBody.Builder()
                .add("username", "张少林")
                .add("password", "123456")
                .build();
        Request request = new Request.Builder()
                .url("http://192.168.1.104:8080/users/register")
                .post(formBody)
                .build();
        okHttpClient.newCall(request)
                .enqueue(new Callback() {
                    @Override
                    public void onFailure(Call call, IOException e) {

                    }

                    @Override
                    public void onResponse(Call call, Response response) throws IOException {
                      if (!response.isSuccessful())
                            throw new IOException("Unexpected code " + response);
                        Log.e(TAG, "onResponse: " + response.body().string());
                    }
                });
    }

POST 图文上传

public void post_img_title() {
        //获取手机中的图片文件
        List<File> files = FileUtils.listFilesInDir(SDCardUtils.getSDCardPath() + "/Pictures/Screenshots", false);
        File file = files.get(1);
        MediaType MEDIA_TYPE_PNG = MediaType.parse("image/png");
        OkHttpClient client = new OkHttpClient();
        RequestBody requestBody = new MultipartBody.Builder()
                .setType(MultipartBody.FORM)//设置表单类型
                .addFormDataPart("title", "Logo")//添加表单键值对
                .addFormDataPart("image", "logo.png", RequestBody.create(MEDIA_TYPE_PNG, file))//添加表单文件
                .build();
        Request request = new Request.Builder()
                .url("xxxxxxx")
                .post(requestBody)
                .build();
        client.newCall(request)
                .enqueue(new Callback() {
                    @Override
                    public void onFailure(Call call, IOException e) {
                      //请求失败处理
                    }

                    @Override
                    public void onResponse(Call call, Response response) throws IOException {
                        if (!response.isSuccessful())
                            throw new IOException("Unexpected code " + response);
                        Log.e(TAG, "onResponse: " + response.body().string());
                    }
                });
    }

文件下载,这里下载一张图片

 public void downloadImg(){
        OkHttpClient client = new OkHttpClient();
        final Request request = new Request.Builder()
                .get()
                .url("https://www.baidu.com/img/bd_logo1.png")
                .build();
        Call call = client.newCall(request);
        call.enqueue(new Callback() {
            @Override
            public void onFailure(Call call, IOException e) {
                
            }

            @Override
            public void onResponse(Call call, Response response) throws IOException {
                //拿到字节流
                InputStream is = response.body().byteStream();

                int len = 0;
                File file  = new File(Environment.getExternalStorageDirectory(), "image.png");
                FileOutputStream fos = new FileOutputStream(file);
                byte[] buf = new byte[128];

                while ((len = is.read(buf)) != -1){
                    fos.write(buf, 0, len);
                }

                fos.flush();
                //关闭流
                fos.close();
                is.close();
            }
        });
    }

滴滴,到站了,下车~~~

最后

结语:虽说正式开发中,一般会使用基于 OkHttp 封装一层的网络库,例如 Retrofit 2,OkGo,底层还是使用OkHttp 做网络请求的,个人觉得绝对有必要理清 OkHttp 的基本使用,有时间甚至可以自己封装一个网络框架出来也是个好的磨练。通过这次的总结,加上看 OkHttp 的部分源码,收获不小,最大的感悟就是不应该只会调用 api ,而应该经常去看看流行框架的源码,好的框架源码是值得一看的。计划下次对 OkHttp 的缓存,以及拦截器做一下总结~

一点点学习总结,一点点思考,如有不足还请指出,如果喜欢,小手一点给个赞~~

如需转载请注明出处,谢谢~
http://www.jianshu.com/u/52ccd7428abe

最后的最后,感谢乐于分享的大神,参考链接:

更多原创文章会在公众号第一时间推送,欢迎扫码关注 张少林同学

张少林同学.jpg
最后编辑于
©著作权归作者所有,转载或内容合作请联系作者
  • 序言:七十年代末,一起剥皮案震惊了整个滨河市,随后出现的几起案子,更是在滨河造成了极大的恐慌,老刑警刘岩,带你破解...
    沈念sama阅读 216,997评论 6 502
  • 序言:滨河连续发生了三起死亡事件,死亡现场离奇诡异,居然都是意外死亡,警方通过查阅死者的电脑和手机,发现死者居然都...
    沈念sama阅读 92,603评论 3 392
  • 文/潘晓璐 我一进店门,熙熙楼的掌柜王于贵愁眉苦脸地迎上来,“玉大人,你说我怎么就摊上这事。” “怎么了?”我有些...
    开封第一讲书人阅读 163,359评论 0 353
  • 文/不坏的土叔 我叫张陵,是天一观的道长。 经常有香客问我,道长,这世上最难降的妖魔是什么? 我笑而不...
    开封第一讲书人阅读 58,309评论 1 292
  • 正文 为了忘掉前任,我火速办了婚礼,结果婚礼上,老公的妹妹穿的比我还像新娘。我一直安慰自己,他们只是感情好,可当我...
    茶点故事阅读 67,346评论 6 390
  • 文/花漫 我一把揭开白布。 她就那样静静地躺着,像睡着了一般。 火红的嫁衣衬着肌肤如雪。 梳的纹丝不乱的头发上,一...
    开封第一讲书人阅读 51,258评论 1 300
  • 那天,我揣着相机与录音,去河边找鬼。 笑死,一个胖子当着我的面吹牛,可吹牛的内容都是我干的。 我是一名探鬼主播,决...
    沈念sama阅读 40,122评论 3 418
  • 文/苍兰香墨 我猛地睁开眼,长吁一口气:“原来是场噩梦啊……” “哼!你这毒妇竟也来了?” 一声冷哼从身侧响起,我...
    开封第一讲书人阅读 38,970评论 0 275
  • 序言:老挝万荣一对情侣失踪,失踪者是张志新(化名)和其女友刘颖,没想到半个月后,有当地人在树林里发现了一具尸体,经...
    沈念sama阅读 45,403评论 1 313
  • 正文 独居荒郊野岭守林人离奇死亡,尸身上长有42处带血的脓包…… 初始之章·张勋 以下内容为张勋视角 年9月15日...
    茶点故事阅读 37,596评论 3 334
  • 正文 我和宋清朗相恋三年,在试婚纱的时候发现自己被绿了。 大学时的朋友给我发了我未婚夫和他白月光在一起吃饭的照片。...
    茶点故事阅读 39,769评论 1 348
  • 序言:一个原本活蹦乱跳的男人离奇死亡,死状恐怖,灵堂内的尸体忽然破棺而出,到底是诈尸还是另有隐情,我是刑警宁泽,带...
    沈念sama阅读 35,464评论 5 344
  • 正文 年R本政府宣布,位于F岛的核电站,受9级特大地震影响,放射性物质发生泄漏。R本人自食恶果不足惜,却给世界环境...
    茶点故事阅读 41,075评论 3 327
  • 文/蒙蒙 一、第九天 我趴在偏房一处隐蔽的房顶上张望。 院中可真热闹,春花似锦、人声如沸。这庄子的主人今日做“春日...
    开封第一讲书人阅读 31,705评论 0 22
  • 文/苍兰香墨 我抬头看了看天上的太阳。三九已至,却和暖如春,着一层夹袄步出监牢的瞬间,已是汗流浃背。 一阵脚步声响...
    开封第一讲书人阅读 32,848评论 1 269
  • 我被黑心中介骗来泰国打工, 没想到刚下飞机就差点儿被人妖公主榨干…… 1. 我叫王不留,地道东北人。 一个月前我还...
    沈念sama阅读 47,831评论 2 370
  • 正文 我出身青楼,却偏偏与公主长得像,于是被迫代替她去往敌国和亲。 传闻我的和亲对象是个残疾皇子,可洞房花烛夜当晚...
    茶点故事阅读 44,678评论 2 354

推荐阅读更多精彩内容