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'}

OkHttpClient client = new OkHttpClient().newBuilder()                //用于模擬弱網(wǎng)的攔截器                .addNetworkInterceptor(new DoraemonWeakNetworkInterceptor())                //網(wǎng)絡(luò)請(qǐng)求監(jiān)控的攔截器 ，用于網(wǎng)絡(luò)流量監(jiān)聽等                .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:                //超時(shí)                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:                //斷網(wǎng)                throw WeakNetworkManager.get().simulateOffNetwork(chain.request().url().host());        }    }}

public interface Interceptor {  Response intercept(Chain chain) throws IOException;}

@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);  }

//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;  }

<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>

public final class CaptureInfoInterceptor implements Interceptor{    @Override public Response intercept(Chain chain) throws IOException {    //獲取request 所有信息    ...    //獲取response 所有信息    ...        //存儲(chǔ)抓包數(shù)據(jù)    CacheUtils.getInstance().saveCapture(request.url().toString(),captureEntity);    }}

new OkHttpClient.Builder()   .addInterceptor(new CaptureInfoInterceptor())   .build();

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);   }