restTemplate 发送post请求

        <!--jackson 依赖--><dependency><groupId>com.fasterxml.jackson.core</groupId><artifactId>jackson-core</artifactId></dependency><dependency><groupId>com.fasterxml.jackson.core</groupId><artifactId>jackson-annotations</artifactId></dependency><dependency><groupId>com.fasterxml.jackson.dataformat</groupId><artifactId>jackson-dataformat-xml</artifactId></dependency>

package com.atguli.common.demo;import com.alibaba.fastjson.JSONObject;
import com.fasterxml.jackson.core.JsonProcessingException;
import com.fasterxml.jackson.databind.ObjectMapper;
import lombok.extern.slf4j.Slf4j;
import org.springframework.http.*;
import org.springframework.web.client.RestTemplate;import java.util.ArrayList;/*** User: ldj* Date: 2022/3/25* Time: 1:30* Description: restTemplate*/
@Slf4j
public class RestTemplateDemo {public static void main(String[] args) throws JsonProcessingException {String url = "http://locahost:8080/test";RestTemplate restTemplate = new RestTemplate();HttpHeaders headers = new HttpHeaders();MediaType type = MediaType.parseMediaType("application/json; charset=UTF-8");headers.setContentType(type);headers.add("Accept", MediaType.APPLICATION_JSON.toString());ArrayList<Object> similarList = new ArrayList<>();similarList.add("1");similarList.add("2");similarList.add("3");JSONObject requestMap = new JSONObject();requestMap.put("name", "ldj");requestMap.put("age", "15");requestMap.put("similarList",similarList);HttpEntity<JSONObject> entity = new HttpEntity<>(requestMap, headers);ObjectMapper objectMapper = new ObjectMapper();try {String similarJSON = objectMapper.writeValueAsString(requestMap);log.info("similarJSON:{}",similarJSON);} catch (Exception e) {e.printStackTrace();}//使用JSONObject，不需要创建实体类VO来接受返参，缺点是别人不知道里面有哪些字段,即不知道有那些keyJSONObject body1 = restTemplate.postForObject(url, entity, JSONObject.class);log.info("body1:{}",objectMapper.writeValueAsString(body1));ResponseEntity<JSONObject> responseEntity = restTemplate.postForEntity(url, requestMap, JSONObject.class);JSONObject body2 = responseEntity.getBody(); //响应体HttpStatus statusCode = responseEntity.getStatusCode(); //状态码HttpHeaders headers1 = responseEntity.getHeaders();//获取到头信息}
}

package com.jt;import com.jt.model.dto.UserDTO;
import lombok.extern.slf4j.Slf4j;
import org.junit.runner.RunWith;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.test.autoconfigure.web.servlet.AutoConfigureMockMvc;
import org.springframework.boot.test.context.SpringBootTest;
import org.springframework.http.*;
import org.springframework.test.context.junit4.SpringRunner;
import org.springframework.web.client.RestClientException;
import org.springframework.web.client.RestTemplate;
import org.springframework.web.util.UriComponentsBuilder;import java.net.URI;
import java.nio.charset.StandardCharsets;
import java.util.HashMap;
import java.util.Map;
import java.util.Objects;/*** @Author: ldj* @Date: 2022/06/24/11:32* @Description:*/@Slf4j
@RunWith(SpringRunner.class)
@AutoConfigureMockMvc
@SpringBootTest
public class RestTemplateTest {@Autowiredprivate RestTemplate restTemplate;public void test() {String url = "http://localhost:8089/UserController/test";Map<String, Object> requestMap = new HashMap<>();requestMap.put("id", 145515555);requestMap.put("name", "ldj");UriComponentsBuilder uriComponentsBuilder = UriComponentsBuilder.fromHttpUrl(url);//拼接url参数 "http://localhost:8089/UserController/test?id=145515555&name=ldj"requestMap.forEach(uriComponentsBuilder::queryParam);URI uri = uriComponentsBuilder.build().encode(StandardCharsets.UTF_8).toUri();//1.请求头HttpHeaders httpHeaders = new HttpHeaders();//httpHeaders.setContentType(MediaType.valueOf(MediaType.APPLICATION_JSON_UTF8_VALUE));httpHeaders.setContentType(MediaType.parseMediaType("application/json; charset=UTF-8"));httpHeaders.add("Accept", MediaType.APPLICATION_JSON.toString());//2.请求体HttpEntity<Void> httpEntity = new HttpEntity<>(null, httpHeaders);//3.响应体ResponseEntity<UserDTO> responseEntity = null;//4.发送get请求try {responseEntity = restTemplate.exchange(uri.toString(), HttpMethod.GET, httpEntity, UserDTO.class);} catch (RestClientException e) {log.error("[RestTemplateTest-test] http request error", e);}//5.数据处理if (Objects.nonNull(responseEntity)) {UserDTO body = responseEntity.getBody();if (Objects.isNull(body)) {log.info("返回错误的响应的状态码");} else {String status = body.getStatus();if (!Objects.equals("2000", status)) {log.info("返回错误的响应的状态码");}//数据进行业务处理 略}}//===============================================================================   //4.发送post请求RequestEntity<Map<String,Object>> requestEntity = RequestEntity.post(uri).header("Accept", MediaType.APPLICATION_JSON.toString()).contentType(MediaType.APPLICATION_JSON).accept(MediaType.APPLICATION_JSON).body(new LinkedMultiValueMap<>()); //也可以是DTOtry {responseEntity = restTemplate.exchange(requestEntity,UserDTO.class);} catch (RestClientException e) {log.error("[RestTemplateTest-test] http request error", e);}}
}

后续补充：向阿里云发送post请求获取短信验证码测试

配置restTemplate

package com.atguli.common.config;import org.springframework.beans.factory.annotation.Value;
import org.springframework.cloud.client.loadbalancer.LoadBalanced;
import org.springframework.cloud.context.config.annotation.RefreshScope;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.http.client.ClientHttpRequestFactory;
import org.springframework.http.client.SimpleClientHttpRequestFactory;
import org.springframework.web.client.RestTemplate;/*** User: ldj* Date: 2022/9/1* Time: 5:00* Description: No Description*/
@RefreshScope //动态加载配置文件（可不加）
@Configuration
public class RestTemplateConfig {//连接超时时间,当配置文件没设定时间时，默认6000ms@Value("${resttemplate.parameter.connectTimeout:6000}")private Integer connectTimeout;//读取超时时间,当配置文件没设定时间时，默认6000ms@Value("${resttemplate.parameter.readTimeout:6000}")private Integer readTimeout;@Bean//@LoadBalanced //客户端对服务器的负载均衡public RestTemplate restTemplate(ClientHttpRequestFactory factory) {return new RestTemplate(factory);}@Beanpublic ClientHttpRequestFactory simpleClientHttpRequestFactory() {SimpleClientHttpRequestFactory factory = new SimpleClientHttpRequestFactory();factory.setReadTimeout(readTimeout);factory.setConnectTimeout(connectTimeout);return factory;}
}

配置Jackson序列化与反序列化规则

package com.atguli.common.config;import com.fasterxml.jackson.annotation.JsonInclude;
import com.fasterxml.jackson.core.JsonParser;
import com.fasterxml.jackson.databind.ObjectMapper;
import com.fasterxml.jackson.databind.module.SimpleModule;
import com.fasterxml.jackson.databind.ser.std.ToStringSerializer;
import org.springframework.boot.autoconfigure.condition.ConditionalOnMissingBean;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.context.annotation.Primary;
import org.springframework.http.converter.json.Jackson2ObjectMapperBuilder;/*** User: ldj* Date: 2022/7/23* Time: 20:50* Description: No Description*/@Configuration
public class JacksonConfig {@Bean@Primary@ConditionalOnMissingBean(ObjectMapper.class)public ObjectMapper objectMapper(Jackson2ObjectMapperBuilder builder){ObjectMapper objectMapper = builder.createXmlMapper(false).build();SimpleModule simpleModule = new SimpleModule();//Long -> String 解决返回前端id是Long类型精度降低，后位数变成0 配置注解 @JsonSerialize(using = ToStringSerializer.class)使用simpleModule.addSerializer(Long.class, ToStringSerializer.instance);objectMapper.registerModule(simpleModule);// Include.Include.ALWAYS 默认// Include.NON_DEFAULT 属性为默认值不序列化// Include.NON_EMPTY 属性为 空（""） 或者为 NULL 都不序列化，忽略该字段// Include.NON_NULL  属性为NULL 不序列化objectMapper.setSerializationInclusion(JsonInclude.Include.NON_EMPTY);// 允许出现单引号objectMapper.configure(JsonParser.Feature.ALLOW_SINGLE_QUOTES, true);return objectMapper;}
}

如果报错：java.lang.IllegalStateException: No instances available for dfsns.market.alicloudapi.com

at org.springframework.cloud.netflix.ribbon.RibbonLoadBalancerClient.execute

@LoadBalanced 的作用是负载均衡，使用ip地址访问，无法起到负载均衡的作用，因为每次都是调用同一个服务；注释掉配置类//@LoadBalanced


import com.aliyun.oss.OSSClient;
import com.atguli.common.config.RestTemplateConfig;
import com.fasterxml.jackson.annotation.JsonIgnoreProperties;
import com.fasterxml.jackson.annotation.JsonInclude;
import lombok.Data;
import lombok.extern.slf4j.Slf4j;
import org.junit.Test;
import org.junit.runner.RunWith;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.test.context.SpringBootTest;
import org.springframework.context.annotation.Import;
import org.springframework.http.HttpHeaders;
import org.springframework.http.MediaType;
import org.springframework.http.RequestEntity;
import org.springframework.http.ResponseEntity;
import org.springframework.test.context.junit4.SpringRunner;
import org.springframework.util.LinkedMultiValueMap;
import org.springframework.util.MultiValueMap;
import org.springframework.web.client.RestClientException;
import org.springframework.web.client.RestTemplate;
import org.springframework.web.util.UriComponentsBuilder;import java.net.URI;
import java.nio.charset.StandardCharsets;@Slf4j
@Import(value = {RestTemplateConfig.class, JacksonConfig.class})
@RunWith(SpringRunner.class)
@SpringBootTest
public class ThirdPartyApplicationTests {@Autowiredprivate RestTemplate restTemplate;@Autowiredprivate ObjectMapper objectMapper;@Testpublic void smsTest() {//4.发送post请求String url = "http://dfsns.market.alicloudapi.com/data/send_sms";String appCode = "APPCODE 65ed5499417944f1ad101a12014a80c9";UriComponentsBuilder uriComponentsBuilder = UriComponentsBuilder.fromHttpUrl(url);URI uri = uriComponentsBuilder.build().encode(StandardCharsets.UTF_8).toUri();//1.请求头HttpHeaders httpHeaders = new HttpHeaders();httpHeaders.add("Authorization", appCode);httpHeaders.setContentType(MediaType.valueOf(MediaType.APPLICATION_FORM_URLENCODED_VALUE));MultiValueMap<String, String> requestMap = new LinkedMultiValueMap<>();requestMap.add("content", "code:6666");requestMap.add("phone_number", "填写真正的手机号码");requestMap.add("template_id", "TPL_0000");RequestEntity<MultiValueMap<String, String>> requestEntity = RequestEntity.post(uri).headers(httpHeaders).body(requestMap);ResponseEntity<Response> responseEntity;try {responseEntity = restTemplate.exchange(requestEntity, Response.class);//log.info(Objects.requireNonNull(responseEntity.getBody()).toString());log.info(objectMapper.writeValueAsString(responseEntity.getBody()));} catch (RestClientException e) {log.error("[RestTemplateTest-test] http request error", e);}}@Data//局部起作用注解，JacksonConfig是全局起作用，本测试不做全局配置，使用一个注解就可以@JsonInclude(value= JsonInclude.Include.NON_NULL)public static class Response {private String status;private String request_id;private String reason;}}

restTemplate 发送post请求相关推荐

RestTemplate 发送 Https 请求调用
RestTemplate 发送 Https 请求调用个人博客:https://jacob.org.cn import org.apache.http.conn.ssl.NoopHostnameVer ...
restTemplate发送put请求
restTemplate发送put请求 1.没有返回体 2.有返回体 HttpHeaders headers = new HttpHeaders(); headers.setContentType(o ...
resttemplate发送post请求
/*** 向目的URL发送post请求* @param url 目的url* @param params 发送的参数* @return ResultVO*/public static ResultVO ...
springboot 使用restTemplate 发送https请求忽略ssl证书
最近在写接口的时候给对方回推数据,发送https请求的时候遇到这么个报错:javax.net.ssl.SSLHandshakeException: sun.security.validator.Val ...
Spring中使用RestTemplate发送Http请求
作为一个Java开发选手,平时调用外部服务都是通过PRC接口,而这次业务下游只提供Http接口,就有点捉急... RestTemplate的基本使用 RestTemplate是spring实现的,基于 ...
RestTemplate 发送 get 请求使用误区多值为null
http://blog.csdn.net/zhousenshan/article/details/71055687 ****************************************** ...
RestTemplate发送form-data请求上传rul资源文件及对象参数
需求上传文件服务中的文件到其他平台接口描述:用于上传工程日志相关资料请求url:/cq-szh-projectdocumentscomputesvc/api/service/addEnginee ...
使用Fiddler监控使用RestTemplate发送网络请求的Java应用
原始Java代码: public static void getUserInfo() {String responseStr = null;RestTemplate template = new Re ...
【RestTemplate发送post、get请求】
RestTemplate发送post.get请求使用RestTemplate发送post请求 private String restTemplateByPost(String apiUrl, Map ...

restTemplate 发送post请求

at org.springframework.cloud.netflix.ribbon.RibbonLoadBalancerClient.execute

restTemplate 发送post请求相关推荐

最新文章

热门文章