@Test
public void test() throws Exception{
String url = "http://localhost:8081/aa";
//headers
HttpHeaders requestHeaders = new HttpHeaders();
requestHeaders.add("api-version", "1.0");
//body
MultiValueMap<String, String> requestBody = new LinkedMultiValueMap<>();
requestBody.add("id", "1");
//HttpEntity
HttpEntity<MultiValueMap> requestEntity = new HttpEntity<MultiValueMap>(requestBody, requestHeaders);
//post
ResponseEntity<String> responseEntity = restTemplate.postForEntity(url, requestEntity, String.class);
System.out.println(responseEntity.getBody());
ResponseEntity<String> responseEntity1 = restTemplate.exchange("http://172.26.186.206:8080/hive/list/schemas?appid=admin_test",
HttpMethod.GET, requestEntity, String.class);
System.out.println(responseEntity1.getBody());
}
restTemplate的注解如下:
@Component
public class MyConfig {
@Autowired
RestTemplateBuilder builder;
@Bean
public RestTemplate restTemplate() {
return builder.build();
}
}
发送get请求
@Test public void testCheck() { String url = "http://172.26.186.206:8080/syncsql/process"; String timeStramp = String.valueOf(System.currentTimeMillis()); HttpHeaders headers = new HttpHeaders(); headers.add("appid", ""); headers.add("sign", sign(null, null,null)); headers.add("timestamp", timeStramp); JSONObject jsonObj = new JSONObject(); HttpEntity<String> formEntity = new HttpEntity<String>(null, headers); Map<String, Object> maps = new HashMap<String, Object>(); maps.put("sql", "select * from jingfen.d_user_city"); maps.put("type", 1); maps.put("account", "admin_test"); ResponseEntity<String> exchange = restTemplate.exchange(url + "?sql={sql}&type={type}&account={account}", HttpMethod.GET, formEntity, String.class, maps); String body = exchange.getBody(); LOGGER.info("{}", body); }
© 著作权归作者所有
文章评论(0)