restTemplate发送get与post请求并且带参数问题
作者:时空那束光
这篇文章主要介绍了restTemplate发送get与post请求并且带参数问题,具有很好的参考价值,希望对大家有所帮助。如有错误或未考虑完全的地方,望不吝赐教
restTemplate发送get与post请求并带参数
@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); }
RestTemplate发送get和post携带参数请求demo
get请求
public static void main(String[] args) { RestTemplate restTemplate = new RestTemplate(); String res = restTemplate.getForObject("http://localhost:8080/test",String.class); System.out.println(res); }
get请求带参数
public static void main(String[] args) { RestTemplate restTemplate = new RestTemplate(); Map<String,String> map = new HashMap<String,String>(); map.put("strs","hello"); String res = restTemplate.getForObject("http://localhost:8080/test?strs={strs}",String.class,map); System.out.println(res); }
post请求
public static void main(String[] args) { RestTemplate restTemplate = new RestTemplate(); String res = restTemplate.postForObject("http://localhost:8080/test",null,String.class); System.out.println(res); }
post请求带参数
public static void main(String[] args) { RestTemplate restTemplate = new RestTemplate(); MultiValueMap<String, String> map = new LinkedMultiValueMap<String, String>(); map.add("strs", "hello"); String result = restTemplate.postForObject("http://localhost:8080/test", map, String.class); System.out.println(result); }
post请求返回xml格式而不是json的问题
在华为微服务环境下,RestTemplate发送请求返回的格式默认是xml格式,要想获取json格式响应,可以用下面的工具类
Demo:
String json = HttpUtils.doPostFormData(url, multiValueMap);
依赖
import org.apache.http.HttpEntity; import org.apache.http.NameValuePair; import org.apache.http.client.ClientProtocolException; import org.apache.http.client.config.RequestConfig; import org.apache.http.client.entity.UrlEncodedFormEntity; import org.apache.http.client.methods.CloseableHttpResponse; import org.apache.http.client.methods.HttpPost; import org.apache.http.client.utils.URIBuilder; import org.apache.http.impl.client.CloseableHttpClient; import org.apache.http.impl.client.HttpClients; import org.apache.http.message.BasicNameValuePair; import org.apache.http.util.EntityUtils; import java.io.IOException; import java.util.*; public class HttpUtils { public static String doPostFormData(String url, HashMap<String, String> map) throws Exception { String result = ""; CloseableHttpClient client = null; CloseableHttpResponse response = null; RequestConfig defaultRequestConfig = RequestConfig.custom().setSocketTimeout(550000).setConnectTimeout(550000) .setConnectionRequestTimeout(550000).setStaleConnectionCheckEnabled(true).build(); client = HttpClients.custom().setDefaultRequestConfig(defaultRequestConfig).build(); URIBuilder uriBuilder = new URIBuilder(url); HttpPost httpPost = new HttpPost(uriBuilder.build()); httpPost.setHeader("Connection", "Keep-Alive"); httpPost.setHeader("Charset", "UTF-8"); httpPost.setHeader("Content-Type", "application/x-www-form-urlencoded"); Iterator<Map.Entry<String, String>> it = map.entrySet().iterator(); List<NameValuePair> params = new ArrayList<>(); while (it.hasNext()) { Map.Entry<String, String> entry = it.next(); NameValuePair pair = new BasicNameValuePair(entry.getKey(), entry.getValue()); params.add(pair); } httpPost.setEntity(new UrlEncodedFormEntity(params, "UTF-8")); try { response = client.execute(httpPost); if (response != null) { HttpEntity resEntity = response.getEntity(); if (resEntity != null) { result = EntityUtils.toString(resEntity, "UTF-8"); } } } catch (ClientProtocolException e) { throw new RuntimeException("创建连接失败" + e); } catch (IOException e) { throw new RuntimeException("创建连接失败" + e); } return result; } }
总结
以上为个人经验,希望能给大家一个参考,也希望大家多多支持脚本之家。