使用restTemplate访问外部接口

素颜马尾好姑娘i 2022-01-29 12:49 401阅读 0赞

package com.example.demo;
    
    import com.alibaba.fastjson.JSONObject;
    import org.junit.Test;
    import org.junit.runner.RunWith;
    import org.springframework.boot.test.context.SpringBootTest;
    import org.springframework.http.HttpEntity;
    import org.springframework.http.HttpHeaders;
    import org.springframework.http.MediaType;
    import org.springframework.test.context.junit4.SpringRunner;
    import org.springframework.web.client.RestTemplate;
    
    import javax.annotation.Resource;
    
    @RunWith(SpringRunner.class)
    @SpringBootTest
    public class DemoApplicationTests {
    
        @Resource
        private RestTemplate restTemplate;
    
        /**
         * json数据的处理，后台发起请求
         */
    
        @Test
        public void contextLoads() {
            JSONObject jsobj1 = new JSONObject();
            JSONObject jsobj2 = new JSONObject();
            jsobj2.put("deviceID", "112");
            jsobj2.put("channel", "channel");
            jsobj2.put("state", "0");
            jsobj1.put("item", jsobj2);
            jsobj1.put("requestCommand", "control");
            //发起请求方法一
            //post1(jsobj1,"http://192.168.3.4:8080/HSDC/test/authentication");
            //发起请求方式二  在spring boot框架下才可以使用！创建并注入RestTemplateConfig类
            //post2(jsobj1,"http://192.168.3.4:8080/HSDC/test/authentication");
    
        }
    
        public  String post2(JSONObject json,String path) {
            //设置请求头
            HttpHeaders headers = new HttpHeaders();
            headers.setContentType(MediaType.APPLICATION_JSON_UTF8);
            headers.add("Accept", MediaType.APPLICATION_JSON.toString());
            //请求体
            HttpEntity<String> formEntity = new HttpEntity<String>(json.toString(), headers);
            //发起请求，并且以字符串的形势返回，具体怎么请看我另外一篇博客。
            String jsonResult = restTemplate.postForObject(path, formEntity, String.class);
            return jsonResult;
        }
    
        /*public  String post1(JSONObject json,String path) {
            String result = "";
            try {
                HttpClient client = new DefaultHttpClient();
                HttpPost post = new HttpPost(url);
                post.setHeader("Content-Type", "appliction/json");
                post.addHeader("Authorization", "Basic YWRtaW46");
                StringEntity s = new StringEntity(json.toString(), "utf-8");
                s.setContentEncoding(new BasicHeader(HTTP.CONTENT_TYPE, "appliction/json"));
                post.setEntity(s);
                HttpResponse httpResponse = client.execute(post);
                InputStream in = httpResponse.getEntity().getContent();
                BufferedReader br = new BufferedReader(new InputStreamReader(in, "utf-8"));
                StringBuilder strber = new StringBuilder();
                String line = null;
                while ((line = br.readLine()) != null) {
                    strber.append(line + "\n");
    
                }
                in.close();
                result = strber.toString();
                if (httpResponse.getStatusLine().getStatusCode() != HttpStatus.SC_OK) {
                    result = "服务器异常";
                }
            } catch (Exception e) {
                System.out.println("请求异常");
                throw new RuntimeException(e);
            }
            System.out.println("result==" + result);
            return result;
        }*/
    
    
    }

package com.rf.wit_harns_service.configuration;
    
    import org.springframework.context.annotation.Bean;
    import org.springframework.context.annotation.Configuration;
    import org.springframework.http.client.ClientHttpRequestFactory;
    import org.springframework.http.client.SimpleClientHttpRequestFactory;
    import org.springframework.web.client.RestTemplate;
    
    @Configuration
    public class RestTemplateConfig {
        @Bean
           public RestTemplate restTemplate(ClientHttpRequestFactory factory) {
               return new RestTemplate(factory);
           }
        
           @Bean
           public ClientHttpRequestFactory simpleClientHttpRequestFactory() {
               SimpleClientHttpRequestFactory factory = new SimpleClientHttpRequestFactory();
               //设置请求时间
               factory.setReadTimeout(500000);//单位为ms
             //设置连接时间
               factory.setConnectTimeout(5000);//单位为ms
               return factory;
           }
    
    }

### 加入我们群 ###

如果有需要，欢迎可以加入我们的QQ群！（QQ搜索 816175200，加入我们的QQ群吧！）  
有任何问题，也可以加入我们的QQ群，欢迎交（che）流（dan）！也欢迎参观我的博客[www.aquestian.cn][]！

[www.aquestian.cn]: http://www.aquestian.cn/