美文网首页linux运维
RestTemplate + okhttp3 简单使用

RestTemplate + okhttp3 简单使用

作者: 毛嘟嘟 | 来源:发表于2020-09-26 20:21 被阅读0次

    RestTemplate:
    是 Spring 提供的用于访问Rest服务的客户端, RestTemplate 提供了多种便捷访问远程Http服务的方法,能够大大提高客户端的编写效率。
    –注意RestTemplate只有初始化配置(也可以不配,有默认的),没有什么连接池
    okhttp3:官方文档
    OkHttp是一个高效的HTTP客户端:

    •   HTTP / 2支持允许对同一主机的所有请求共享一个套接字。
    •   连接池可减少请求延迟(如果HTTP / 2不可用)。
    •  透明的GZIP缩小了下载大小。
    •  响应缓存可以完全避免网络重复请求。

      当网络出现问题时,OkHttp会坚持不懈:它将从常见的连接问题中静默恢复。如果您的服务具有多个IP地址,则在第一次连接失败时,OkHttp将尝试使用备用地址。这对于IPv4 + IPv6和冗余数据中心中托管的服务是必需的。OkHttp支持现代TLS功能(TLS 1.3,ALPN,证书固定)。可以将其配置为回退以获得广泛的连接性。
      使用OkHttp很容易。它的请求/响应API具有流畅的构建器和不变性。它支持同步阻塞调用和带有回调的异步调用。

    1.添加pom依赖

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

    2.application.properties设置相关配置参数

    ok.http.connect-timeout=1
    ok.http.read-timeout=3
    ok.http.write-timeout=3
    # 连接池中整体的空闲连接的最大数量
    ok.http.max-idle-connections=200
    # 连接空闲时间最多为 300 秒
    ok.http.keep-alive-duration=300
    

    2.RestTemplateConfig配置类

    import okhttp3.ConnectionPool;
    import okhttp3.OkHttpClient;
    import org.springframework.beans.factory.annotation.Value;
    import org.springframework.context.annotation.Bean;
    import org.springframework.context.annotation.Configuration;
    import org.springframework.http.client.ClientHttpRequestFactory;
    import org.springframework.http.client.OkHttp3ClientHttpRequestFactory;
    import org.springframework.web.client.RestTemplate;
    
    import java.util.concurrent.TimeUnit;
    
    @Configuration
    public class RestTemplateConfig {
    
        @Value("${ok.http.connect-timeout}")
        private Integer connectTimeout;
    
        @Value("${ok.http.read-timeout}")
        private Integer readTimeout;
    
        @Value("${ok.http.write-timeout}")
        private Integer writeTimeout;
    
        @Value("${ok.http.max-idle-connections}")
        private Integer maxIdleConnections;
    
        @Value("${ok.http.keep-alive-duration}")
        private Long keepAliveDuration;
    
    
        /**
         * 声明 RestTemplate
         */
        @Bean
        public RestTemplate httpRestTemplate() {
            ClientHttpRequestFactory factory = httpRequestFactory();
            RestTemplate restTemplate = new RestTemplate(factory);
            // 可以添加消息转换
            //restTemplate.setMessageConverters(...);
            // 可以增加拦截器
            //restTemplate.setInterceptors(...);
            return restTemplate;
        }
    
        public ClientHttpRequestFactory httpRequestFactory() {
            return new OkHttp3ClientHttpRequestFactory(okHttpConfigClient());
        }
    
        public OkHttpClient okHttpConfigClient(){
             return new OkHttpClient().newBuilder()
                     .connectionPool(pool())
                     .connectTimeout(connectTimeout, TimeUnit.SECONDS)
                     .readTimeout(readTimeout, TimeUnit.SECONDS)
                     .writeTimeout(writeTimeout, TimeUnit.SECONDS)
                     .hostnameVerifier((hostname, session) -> true)
                     // 设置代理
    //              .proxy(new Proxy(Proxy.Type.HTTP, new InetSocketAddress("127.0.0.1", 8888)))
                     // 拦截器
    //                .addInterceptor()
                     .build();
        }
    
        public ConnectionPool pool() {
            return new ConnectionPool(maxIdleConnections, keepAliveDuration, TimeUnit.SECONDS);
        }
    
    }
    

    3.测试controller

    import org.springframework.beans.factory.annotation.Autowired;
    import org.springframework.http.ResponseEntity;
    import org.springframework.web.bind.annotation.GetMapping;
    import org.springframework.web.bind.annotation.RestController;
    import org.springframework.web.client.RestTemplate;
    
    @RestController
    public class RestTemplateController {
        @Autowired
        private RestTemplate httpRestTemplate;
    
    
        @GetMapping("testRestTemplate")
        public ResponseEntity testRestTemplate(){
            ResponseEntity responseEntity = httpRestTemplate.getForEntity("http://localhost:8080/testReturn", String.class);
            System.out.println(responseEntity);
            return responseEntity;
        }
    
        @GetMapping("testReturn")
        public String testReturn() throws InterruptedException {
            Thread.sleep(1000);
            return "test";
        }
    
    }
    

    相关文章链接:

    https://www.jianshu.com/p/1f1d48fd2208

    https://blog.csdn.net/hd20086996/article/details/105282035

    https://blog.csdn.net/u010979642/article/details/89103162

    相关文章

      网友评论

        本文标题:RestTemplate + okhttp3 简单使用

        本文链接:https://www.haomeiwen.com/subject/qikhuktx.html