Square

square 开源库 OkHttp的分析

看一下示例：

  • get方式请求一个URL的内容

    package com.squareup.okhttp.guide;
import com.squareup.okhttp.OkHttpClient;
import com.squareup.okhttp.Request;
import com.squareup.okhttp.Response;
improt java.io.IOException;

public class GetExample {
   //初始化一个OkHttpClient
   OkHttpClient client = new OkHttpClient();
   //Get请求的核心方法
   String run(String url) throws IOException {
     //生成一个request,把url放进去
     Request request = new Request.Builder()
         .url(url)
         .build();
     //执行request，并得到response
     Response response = client.newCall(request).execute();
     //把response中的body转化为string返回
     return response.body().string();
   }
   public static void main(String[] args) throws IOException {
     GetExample example = new GetExample();
     String response = example.run("https://raw.github.com/square/okhttp/master/README.md");
     System.out.println(response);
   }
}

  • Post方式提交内容到服务器

    package com.squareup.okhttp.guide;
improt com.squareup.okhttp.MediaType;
improt com.squareup.okhttp.OkHttpClient;
import com.squareup.okhttp.Request;
import com.squareup.okhttp.RequestBody;
import com.squareup.okhttp.Response;
improt java.io.IOException;
public class PostExample {
  public static final MediaType JSON
      = MediaType.parse("application/json; charset=utf-8");
  //初始化一个OkHttpClient
  OkHttpClient client = new OkHttpClient();
  //post请求的核心方法
  String post(String url, String json) throws IOException {
    //创建一个Json格式的请求body
    RequestBody body = RequestBody.create(JSON, json);
    //生成一个request，把url和body放进去
    Request request = new Request.Builder()
        .url(url)
        .post(body)
        .build();
    //执行request，并得到response
    Response response = client.newCall(request).execute();
    //把response中的body转化成string返回
    return response.body().string();
  }
  //模拟一段测试的Json数据
  String bowlingJson(String player1, String player2) {
    return "{'winCondition':'HIGH_SCORE',"
        + "'name':'Bowling',"
        + "'round':4,"
        + "'lastSaved':1367702411696,"
        + "'dateStarted':1367702378785,"
        + "'players':["
        + "{'name':'" + player1 + "','history':[10,8,6,7,8],'color':-13388315,'total':39},"
        + "{'name':'" + player2 + "','history':[6,10,5,10,10],'color':-48060,'total':41}"
        + "]}";
  }

  public static void main(String[] args) throws IOException {
    PostExample example = new PostExample();
    String json = example.bowlingJson("Jesse", "Jake");
    String response = example.post("http://www.roundsapp.com/post", json);
    System.out.println(response);
  }

}

调用(calls)

HTTP客户端的工作就是接受你的request并产生response。

  • Request

  • Response

    利用一个code来响应一个请求，response也包括一个头部（headers）和一个可选的实体(body)

改写请求(Rewriting Requests)

请求利用头部的headers的URL来抓取信息，为了保证正确性和效率，OkHttp会在发送前改写你的请求。

改写响应(Rewriting responses)

get请求成功，网络返回的响应和缓存中的响应将会被合并。

跟进请求(Follow-up Requests)

  • 当你请求的URL已经转移，服务器将返回一个响应代码(302)表示文档所在的新的URL。

    OKHttp将跟随重定向去取得最终的Response。

    如果响应遇到一个关于授权的挑战，OKHttp会通过Authenticator(如果这个是配置好的)来满足这个挑战

    如果Authenticator提供了一个凭证，Request就会用这个凭证去重试。

重试请求(Retrying Requests)

  • 有时连接会失败：有可能是一个池的连接不新鲜或连接断开了，也有可能是服务器本身不能到达。如果有一个可用的不同的路由，OKHttp将重试这个请求。

调用(Calls)

通过上面的改写，重定向，跟进和重试，你简单的请求可能会产生很多的请求和响应。OKHttp使用Call去满足你的Request的任 务是必要的(不管通过了多少中间的请求和响应)。通常中间的请求和响应不会很多，更令人欣喜的是，如果你的URL重定向了或 者是转移到到另一个IP地址，你的HTTP请求代码将会继续工作。

Calls有以下两种执行方式：

  • 同步： 你的线程会一直阻塞到直到Response到达。

  • 异步： 你可以在任何线程中排队请求。当Response到达时，你将在另一个线程中获得回调。

    Calls可以任何线程中取消。如果这个请求尚未完成，它将返回失败。如果代码中正在write一个request
    body或者是正在read一个response body，这时候你取消了这个请求，就会得到IOException的异常。

调度(dispatch)

对于同步调用,你通过自己的线程管理并发请求。注意，太多的并发连接浪费资源;太少的并发连接导致延。

对于异步调用,调度器实现了最大化的并发请求策略。你可以设置per-webserver(默认为5)和overall(默认是64)的最大值。

连接(Connections)

OkHttp和你的服务器时会使用三样东西：URL、地址和线路。

URLs

这部分不明白的太多，先放在这里。
[connections]{http://lzyblog.com/2014/12/23/Square%E5%BC%80%E6%BA%90%E5%BA%93OKHttp%E7%9A%84%E5%88%86%E6%9E%90%E5%92%8C%E4%BD%BF%E7%94%A8%EF%BC%88%E4%B8%89%EF%BC%89/}

done.

chenzhao@hustunique.com