Spring Boot之RestTemplate

// 挑选符合medium类型的站点进行信息查询,非此类型的不进行查询
ServiceInstance serviceInstance = loadBalancerClient.choose("phemsjava");
String url = serviceInstance.getUri() + "/api/filterSiteByMedium";
RestTemplate restTemplate = new RestTemplate();
MultiValueMap<String, String> request = new LinkedMultiValueMap<>();
request.add("sitenolist", sitenolist);
request.add("medium_type", mediumtype);
List result = restTemplate.postForObject(url, request,List.class);

// 使用get方法
//设置get请求参数
Map<String,String> params = new HashMap<>();
params.put("orgCode","900000");
params.put("waybillNo","773011197999686");
//设置请求头参数
HttpHeaders requestHeaders = new HttpHeaders();
requestHeaders.add("appId", "app_service");

HttpEntity request = new HttpEntity(requestHeaders);

ResponseEntity<String> exchange = restTemplate.exchange(url, HttpMethod.GET,request, String.class, params);
System.out.println(exchange.getBody());

// 使用post方法
String url = "http://url:port/arius/_sql";
String postBody = "select count(*) from monitor";
HttpHeaders headers = new HttpHeaders();
headers.add("User-Agent", "curl/7.58.0");
HttpEntity<String> entity = new HttpEntity<>(postBody, headers);
ResponseEntity<JSONObject> response = restTemplate.postForEntity(url, entity, JSONObject.class);
System.out.println(response.getBody().toJSONString());

// 发送自动通知
ServiceInstance serviceInstance = loadBalancerClient.choose("databases");

String url = serviceInstance.getUri() + "/wx/sendMsgTimed";
RestTemplate restTemplate = new RestTemplate();
// 拼接发送内容
JSONObject post=new JSONObject();
post.put("templateid","DrhF7FOngRmQxYXFb5MzP8CSZtDVaXWtubkI2cYL15E");
post.put("siteno",siteno);

// 请求头设置,x-www-form-urlencoded格式的数据
HttpHeaders headers = new HttpHeaders();
headers.setContentType(MediaType.APPLICATION_FORM_URLENCODED);

// 组装请求体
HttpEntity<String> request =new HttpEntity<String>(JSONObject.toJSONString(post), headers);
JSONObject sendResult = restTemplate.postForObject(url, request,JSONObject.class);

// 拼接发送内容
MultiValueMap<String, String> paramMap = new LinkedMultiValueMap<>();
paramMap.add("templateid","DrhF7FOngRmQxYXFb5MzP8CSZtDVaXWtubkI2cYL15E");
paramMap.add("siteno",String.valueOf(siteno));

String dbalias=loginUserHolder.getDbname();
paramMap.add("dbalias",dbalias);

String templateparams="";
paramMap.add("templateparams",templateparams);

// 请求头设置,x-www-form-urlencoded格式的数据
HttpHeaders headers = new HttpHeaders();
headers.setContentType(MediaType.APPLICATION_FORM_URLENCODED);

// 组装请求体
HttpEntity<MultiValueMap> request =new HttpEntity<MultiValueMap>(paramMap, headers);

JSONObject sendResult = restTemplate.postForObject(url, request,JSONObject.class);