解决response.body().string()无法读取多次的问题

项目场景：

最近项目的需求是在请求接口的时候如果token失效，就重新去获取新的token，最后再用新的token去请求原先请求的接口。于是这里我们会使用到响应拦截器Interceptor，我项目使用的是 EasyHttp，是对okhttp的封装，感兴趣的可以去瞅瞅。这里需要自己去写一个响应拦截器，用来拦截服务器返回token是否失效的请求，如果返回token失效，则我们就在拦截器中同步请求新的token回来，然后将新的token填充到之前的请求，重新获取数据。

拦截器部分代码：

/**
 * 响应拦截器，用于验证token
 */
public class TokenInterceptor implements Interceptor {
    private static final String TAG = "TokenInterceptor";

    @NonNull
    @Override
    public Response intercept(Chain chain) throws IOException {
        Request request = chain.request();
        Response response = chain.proceed(request);
        try {
            //判断token过期
            if (isTokenExpired(response)) {
                //同步请求方获取最新的Token
                String newToken = getNewToken();
                //使用新的Token，使用newBuilder反向创建新的请求
                Request newRequest = chain.request()
                        .newBuilder()
                        .header(DEV_SESSION, newToken)
                        .build();
                //重新请求
                return chain.proceed(newRequest);
            }
        } catch (Exception e) {
            e.printStackTrace();
        }
        return response;
    }
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29

问题描述

但是问题来了，在拦截器中需要获取返回的Response提取数据才能判断是否token过期，我们需要使用response.body.string() 来读取数据。

   try {
      String  text = response.body.string();
    } catch (Exception e) {
        // 返回结果读取异常
        e.printStackTrace();
    }
1
2
3
4
5
6

这里读取是正常的，然后在统一解析返回Response的类中再次使用response.body.string() 的时候它会报一个异常java.lang.IllegalStateException: closed，随后在网上找了下解决方法，这该死的百度越来越烂了，找到10个都有9个都是同一篇文章内容各个平台发布搬运，开发查东西还是要用谷歌

---

原因分析：

我先是在网上查了一下原因，原来response.body.string()只可以使用一次，我在拦截器中使用过一次，再去使用的时候就会报错，根据源码分析，原来是okhttp在读取完返回的结果之后会默认启动关闭，所以第二次使用的时候，它会提示已经关闭的异常，所以我考虑在拦截器中解决这个问题，用其他的方式来代替。

---

解决方案：

话不多说了直接上解决方法代码：

 /**
     * 解析 ResponseBody
     * @param responseBody -
     * @return 解析结果
     */
    private String getResponseBody(ResponseBody responseBody) throws Exception {
        BufferedSource source = responseBody.source();
        source.request(Long.MAX_VALUE);
        Buffer buffer = source.getBuffer();

        Charset charset = StandardCharsets.UTF_8;
        MediaType contentType = responseBody.contentType();
        if (contentType != null) {
            try {
                charset = contentType.charset(StandardCharsets.UTF_8);
            } catch (UnsupportedCharsetException e) {
                DebugLog.e("将http数据写入流异常,异常原因：" + Arrays.toString(e.getStackTrace()));
            }
        }

        if (!isPlaintext(buffer)) {
            return null;
        }

        if (responseBody.contentLength() != 0) {
            assert charset != null;
            return buffer.clone().readString(charset);
        }
        return null;
    }


    private boolean isPlaintext(Buffer buffer) throws EOFException {
        try {
            Buffer prefix = new Buffer();
            long byteCount = buffer.size() < 64 ? buffer.size() : 64;
            buffer.copyTo(prefix, 0, byteCount);
            for (int i = 0; i < 16; i++) {
                if (prefix.exhausted()) {
                    break;
                }
                int codePoint = prefix.readUtf8CodePoint();
                if (Character.isISOControl(codePoint) && !Character.isWhitespace(codePoint)) {
                    return false;
                }
            }
            return true;
        } catch (EOFException e) {
            return false;
        }
    }
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51

第二种读取的方法就是获取responseBody.source()中的BufferedSource进行解析，这样就不会触发关闭，后面再次使用response.body.string()就不会有问题了。

对了，我在获取新的token的时候是使用Okhttp重新创建了一个同步请求，这里的读取是单独一个请求，所以不用考虑使用第二次的情况。

以此做个记录，遇到问题的希望对你们也有所帮助。

参考文章：http://t.zoukankan.com/duguxiaobiao-p-12092231.html