OKHTTP 简单分析

　　

内部使用了OKIO库， 此库中Source表示输入流（至关于InputStream）,Sink表示输出流（至关于OutputStream）

    特色：

    ·既支持同步请求，也支持异步请求，同步请求会阻塞当前线程，异步请求不阻塞当前线程，异步执行完成后回掉相应的方法

    ·支持HTTP/2协议，经过HTTP/2 可让客户端中到服务器的全部请求共用同一个Socket链接

    ·非HTTP/2 请求时， OKHTTP内部会维护一个线程池，经过线程池能够对HTTP/1.x的链接进行复用，减小延迟

    ·透明的Gzip处理下降了通讯数据的大小

    ·请求的数据能够进行缓存

 

重要的类：

   ·Request 请求类，OKHTTP中大量使用了Builder构建器模式，Request也不例外，其内部有静态内部类Builder, 封装了请求url，请求方法method，请求头headers， 请求体RequestBody，请求标记tag

    ·Headers类， 被封装在Request或Response中，其内部使用一维数组String[] namesAndValues表示header的key value信息,能够看到除了导入包中的Util、HttpDate类以外，跟OKHTTP的关联并不大，能够将此类copy出来单独分析。在Builder内部类中有一个ArrayList<String> namesAndValues

,当咱们添加header键值对时，调用add方法，最终调用addLenient()方法将name,value的值依次添加到列表中，列表内部按照name,value,name2,value2,name3,value3...的顺序排列，在build()方法中调用toArray方法再转换为String数组，内部元素的顺序不变，这样在用get方法查找的时候

private static String get(String[] namesAndValues, String name) {
    for (int i = namesAndValues.length - 2; i >= 0; i -= 2) {
      if (name.equalsIgnoreCase(namesAndValues[i])) {
        return namesAndValues[i + 1];
      }
    }
    return null;
  }

　　

能够先查找对应的name，获得name对应的索引后，那么value是紧随name其后的，天然能够获得value的值。且在查找的时候i的值能够每隔2作一次处理。这样有些巧妙的设计，避免使用Map去存储键值对，必定程度上提升了效率。 因为在调用get方法时是倒序查找，故添加相同的字段时，取最后一个的值。若是使用set(String name, String value) 则会移除旧的name和value。须要注意的是有时候响应头含有多个重复name的header， 好比有个多 Set-Cookie,这时候能够调用 values(String name)即可以得到多个值。

    ·ResponseBody 内部使用了OKIO， 能够获得字节数组 bytes(), 字符串结果string(),或者是输入流 byteStream, 特别须要注意的是bytes() string() 方法的注释，这两个方法会将响应实体内容所有加载到内存中，因此若是响应实体比较大的话，应该考虑使用流的形式读取。其中charStream()使用响应头Content-Type指定的字符集来解析响应体。默认是UTF-8

 

Call

    同步方法execute() 会阻塞当前线程直到有响应。

    异步方法 enqueue(Callback responseCallback)

 

OKHttpClient

    内部也使用Builder构建器模式，能够配置超时时间，缓存，代理，拦截器等

 

Force a Network Response

    在某些情形下，例如点击了刷新按钮以后，有必要跳过缓存，直接向服务器获取资源，为了得到刷新后的资源能够 添加 Connection.addRequestProperty(“Cache-Control”, “no-cache”), 或者能够直接使用 connection.addRequestProperty(“Cache-Control”， “max-age=0”);

Force a Cache Response

    Connection.addRequestProperty(“Cache-Control”, “only-if-cached”);

 

请求的流程：

    ·异步请求

         建立Request ，执行client.newCall(request).enqueue(Callback)方法，跟踪newCall方法，方法内部new了一个RealCall，RealCall实现了Call接口，查看RealCall的enqueue方法，最终调用client.dispatcher().enqueue(new AsyncCall(responseCallback);其中Dispatcher内部封装了线程池(能够看到默认的线程池也是没有核心线程， 和Android-Async-http的默认线程池一致)，查看Dispatcher的enqueue方法能够看到若是正在请求的call数量小于最大请求数，则将call添加到runningAsyncCalls中，并提交call到线程池中(AsyncCall实现了Runnable的接口), 查看AsyncCall的构造方法，能够看到传入响应的回调，AsyncCall提交到线程池中后，run方法中会调用execute方法，

在AsyncCall的execute方法中经过getResponseWithInterceptorChain()方法获得Response，并进行响应的请求成功或失败的回调，而后调用finished方法移除以前添加到Queue中的call。

    

上传文件:

OkHttpClient httpClient = new OkHttpClient();

RequestBody requestBody = FormBody.create(MediaType.parse("image/jpeg"),
		new File(getExternalCacheDir()+ File.separator +"IMG_20171106_202814.jpg"));

MultipartBody multipartBody = new MultipartBody.Builder()
		.setType(MultipartBody.FORM)
		.addFormDataPart("uploadimg", "IMG_20171106_202814.jpg", requestBody)
		.build();

Request request = new Request.Builder().url("http://www.chuantu.biz/upload.php")
		.addHeader("Cache-Control", "max-age=0")
		.addHeader("Upgrade-Insecure-Requests", "1")
		.addHeader("Accept-Language","zh-CN,zh;q=0.8")
		.post(multipartBody).build();

Call call = httpClient.newCall(request);
call.enqueue(new Callback() {
	@Override
	public void onFailure(Call call, IOException e) {
	}

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

		Log.d("song", response.body().string());
	}
});

　　

Fidddler抓包的截图