java

关注公众号 jb51net

关闭
首页 > 软件编程 > java > restTemplate发送get与post请求并带参数

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

总结

以上为个人经验,希望能给大家一个参考,也希望大家多多支持脚本之家。

您可能感兴趣的文章:
阅读全文