亚洲在线久爱草,狠狠天天香蕉网,天天搞日日干久草,伊人亚洲日本欧美

為了賬號安全,請及時綁定郵箱和手機立即綁定

重識OkHttp——更深入了解如何使用

標簽:
Android

本文的分析基于OkHttp3.4,不展示完整的代码示例,具体可以查看这个官方例子或者项目中的samples

OkHttp作为square公司出品的一个网络请求框架,应该算是目前Android端最火爆的网络框架了。我公司目前的项目中采用的都是Rxjava结合Retrofit进行网络请求的处理,对于底层真正实现网络请求的OkHttp关注的不是很多。最近探究了一下OkHttp的源码,对OkHttp的使用有了一些新的认识,在此做一下总结。

1 OkHttp的优点

OkHttp作为当前Android端最火热的网络请求框架,必然有很多的优点。

·         支持HTTP/2 协议,允许连接到同一个主机地址的所有请求共享Socket。这必然会提高请求效率。

·         在HTTP/2协议不可用的情况下,通过连接池减少请求的延迟。

·         GZip透明压缩减少传输的数据包大小。

·         响应缓存,避免同一个重复的网络请求。

2 网络处理3要素

对于客户端来讲,我们关注的就是把正确的请求发送到服务端并拿到结果来进行处理。在OkHttp中,我认为可以分为3个部分:

·         Request类封装客户端发送的请求,包括请求的url,请求方法method(主要是GET和POST方法)、请求头header以及请求体requestBody;

·         Response类封装了服务器响应的数据,包括code、message、body、header等。

·         OkHttpClient负责发送请求Request并通过同步或者异步的方式返回服务器的响应Response,就好比是一个浏览器。

OkHttp中通过建造者模式来构建OkHttpClient、Request和Response。对于客户端来讲,我们不需要过多关注Response是如何构建的,因为这个是OkHttp对响应结果进行了封装处理。我们只关注请求Request和客户端OkHttpClient如何构建即可。

2.1 请求Request

Request采用建造者模式来配置url,请求方法method、header、tag和cacheControl。

·         设置url。可以是String类型、URL类型和HttpUrl类型。最终都是用到HttpUrl类型。

·         设置method,包含get、post方法等。默认的是get方法。post方法要传RequestBody,类似的还有delete、put、patch。

·         设置header,方法有addHeader(String name, String value)、 removeHeader(String name)、header(String name, String value)、headers(Headers headers)。headers(Headers headers)调用之后其它的header都会被移除,只添加这一个header。而header(String name, String value)方法调用之后,其它与这个name同名的header都会被移除,只保留这一个header。

·         设置tag,设置tag可以用来取消这一请求。如果未指定tag或者tag为null,那么这个request本身就会当做是一个tag用来被取消请求。

·         设置cacheControl,这个是设置到请求头中。用来替换其它name是"Cache-Control"的header。如果cacheControl是空的话就会移除请求头中name是"Cache-Control"的header。

                                              

OkHttp采用POST方法向服务器发送一个请求体,在OkHttp中这个请求体是RequestBody。这个请求体可以是:

·         String类型

·         Stream流类型

·         File文件类型

·         Form表单形式的key-value类型

·         类似Html文件上传表单的复杂请求体类型(多块请求)。

RequestBody有几个静态方法用于创建不同类型的请求体:

[代码]java代码:

?

1

2

3

4

5

//创建String类型的请求体

public static RequestBody   create(MediaType contentType, String content)

 

//创建文件类型的请求体

 public static RequestBody create(final MediaType contentType, final File file)

最终都是相当于重写了RequestBody的两个抽象方法来写入流,如果传递流类型的参数,只要重写这两个抽象方法即可。

[代码]java代码:

?

1

2

3

4

5

6

7

8

//对应的是name为Content-Type的header

public abstract MediaType contentType();

 

//这个BufferedSink位于Okio包下,提供高效的写入。

