springboot使用RestTemplate调用第三方接口

╰+攻爆jí腚メ 2023-01-10 10:20 210阅读 0赞

一.pom文件使用RestTemplate需要引入依赖  
<dependency>  
   <groupId>org.apache.httpcomponents</groupId>  
   <artifactId>httpclient</artifactId>  
   <version>4.5.2</version>  
</dependency>  
二.实例化该类的一个实例

import org.springframework.beans.factory.annotation.Autowired;
    import org.springframework.boot.web.client.RestTemplateBuilder;
    import org.springframework.context.annotation.Bean;
    import org.springframework.context.annotation.Configuration;
    import org.springframework.http.client.HttpComponentsClientHttpRequestFactory;
    import org.springframework.web.client.RestTemplate;
    
    @Configuration
    public class RestTempleConfig {
        // 启动的时候要注意，由于我们在controller中注入了RestTemplate，所以启动的时候需要实例化该类的一个实例
        @Autowired
        private RestTemplateBuilder builder;
        // 使用RestTemplateBuilder来实例化RestTemplate对象，spring默认已经注入了RestTemplateBuilder实例
        @Bean
        public RestTemplate restTemplate() {
            return builder.build();
        }
        @Bean
        public RestTemplate customRestTemplate() {
            HttpComponentsClientHttpRequestFactory httpRequestFactory = new HttpComponentsClientHttpRequestFactory();
            httpRequestFactory.setConnectionRequestTimeout(3000);
            httpRequestFactory.setConnectTimeout(3000);
            httpRequestFactory.setReadTimeout(3000);
            return new RestTemplate(httpRequestFactory);
        }
    }

三.调用第三方http接口

import org.springframework.context.annotation.Configuration;
    import org.springframework.scheduling.annotation.EnableScheduling;
    import org.springframework.web.client.RestTemplate;
    import org.springframework.beans.factory.annotation.Autowired;
    
    @Configuration
    @EnableScheduling
    public class TestTask {
        @Autowired
        private RestTemplate restTemplate;
        public void test() {
    	   
    	    JSONObject json = new JSONObject();
    	    json.put("id", "id");
    	    //如果默认不进行处理的话这里返回的是List<LinkedHashMap<K, V>> 格式的数据并不是我们需要的;
    	    Map result = restTemplate.postForObject("http:127.0.0.1/test", json,Map.class);
        }
    }

四.调用第三方https接口

import org.springframework.context.annotation.Configuration;
    import org.springframework.scheduling.annotation.EnableScheduling;
    import org.springframework.web.client.RestTemplate;
    import org.springframework.beans.factory.annotation.Autowired;
    
    @RestController
    @RequestMapping("test")
    public class Test {
        @Autowired
        private RestTemplate restTemplate;
        public void test() {
    	   
    	   RestTemplate restTemplate = new RestTemplate(new HttpsClientRequestFactory());
           String url = "https://api.weixin.qq.com";
           ResponseEntity<String> res = restTemplate .getForEntity(url, String.class);
           JSONObject jsonObject = JSONObject.parseObject(res.getBody());
        }
    }

import org.apache.http.conn.ssl.SSLContexts;
    import org.apache.http.conn.ssl.TrustStrategy;
    import org.springframework.http.client.SimpleClientHttpRequestFactory;
    
    import javax.net.ssl.HttpsURLConnection;
    import javax.net.ssl.SSLContext;
    import java.net.HttpURLConnection;
    import java.security.KeyStore;
    import java.security.cert.CertificateException;
    import java.security.cert.X509Certificate;
    
    
    /**
     * @description:
     * @author: bgq
     * @create: 2021/3/22 17:14
     */
    public class HttpsClientRequestFactory  extends SimpleClientHttpRequestFactory {
        @Override
        protected void prepareConnection(HttpURLConnection connection, String httpMethod) {
            try {
                if (!(connection instanceof HttpsURLConnection)) {// http协议
                    // throw new RuntimeException("An instance of HttpsURLConnection is expected");
                    super.prepareConnection(connection, httpMethod);
                }
                if (connection instanceof HttpsURLConnection) {// https协议，修改协议版本
                    KeyStore trustStore = KeyStore.getInstance(KeyStore.getDefaultType());
                    // 信任任何链接
                    TrustStrategy anyTrustStrategy = new TrustStrategy() {
                        @Override
                        public boolean isTrusted(X509Certificate[] x509Certificates, String s) throws CertificateException {
                            return true;
                        }
                    };
                    SSLContext ctx = SSLContexts.custom().useTLS().loadTrustMaterial(trustStore, anyTrustStrategy).build();
                    ((HttpsURLConnection)connection).setSSLSocketFactory(ctx.getSocketFactory());
                    HttpsURLConnection httpsConnection = (HttpsURLConnection)connection;
                    super.prepareConnection(httpsConnection, httpMethod);
                }
            } catch (Exception e) {
                e.printStackTrace();
            }
        }
    
    }