Android OKHttp 可能你历来没用过的拦截器 【实用推荐】

时间  2019-12-08
标签 android okhttp 可能 历来 没用 拦截 实用推荐 栏目 Android 繁體版
原文   原文链接

前言

在平时开发中，你有没有下面这样的困扰呢？java

场景一

明明是服务端的接口数据错误，而QA（测试）第一个找到的多是客户端开发的你，为何这个页面出现错误了？android

而做为客户端开发的你，可能要拿出测试机连上电脑，打一下Log，看一下到底返回了什么数据，致使页面错误。git

或者高级一点的QA，会本身打Log或者链接抓包工具看一下服务端返回的具体数据，而后把Bug提给对应的人，而大多数公司的业务测试，都仅仅是测试业务，无论技术层的。我司的大部分QA，属于外派来的，通常也只测试业务，每次有问题，都先找客户端。github

场景二

你如今正在外面作地铁，产品或者你领导忽然给你反馈，你以前作的那块业务，忽然线上跑不起来了，不行了。你一想，这确定是服务端的问题啊，可是怎么证实呢？缓存

场景三

服务端上个线，每次都须要客户端加班配合，说有问题，能够及时帮助排查问题。cookie

推荐一个小工具

说了这么多，就是缺乏一个端上的抓包小工具，来查看服务端的数据是否有问题，今天推荐的是一个基于OKHttp的抓包工具。 部分截图以下网络

支持功能

  • 自带分类接口
  • 抓包数据以时间为纬度,默认存储到手机缓存下 /Android/Data/包名/Cache/capture/ 下
  • 支持Http/Https协议的抓包，分类请求方式/请求URL/请求Header/请求体/响应状态/响应Header/响应体
  • 支持一键复制对应的状态
  • 响应体若是是JSON，支持自动格式化
  • 抓包数据，默认缓存一天

Github地址

代码已经托管到Github 地址：github.com/DingProg/Ne…app

快速接入

 

allprojects {
	repositories {
	   maven { url 'https://jitpack.io' }
	}
}

dependencies {
    debugImplementation 'com.github.DingProg.NetworkCaptureSelf:library:v1.0.1'
    releaseImplementation 'com.github.DingProg.NetworkCaptureSelf:library_no_op:v1.0.1'	 
}
复制代码

在你的全局OkHttp中添加 Interceptormaven

new OkHttpClient.Builder()
        .addInterceptor(new CaptureInfoInterceptor())
        .build();
复制代码

原理及涉及知识详解

做为Android开发，说到OKHttp的Interceptor，确定熟悉不过了。那么你对 Interceptor 又了解多少呢？你都使用过那些OKHttp的 Interceptor呢？ide

咱们先来看一下最近滴滴很火的哆啦A梦

DoraemonKit

长下面这个样子

其中关于网络模块OK Http的监听以下

OkHttpClient client = new OkHttpClient().newBuilder()
                //用于模拟弱网的拦截器
                .addNetworkInterceptor(new DoraemonWeakNetworkInterceptor())
                //网络请求监控的拦截器 ，用于网络流量监听等
                .addInterceptor(new DoraemonInterceptor()).build();
复制代码

这里举例说一下弱网模拟

弱网模拟

看一下他的实现代码

public class DoraemonWeakNetworkInterceptor implements Interceptor {

    @Override
    public Response intercept(Chain chain) throws IOException {
        if (!WeakNetworkManager.get().isActive()) {
            Request request = chain.request();
            return chain.proceed(request);
        }
        final int type = WeakNetworkManager.get().getType();
        switch (type) {
            case WeakNetworkManager.TYPE_TIMEOUT:
                //超时
                final HttpUrl url = chain.request().url();
                throw WeakNetworkManager.get().simulateTimeOut(url.host(), url.port());
            case WeakNetworkManager.TYPE_SPEED_LIMIT:
                //限速
                return WeakNetworkManager.get().simulateSpeedLimit(chain);
            default:
                //断网
                throw WeakNetworkManager.get().simulateOffNetwork(chain.request().url().host());
        }
    }
}
复制代码