public abstract void writeTo(BufferedSink   sink) throws IOException;

 

//在写入的时候可以传递内容的大小,如果不知道就返回-1即可。

public long contentLength()   throws IOException   {  return -1;}

例如,我们提交一个String:

[代码]java代码:

?

01

02

03

04

05

06

07

08

09

10

11

12

String postBody = ""

        +   "Releases\n"

        +   "--------\n"

        +   "\n"

        +   " * _1.0_ May 6, 2013\n"

        +   " * _1.1_ June 15, 2013\n"

        +   " * _1.2_ August 11, 2013\n";

 

Request request = new Request.Builder()

        .url("https://api.github.com/markdown/raw")

        .post(RequestBody.create(MEDIA_TYPE_MARKDOWN,   postBody))

        .build();

提交File:

[代码]java代码:

?

1

2

3

4

5

6

File file = new File("README.md");

 

Request request = new Request.Builder()

        .url("https://api.github.com/markdown/raw")

        .post(RequestBody.create(MEDIA_TYPE_MARKDOWN,   file))

        .build();

提交流:

[代码]java代码:

?

01

02

03

04

05

06

07

08

09

10

11

12

13

14

15

16

17

18

19

20

21

22

23

24

25

26

27

28

RequestBody requestBody = new RequestBody() {

       @Override

        public MediaType contentType() {

             return MEDIA_TYPE_MARKDOWN;

        }

 

        @Override

         public void writeTo(BufferedSink sink) throws IOException {

              sink.writeUtf8("Numbers\n");

              sink.writeUtf8("-------\n");

              for (int i = 2; i <= 997; i++) {

                     sink.writeUtf8(String.format("   * %s = %s\n", i, factor(i)));

               }

           }

 

          private String factor(int n) {

                for (int i = 2; i < n; i++) {

                     int x = n / i;

                     if (x * i == n) return factor(x) + " × " + i;

                 }

                return Integer.toString(n);

                }

};

 

Request request = new Request.Builder()

        .url("https://api.github.com/markdown/raw")

        .post(requestBody)

        .build();

对于提交表单和分块请求,OkHttp提供了两个RequestBody的子类,FormBodyMultipartBody

2.1.1 表单FormBody

FormBody也是采用建造者模式, 这个很简单,添加key-value形式的键值对即可。
添加键值对有两个方法:

[代码]java代码:

?

1

2

3

4

5

//采用OkHttp默认的编码

public Builder add(String name, String value)

 

//采用用户要求的编码

public Builder addEncoded(String name, String value)

例如:

[代码]java代码:

?

1

2

3

4

5

6

7

RequestBody formBody = new FormBody.Builder()

                      .add("search",   "Jurassic Park")

                      .build();

Request request = new Request.Builder()

                      .url("https://en.wikipedia.org/w/index.php")

                      .post(formBody)

                      .build();

2.1.2 分块MultipartBody

MultipartBody也是采用建造者模式,MultipartBody.Builder可以构建兼容Html文件上传表单的复杂请求体。每一部分的多块请求体都是它自身的请求体,并且可以定义它自己的请求头。如果存在的话,这些请求头用来描述这部分的请求体。例如Content-Disposition、Content-Length 和 Content-Type如果可用就会被自动添加到头。

MIME类型有:

[代码]java代码:

?

1

2

3

4

5

6

7

public static final MediaType MIXED = MediaType.parse("multipart/mixed");

 

  public static final MediaType   ALTERNATIVE = MediaType.parse("multipart/alternative");

 

  public static final MediaType   DIGEST = MediaType.parse("multipart/digest");

 

  public static final MediaType   PARALLEL = MediaType.parse("multipart/parallel");

有几个主要的方法:

[代码]java代码:

?

01

02

03

04

05

06

07

08

09

10

11

12

13

14

15

16

17

18

19

20

21

22

23

24

25

26

