okhttp 3:如何使用Java/Android手动解压缩gzip/平减响应开发者社区

文章/答案/技术大牛

发布

//decompresser
public static String decompressGZIP(InputStream inputStream) throws IOException
    InputStream bodyStream = new GZIPInputStream(inputStream);
    ByteArrayOutputStream outStream = new ByteArrayOutputStream();
    byte[] buffer = new byte[4096];
    int length;
    while ((length = bodyStream.read(buffer)) > 0) 
        outStream.write(buffer, 0, length);
    return new String(outStream.toByteArray());
//run scraper
scrape(api, new Callback()
    // Something went wrong
    @Override
    public void onFailure(@NonNull Call call, @NonNull IOException e)
    @Override
    public void onResponse(@NonNull Call call, @NonNull Response response) throws IOException
        if (response.isSuccessful())
                InputStream responseBodyBytes = responseBody.byteStream();
                returnedObject = GZIPCompression.decompress(responseBodyBytes);
                if (returnedObject != null)
                    String htmlResponse = returnedObject.toString();
            catch (ProtocolException e){}
            if(response != null) response.close();
private Call scrape(Map<?, ?> api, Callback callback)
    MediaType JSON = MediaType.parse("application/json; charset=utf-8");
    String method = (String) api.get("method");
    String url = (String) api.get("url");
    Request.Builder requestBuilder = new Request.Builder().url(url);
    RequestBody requestBody;
    requestBuilder.header("User-Agent", "Mozilla/5.0 (Windows NT 10.0; Win64; x64; rv:61.0) Gecko/20100101 Firefox/61.0");
    requestBuilder.header("Accept", "text/html,application/xhtml+xml,application/xml;q=0.9,*/*;q=0.8");
    requestBuilder.header("Accept-Language", "en-US,en;q=0.5");
    requestBuilder.header("Accept-Encoding", "gzip, deflate");
    requestBuilder.header("Connection", "keep-alive");
    requestBuilder.header("Upgrade-Insecure-Requests", "1");
    requestBuilder.header("Cache-Control", "max-age=0");
    Request request = requestBuilder.build();
    Call call = client.newCall(request);
    call.enqueue(callback);
    return call;
}

OkHttpClient.Builder clientBuilder = new OkHttpClient.Builder().addInterceptor(new UnzippingInterceptor());
OkHttpClient client = clientBuilder.build();

private class UnzippingInterceptor implements Interceptor {
    @Override
    public Response intercept(Chain chain) throws IOException {
        Response response = chain.proceed(chain.request());
        return unzip(response);
// copied from okhttp3.internal.http.HttpEngine (because is private)
private Response unzip(final Response response) throws IOException {
    if (response.body() == null)
        return response;
    //check if we have gzip response
    String contentEncoding = response.headers().get("Content-Encoding");
    //this is used to decompress gzipped responses
    if (contentEncoding != null && contentEncoding.equals("gzip"))
        Long contentLength = response.body().contentLength();
        GzipSource responseBody = new GzipSource(response.body().source());
        Headers strippedHeaders = response.headers().newBuilder().build();
        return response.newBuilder().headers(strippedHeaders)
                .body(new RealResponseBody(response.body().contentType().toString(), contentLength, Okio.buffer(responseBody)))
                .build();

问 okhttp 3:如何使用Java/Android手动解压缩gzip/平减响应 EN

回答 3

Stack Overflow用户