Android调试神器stetho使用详解和改造

dependencies { 
  compile 'com.facebook.stetho:stetho:1.5.0' 
} 

importPackage(android.widget);
importPackage(android.os);
var handler = new Handler(Looper.getMainLooper());
handler.post(function() { Toast.makeText(context, "Hello from JavaScript", Toast.LENGTH_LONG).show() });

.enableDumpapp(new DumperPluginsProvider() {
 @Override
 public Iterable<DumperPlugin> get() {
  return new Stetho.DefaultDumperPluginsBuilder(context)
    .provide(new MyDumperPlugin())
    .finish();
 }
})
.enableWebKitInspector(Stetho.defaultInspectorModulesProvider(context))
.build())

      .enableDumpapp(new DumperPluginsProvider() {
        public Iterable<DumperPlugin> get() {
          return (new Stetho.DefaultDumperPluginsBuilder(StethoNetworkApplication.this)).finish();
        }
      }).enableWebKitInspector(Stetho.defaultInspectorModulesProvider(context))
.build())

public void dump(DumperContext dumpContext) throws DumpException {
    Iterator<String> args = dumpContext.getArgsAsList().iterator();
    String command = ArgsHelper.nextOptionalArg(args, "");
    if("ls".equals(command)) {
      this.doLs(dumpContext.getStdout());
    } else if("tree".equals(command)) {
      this.doTree(dumpContext.getStdout());
    } else if("download".equals(command)) {
      this.doDownload(dumpContext.getStdout(), args);
    } else {
      this.doUsage(dumpContext.getStdout());
      if(!"".equals(command)) {
        throw new DumpUsageException("Unknown command: " + command);
      }
    }
  }

Thread thread = new Thread(new Runnable() {
  @Override
  public void run() {
    String url = "http://www.zhihu.com/";
    OkHttpClient.Builder builder = new OkHttpClient.Builder()

    OkHttpClient client = builder.build();
    Request request = new Request.Builder()
        .url(url)
        .get()
        .build();
    try {
      Response response = client.newCall(request).execute();
    } catch (IOException e) {
      e.printStackTrace();
    }
  }
});
thread.start();
}

private final NetworkEventReporter mEventReporter = 
  NetworkEventReporterImpl.get();
public Response intercept(Chain chain) throws IOException {
  // 构造一个独特的eventID，一对网络事件（请求和回包）对应一个eventID
  String requestId = mEventReporter.nextRequestId();
  Request request = chain.request();
  // 准备发送请求
  RequestBodyHelper requestBodyHelper = null;
  if (mEventReporter.isEnabled()) {
   requestBodyHelper = new RequestBodyHelper(mEventReporter, requestId);
   OkHttpInspectorRequest inspectorRequest =
     new OkHttpInspectorRequest(requestId, request, requestBodyHelper);
   // 请求即将发送，构造一个OkHttpInspectorRequest，报告给Chrome，此时Network会显示一条请求，处于Pending状态
   mEventReporter.requestWillBeSent(inspectorRequest);
  }
  Response response;
  try {
   // 发送请求，获得回包
   response = chain.proceed(request);
  } catch (IOException e) {
   // 如果发生了IO Exception，则通知Chrome网络请求失败了，显示对应的错误信息
   if (mEventReporter.isEnabled()) {
    mEventReporter.httpExchangeFailed(requestId, e.toString());
   }
   throw e;
  }
  if (mEventReporter.isEnabled()) {
   if (requestBodyHelper != null && requestBodyHelper.hasBody()) {
    requestBodyHelper.reportDataSent();
   }
   Connection connection = chain.connection();
   // 回包的header已收到，构造一个OkHttpInspectorResponse,发送给Chrome用于展示
   mEventReporter.responseHeadersReceived(
     new OkHttpInspectorResponse(
       requestId,
       request,
       response,
       connection));
   // 展示回包信息
   ResponseBody body = response.body();
   MediaType contentType = null;
   InputStream responseStream = null;
   if (body != null) {
    contentType = body.contentType();
    responseStream = body.byteStream();
   }
   responseStream = mEventReporter.interpretResponseStream(
     requestId,
     contentType != null ? contentType.toString() : null,
     response.header("Content-Encoding"),
     responseStream,
     new DefaultResponseHandler(mEventReporter, requestId));
   if (responseStream != null) {
    response = response.newBuilder()
      .body(new ForwardingResponseBody(body, responseStream))
      .build();
   }
  }
  return response;
 }

PulseInspectorRequest 继承自NetworkEventReporter.InspectorRequest
  public void reportRequestSend(PulseInspectorRequest request){
    String requestId = request.id();
    // request will be sent
    RequestBodyHelper requestBodyHelper = null;
    if (mEventReporter.isEnabled()) {
      requestBodyHelper = new RequestBodyHelper(mEventReporter, requestId);
      mEventReporter.requestWillBeSent(request);
      // report request send
      if (requestBodyHelper.hasBody()) {
        requestBodyHelper.reportDataSent();
      }
    }
  }

public void reportRequestSuccess(PulseInspectorResponse response){
  mEventReporter.responseHeadersReceived(response);
  mEventReporter.responseReadFinished(response.requestId());
  String requestId = response.requestId();
  String contentType = "application/json";
  String encoding = null;
  InputStream responseStream = new ByteArrayInputStream(response.getResponseBody().getBytes());
  InputStream responseHandlingInputStream = mEventReporter.interpretResponseStream(
      requestId,
      contentType,
      encoding,
      responseStream,
      new DefaultResponseHandler(mEventReporter, requestId));
  try {
    if (responseHandlingInputStream == null) return;
    // 重点在这，这两行代码一定要加上,StethoInterceptor之所以不需要加，
    // 是因为OkHttp本身对请求采取了职责链式的处理，
    // 虽然在StethoInterceptor的intercept函数里没有进行read和close
    // 但是后续的Interceptor会进行这个操作，实际上这里，才把回包数据发送给了Chrome
    responseHandlingInputStream.read(response.getResponseBody().getBytes());
    responseHandlingInputStream.close();
  } catch (IOException e) {
    e.printStackTrace();
  }
}

public void reportRequestFail(String eventId,String errMsg){
    mEventReporter.httpExchangeFailed(eventId, errMsg);
}