27

28

29

//设置MIME类型,如MIXED(默认的)

  public Builder setType(MediaType type) {}

 

//添加请求体

  public Builder addPart(RequestBody body) {

    return addPart(Part.create(body));

  }

 

//添加包含header的请求体

  public Builder addPart(Headers headers,   RequestBody body) {

    return addPart(Part.create(headers, body));

  }

 

  //请求体添加表单

  public Builder addFormDataPart(String name,   String value) {

    return addPart(Part.createFormData(name,   value));

  }

 

  //请求体中包含文件

  public Builder addFormDataPart(String name,   String filename, RequestBody body) {

    return addPart(Part.createFormData(name,   filename, body));

  }

 

  //添加自己定义的part

  public Builder addPart(Part part) {

    if (part == null) throw new NullPointerException("part == null");

    parts.add(part);

    return this;

  }

例如提交一个图片文件:

[代码]java代码:

?

01

02

03

04

05

06

07

08

09

10

11

12

RequestBody requestBody = new MultipartBody.Builder()

         .setType(MultipartBody.FORM)

        .addFormDataPart("title",   "Square Logo")

        .addFormDataPart("image",   "logo-square.png",

         RequestBody.create(MEDIA_TYPE_PNG,   new File("website/static/logo-square.png")))

        .build();

 

 Request request = new Request.Builder()

         .header("Authorization",   "Client-ID " + IMGUR_CLIENT_ID)

         .url("https://api.imgur.com/3/image")

         .post(requestBody)

         .build();

2.2 客户端OkHttpClient

OkHttpClient采用建造者模式,通过Builder可以配置连接超时时间、读写时间,是否缓存、是否重连,还可以设置各种拦截器interceptor等。
建议在一个App中,OkHttpClient保持一个实例。一个OkHttpClient支持一定数量的并发,请求同一个主机最大并发是5,所有的并发最大是64。这个与OkHttp中的调度器Dispatcher有关,可以设置并发数。本文不对Dispatcher进行讨论。

[代码]java代码:

?

1

2

3

4

OkHttpClient okHttpClient=new OkHttpClient.Builder().build();

 

//如果不需要我们额外配置,可以使用默认的配置

OkHttpClient okHttpClient1 = new OkHttpClient();

一个例子:

[代码]java代码:

?

01

02

03

04

05

06

07

08

09

10

int cacheSize = 10 * 1024 * 1024;   // 10 MiB

File cacheDirectory = new File(getCacheDir(), "OkHttpCache");

Cache cache = new Cache(cacheDirectory, cacheSize);

 

OkHttpClient client = new OkHttpClient.Builder()

        .connectTimeout(60,   TimeUnit.SECONDS)//连接超时时间

        .readTimeout(60,   TimeUnit.SECONDS)//读的时间

        .writeTimeout(60,   TimeUnit.SECONDS)//写的时间

        .cache(cache)//配置缓存

        .build();

OkHttpClient支持单独配置,例如原来设置不同的请求时间,可以通过OkHttpClient的newBuilder()方法来重新构造一个OkHttpClient。例如:

[代码]java代码:

?

01

02

03

04

05

06

07

08

09

10

11

OkHttpClient client = new OkHttpClient();

 

//读的时间设置为500ms

OkHttpClient copy = client.newBuilder()

                          .readTimeout(500,   TimeUnit.MILLISECONDS)

                          .build();

 

//读的时间设置为3000ms

OkHttpClient copy = client.newBuilder()

                          .readTimeout(3000,   TimeUnit.MILLISECONDS)

                          .build();

3 同步请求和异步请求

上面已经讲了如何创建Request和OkHttpClient,剩下的就是发送请求并得到服务器的响应了。OkHttp发送请求可分为同步和异步。OkHttpClient首先通过Request构建一个Call,通过这个Call去执行同步或者异步请求。

[代码]java代码:

?

1

2

#OkHttpClient