实现一个OkHttp的Intercepter，根据不一样的状态来进行延迟，例如以下的模拟超时

/** * 模拟超时 * * @param host * @param port */
    public SocketTimeoutException simulateTimeOut(String host, int port) {
        SystemClock.sleep(mTimeOutMillis);
        return new SocketTimeoutException(String.format("failed to connect to %s (port %d) after %dms", host, port, mTimeOutMillis));
    }
复制代码

根据Interceptor 能够干不少事情，那么Interceptor究竟是什么样的原理呢？

Interceptor原理

先看一下Interceptor的原型

public interface Interceptor {
  Response intercept(Chain chain) throws IOException;
}
复制代码

再看一下OkHttp源码，能够知道，咱们的请求最终都会被调用到RealCall中，并执行到以下代码

@Override protected void execute() {
    boolean signalledCallback = false;
    try {
        Response response = getResponseWithInterceptorChain();
    }
    ...
}

 Response getResponseWithInterceptorChain() throws IOException {
    // Build a full stack of interceptors.
    List<Interceptor> interceptors = new ArrayList<>();
    interceptors.addAll(client.interceptors());
    interceptors.add(retryAndFollowUpInterceptor);
    interceptors.add(new BridgeInterceptor(client.cookieJar()));
    interceptors.add(new CacheInterceptor(client.internalCache()));
    interceptors.add(new ConnectInterceptor(client));
    if (!forWebSocket) {
      interceptors.addAll(client.networkInterceptors());
    }
    interceptors.add(new CallServerInterceptor(forWebSocket));

    Interceptor.Chain chain = new RealInterceptorChain(
        interceptors, null, null, null, 0, originalRequest);
    return chain.proceed(originalRequest);
  }
复制代码

在getResponseWithInterceptorChain 添加了不少OkHttp自定义的拦截器，其中有重定向，Cache，链接请求，发起请求到服务端等。咱们来看一下最后几行 代码,RealInterceptorChain是一个Interceptor.Chain类型，并执行chain.proceed，接着看一下proceed方法

//RealInterceptorChain
 public Response proceed(Request request, StreamAllocation streamAllocation, HttpCodec httpCodec, RealConnection connection) throws IOException {
    ...
    if (index >= interceptors.size()) throw new AssertionError();
    calls++;
    // Call the next interceptor in the chain.
    RealInterceptorChain next = new RealInterceptorChain(
        interceptors, streamAllocation, httpCodec, connection, index + 1, request);
    Interceptor interceptor = interceptors.get(index);
    Response response = interceptor.intercept(next);
    ....
    return response;
  }
复制代码

重点看一下Call the next interceptor in the chain 下面几行代码，他把当前的interceptor.intercept()时，传入的是下一个interceptor的包装类，RealInterceptorChain 这样就实现了，链式递归调用了，直到最后一个response返回，才会依次返回到第一个interceptor。

能够用以下图大体描述

讲了那么多相关的知识点，咱们来回到正题，上述推荐小工具的实现步骤介绍

抓包工具实现主要步骤介绍

添加一个抓包入口

在Manifest中注册便可，以下

<activity android:name="com.ding.library.internal.ui.CaptureInfoActivity" android:configChanges="keyboardHidden|orientation|screenSize|smallestScreenSize|locale" android:launchMode="singleInstance" android:screenOrientation="portrait" android:theme="@style/AppTheme.NoActionBar" />

    <activity-alias android:label="抓包入口" android:name="CaptureInfoActivity" android:targetActivity="com.ding.library.internal.ui.CaptureInfoActivity">
        <intent-filter>
            <action android:name="android.intent.action.MAIN"/>
            <category android:name="android.intent.category.LAUNCHER"/>
        </intent-filter>
    </activity-alias>
