restTemplate發(fā)送get與post請(qǐng)求并且?guī)?shù)問題

更新時(shí)間：2023年07月06日 16:43:22 作者：時(shí)空那束光

這篇文章主要介紹了restTemplate發(fā)送get與post請(qǐng)求并且?guī)?shù)問題，具有很好的參考價(jià)值，希望對(duì)大家有所幫助。如有錯(cuò)誤或未考慮完全的地方，望不吝賜教

restTemplate發(fā)送get與post請(qǐng)求并帶參數(shù)

@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請(qǐng)求

@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攜帶參數(shù)請(qǐng)求demo

get請(qǐng)求

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請(qǐng)求帶參數(shù)

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請(qǐng)求

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請(qǐng)求帶參數(shù)

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請(qǐng)求返回xml格式而不是json的問題

在華為微服務(wù)環(huán)境下，RestTemplate發(fā)送請(qǐng)求返回的格式默認(rèn)是xml格式，要想獲取json格式響應(yīng)，可以用下面的工具類

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;
    }
}