public Call newCall(Request request)

同步方式,调用Call的execute()方法,返回Response,会阻塞当前线程:

[代码]java代码:

?

1

response =   client.newCall(request).execute();

异步方式,调用Call的enqueue(CallBack callBack)方法,会在另一个线程中返回结果。

[代码]java代码:

?

01

02

03

04

05

06

07

08

09

10

11

client.newCall(request).enqueue(new Callback() {

            @Override

            public void onFailure(Call call, IOException e) {

              //处理错误的回调

            }

 

            @Override

            public void onResponse(Call call, Response response) throws IOException {

              //处理正确的回调

            }

        });

4 其他

4.1 配置响应缓存

为了缓存响应,需要一个可读写并且设置大小Size的缓存目录。缓存目录需要私有,其它不信任的应用不能访问这个文件。
如果同时有多个缓存访问同一个缓存目录会报错。所以最好只在App中初始化一次OkHttpClient,给这个实例配置缓存,在整个App生命周期内都用这一个缓存。否则几个缓存会相互影响,导致缓存出错,引起程序崩溃。
响应缓存采用Http头来配置,你可以添加这样的请求头Cache-Control: max-stale=3600。 max-age指的是客户端可以接收生存期不大于指定时间(以为单位)的响应。
为了防止响应使用缓存,可以用CacheControl.FORCE_NETWORK。为了防止使用网络,采用 CacheControl.FORCE_CACHE

注意:如果使用FORCE_CACHE禁止使用网络,而响应又没有缓存存在,OkHttp会报504 Unsatisfiable Request 响应错误。

4.2 取消请求

调用Call.cancel()方法可以立即取消一个网络请求。如果当前线程正在写request或者读response会报IO异常。如果不再需要网络请求,采用这种方法是比较方便的。例如在App中返回了上一页。无论是同步还是异步的请求都可以被取消。

4.3 Response读取响应结果

可以通过Response的code来判断请求是否成功,如果服务器返回的有数据,可以通过Response的body得到一个ResponseBody读取。
如果采用ResponseBody的string()方法会一次性把数据读取到内存中,如果数据超过1MB可能会报内存溢出,所以对于超过1MB的数据,建议采用流的方式去读取,如ResponseBody的byteStream()方法。

需要说明的是:

·         如果ResponseBody的内容不读取的话,不会触发IO流的读取操作

·         内容读取之后,这个body需要关闭。

5 总结

OkHttp中的很多类都用到了建造者模式,可以根据需要灵活配置。采用建造者模式的有:

·         OkHttpClient.Builder

·         Request.Builder

·         FormBody.Builder

·         MultipartBody.Builder

·         Response.Builder

如果单独使用OkHttp进行网络请求,通常需要开发者自己再封装一下,如果不想重复造轮子,Github上面的有一些优秀开源库可以拿来使用(本文只列出star较多的几个):

·         hongyangAndroid/okhttputils(曾经在项目中用过)

·         jeasonlzy/okhttp-OkGo

·         yanzhenjie/NoHttp

原文链接:http://www.apkbus.com/blog-705730-62601.html

點擊查看更多內容
TA 點贊

若覺得本文不錯,就分享一下吧!

評論

作者其他優質文章

正在加載中
  • 推薦
  • 評論
  • 收藏
  • 共同學習,寫下你的評論
感謝您的支持,我會繼續努力的~
掃碼打賞,你說多少就多少
贊賞金額會直接到老師賬戶
支付方式
打開微信掃一掃,即可進行掃碼打賞哦
今天注冊有機會得

100積分直接送

付費專欄免費學

大額優惠券免費領

立即參與 放棄機會
微信客服

購課補貼
聯系客服咨詢優惠詳情

幫助反饋 APP下載

慕課網APP
您的移動學習伙伴

公眾號

掃描二維碼
關注慕課網微信公眾號

舉報

0/150
提交
取消