okHttp的使用

不念不忘少年蓝@ 2023-10-10 18:39 63阅读 0赞

1.导入依赖

<dependency>
        <groupId>com.squareup.okhttp3</groupId>
        <artifactId>okhttp</artifactId>
        <version>3.10.0</version>
    </dependency>

2.创建OkHttpClient 和Request 使用,提交的数据是json格式的

public class TestHttpClient {
    
        public static final MediaType JSON = MediaType.parse("application/json; charset=utf-8");
    
        public String getSync(String url) throws IOException {
    
            String json = "json";
    
            OkHttpClient client = new OkHttpClient().newBuilder()
                    .connectTimeout(10, TimeUnit.SECONDS)  //连接超时阈值
                    .writeTimeout(10, TimeUnit.SECONDS)  //写超时阈值
                    .readTimeout(10, TimeUnit.SECONDS) //读超时阈值
                    .retryOnConnectionFailure(true)  //当失败后重试
                    .addNetworkInterceptor(new CacheInterceptor()) //添加网络拦截器-设置缓存
                    .addInterceptor(new EncryptInterceptor()) //添加应用拦截器
                    .build();
    
    
            RequestBody body = RequestBody.create(JSON, json);
    
            // 2.创建一个Request对象
            Request request = new Request.Builder()
                    .post(body)
                    .url(url)
                    .build();
            // 3.创建一个Call对象并调用execute()方法
            try (Response response = client.newCall(request).execute()) {
                return response.body().string();
            }
        }
    
    }

3.设置拦截器(2中的缓存拦截器和应用拦截器)

public class EncryptInterceptor implements Interceptor {
    
        public static final Logger LOGGER = Logger.getLogger("okhttp");
    
        @Override
        public Response intercept(Chain chain) throws IOException {
            Request originRequest = chain.request();
    
            // 计算认证信息
            String authorization = this.encrypt(originRequest);
    
            // 添加请求头
            Request request = originRequest.newBuilder()
                    .addHeader("Authorization", authorization)
                    .build();
    
            String requestUrl = request.url().toString();
            LOGGER.info("发送请求"+requestUrl+"并对请求添加请求头"+authorization);
    
            Response response = chain.proceed(request);
            ResponseBody responseBody = response.peekBody(1024 * 1024);
    
    
            // 向责任链后面传递
            return chain.proceed(request);
        }
    
        private String encrypt(Request originRequest) {
    
            return "aka1387";
        }

public class CacheInterceptor implements Interceptor {
        @Override
        public Response intercept(Chain chain) throws IOException {
            Response originResponse = chain.proceed(chain.request());
    
            //设置缓存时间为60秒，并移除了pragma消息头，移除它的原因是因为pragma也是控制缓存的一个消息头属性
            return originResponse.newBuilder().removeHeader("pragma")
                    .header("Cache-Control","max-age=600").build();
        }
    }