欢迎您访问程序员文章站本站旨在为大家提供分享程序员计算机编程知识!
您现在的位置是: 首页  >  移动技术

Android的OkHttp包中的HTTP拦截器Interceptor用法示例

程序员文章站 2024-03-05 16:09:19
okhttp(github:https://github.com/square/okhttp) 的 interceptor 就如同名称「拦截器」一样,拦截你的 reques...

okhttp(github:https://github.com/square/okhttp) 的 interceptor 就如同名称「拦截器」一样,拦截你的 request 做一些你想做的事情再送出去。例如:
1.自动加上使用者目前使用的语言送出去取得对应语言的回传内容。
2.将 request 计算出这个 request 的 sigunature 再附加上送出去。
在 okhttp 中分成 application interceptor 和 network interceptor 两种。 application interceptor 是会可以被 cache 起来的。如官网的图片: 

Android的OkHttp包中的HTTP拦截器Interceptor用法示例

拦截器是 okhttp 提供的对 http 请求和响应进行统一处理的强大机制。拦截器在实现和使用上类似于 servlet 规范中的过滤器。多个拦截器可以链接起来,形成一个链条。拦截器会按照在链条上的顺序依次执行。 拦截器在执行时,可以先对请求的 request 对象进行修改;再得到响应的 response 对象之后,可以进行修改之后再返回。
interceptor 接口只包含一个方法 intercept,其参数是 chain 对象。chain 对象表示的是当前的拦截器链条。通过 chain 的 request 方法可以获取到当前的 request 对象。在使用完 request 对象之后,通过 chain 对象的 proceed 方法来继续拦截器链条的执行。当执行完成之后,可以对得到的 response 对象进行额外的处理。
记录请求和响应信息的拦截器:

public class logginginterceptor implements interceptor {
public response intercept(chain chain) throws ioexception {
 request request = chain.request();

 long t1 = system.nanotime();
 system.out.println(string.format("发送请求: [%s] %s%n%s",
   request.url(), chain.connection(), request.headers()));

 response response = chain.proceed(request);

 long t2 = system.nanotime();
 system.out.println(string.format("接收响应: [%s] %.1fms%n%s",
   response.request().url(), (t2 - t1) / 1e6d, response.headers()));

 return response;
}
}

okhttp 中的拦截器分成应用和网络拦截器两种。应用拦截器对于每个 http 响应都只会调用一次,可以通过不调用 chain.proceed 方法来终止请求,也可以通过多次调用 chain.proceed 方法来进行重试。网络拦截器对于调用执行中的自动重定向和重试所产生的响应也会被调用,而如果响应来自缓存,则不会被调用。
添加应用和网络拦截器

client.interceptors().add(new logginginterceptor()); //添加应用拦截器
client.networkinterceptors().add(new logginginterceptor()); //添加网络拦截器

要做计算 request 的 sigunature ,则使用方式如下:

public class apiclient {
 interceptor signedrequestinterceptor = new interceptor() {
  @override
  public response intercept(chain chain) throws ioexception {
   response response = null;
   try {
    request originalrequest = chain.request();
    request signedrequest = signrequestutil.signrequest(originalrequest);
    response = chain.proceed(signedrequest);
   } catch (nosuchalgorithmexception | invalidkeyexception e) {
     e.printstacktrace();
   }

   return response;
  }
 };

 okhttpclient client = new okhttpclient();
 client.networkinterceptors().add(signedrequestinterceptor);
}
public class signrequestutil {
 public static request signrequest(request originalrequest) {
  request.builder requestbuilder = originalrequest.newbuilder();

  // 在这做所有你需要做的事情,重新产生一个 request 送出去。
  return requestbuilder
   .headers(getsignedheaders(originalrequest))
   .build();
 }
}