复制代码

暴露Interceptor

public final class CaptureInfoInterceptor implements Interceptor{
    @Override public Response intercept(Chain chain) throws IOException {
    //获取request 全部信息
    ...
    //获取response 全部信息
    ...
    
    //存储抓包数据
    CacheUtils.getInstance().saveCapture(request.url().toString(),captureEntity);
    }
}
复制代码

这里其中有两种方式，添加到OkHttp的Interceptor，一种硬编码，以下

new OkHttpClient.Builder()
   .addInterceptor(new CaptureInfoInterceptor())
   .build();
复制代码

另外一种方式 采用字节码注入的形式，关于字节码注入，能够简单参考个人另外一篇Gradle学习笔记，自定义 Transform部分。

存储和读取抓包数据 效率问题

存储时，为了避免影响到主APP的网络请求效率，须要在单独的线程中执行IO操做，这里使用了单线程池

public class DiskIOThreadExecutor implements Executor {
   private final Executor mDiskIO;
   public DiskIOThreadExecutor() {
       mDiskIO = Executors.newSingleThreadExecutor();
   }
   @Override
   public void execute(@NonNull Runnable command) {
       mDiskIO.execute(command);
   }
}

复制代码

存储

public void saveCapture(final String url, final CaptureEntity value) {
       Runnable runnable = new Runnable() {
           @Override
           public void run() {
               String saveUrl = url;
               if (url.contains("?")) {
                   saveUrl = saveUrl.substring(0, saveUrl.indexOf("?"));
               }
               String key = urlMd5(saveUrl);
               sp.edit().putString(key, saveUrl).apply();
               checkOrCreateFilePath(key);
               File file = new File(captureFilePath + "/" + key + "/" + getCurrentTime() + ".txt");
               BufferedSink bufferedSink = null;
               try {
                   file.createNewFile();
                   bufferedSink = Okio.buffer(Okio.sink(file));
                   bufferedSink.writeString(JSON.toJSONString(value), StandardCharsets.UTF_8);
                   bufferedSink.flush();
               } catch (Exception e) {
                   e.printStackTrace();
               } finally {
                   if (bufferedSink != null) {
                       try {
                           bufferedSink.close();
                       } catch (IOException e) {
                           e.printStackTrace();
                       }
                   }
               }
           }
       };
       diskIOThreadExecutor.execute(runnable);
   }
复制代码

读取

读取抓包数据时，不直接读取所有的数据，只读取当前抓包的目录，数据，点击时，在去加载对应的数据

public List<String> getCapture() {
   File file = new File(captureFilePath);
   return getFileList(file);
}

public List<String> getCapture(String key) {
   File file = new File(captureFilePath + "/" + key);
   return getFileList(file);
}
复制代码

好了，关于这个小工具，就介绍那么多了，具体细节代码，能够直接查看Github代码仓库，github.com/DingProg/Ne…

总结

其实关于抓包工具，有一些成熟的方案。

  • 电脑端的有Fiddler、Charels，Wireshark等，可是不是特别方便。
  • APP能够抓其余包的工具，如NetWorkPacketCapture/抓包精灵/AndroidHttpCapture，可是都一些限制条件，要么代码没开源，广告多。要么就是只能在WIFI下，或者要么就是须要Root等，不太好定制。

本文，主要是介绍OkHttp的拦截器，并从中发现能够干不少事情。如文中有错误，还忘指正，感谢。

最后也感谢你的点赞及Github的Star NetworkCaptureSelf

相关文章
相关标签/搜索
每日一句
    每一个你不满意的现在，都有一个你没有努力的曾经。
本站公众号
   欢迎关注本站公众号,获取更多信息
联系我们 最近搜索 最新文章 沪ICP备13005482号-10 MyBatis教程 SQL 教程 MySQL教程 Java 教程 Thymeleaf 教程 Hibernate教程 Spring教程 Redis教程