restTemplate發(fā)送get與post請求并且?guī)祮栴}
更新時間:2023年07月06日 16:43:22 作者:時空那束光
這篇文章主要介紹了restTemplate發(fā)送get與post請求并且?guī)祮栴},具有很好的參考價值,希望對大家有所幫助。如有錯誤或未考慮完全的地方,望不吝賜教
restTemplate發(fā)送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();
}
}發(fā)送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發(fā)送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的問題
在華為微服務環(huán)境下,RestTemplate發(fā)送請求返回的格式默認是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("創(chuàng)建連接失敗" + e);
} catch (IOException e) {
throw new RuntimeException("創(chuàng)建連接失敗" + e);
}
return result;
}
}總結
以上為個人經驗,希望能給大家一個參考,也希望大家多多支持腳本之家。
相關文章
Hibernate環(huán)境搭建與配置方法(Hello world配置文件版)
這篇文章主要介紹了Hibernate環(huán)境搭建與配置方法,這里演示Hello world配置文件版的具體實現(xiàn)步驟與相關代碼,需要的朋友可以參考下2016-03-03
SpringBoot對接Twilio實現(xiàn)發(fā)送驗證碼和驗證短信碼
Twilio是一家提供云通信服務的公司,旨在幫助開發(fā)者和企業(yè)通過簡單的API實現(xiàn)各種通信功能,下面我們來看看如何對接Twilio實現(xiàn)發(fā)送驗證碼和驗證短信碼吧2025-03-03
Mapstruct?@Mapper?@Mapping?使用小結
這篇文章主要介紹了Mapstruct?@Mapper?@Mapping使用小結,他們用于各個對象實體間的相互轉換,例如數據庫底層實體轉為頁面對象,Model?轉為?DTO,?DTO?轉為其他中間對象,?VO?等等,相關轉換代碼為編譯時自動產生的新文件和代碼,需要的朋友可以參考下2023-09-09
Mybatis-Plus自動填充更新操作相關字段的實現(xiàn)
這篇文章主要介紹了Mybatis-Plus自動填充更新操作相關字段的實現(xiàn),文中通過示例代碼介紹的非常詳細,對大家的學習或者工作具有一定的參考學習價值,需要的朋友們下面隨著小編來一起學習學習吧2020-12-12
Springboot接入MyBatisPlus的實現(xiàn)
最近web端比較熱門的框架就是SpringBoot和Mybatis-Plus,這里簡單總結集成用法,具有一定的參考價值,感興趣的可以了解一下2023-09-09

