SpringBoot 如何使用RestTemplate发送Post请求
作者:占位符号 发布时间:2022-03-03 09:35:47
标签:SpringBoot,RestTemplate,Post请求
Spring中有个RestTemplate类用来发送HTTP请求很方便,本文分享一个SpringBoot发送POST请求并接收返回数据的例子。
背景:
用户信息放在8081端口的应用上,8082端口应用通过调用api,传递参数,从8081端口应用的数据库中获取用户的信息。
1、待访问的API
我要访问的api是 localhost:8081/authority/authorize,这个api需要传递三个参数,分别是domain(域名),account(用户账号),key(用户秘钥)。先用postman测试一下,返回结果如下:
分别展示了验证成功和验证失败的例子。
2、返回对象
ResultVO类是我构造的类,将会格式化api返回的数据,实现如下:
ResultVO.java
package com.seven.site.VO;
/**
* @author: Seven.wk
* @description: 数据返回类
* @create: 2018/07/04
*/
public class ResultVO<T> {
private Integer code;
private String message;
private T data;
public ResultVO() {
}
public ResultVO(Integer code, String message) {
this.code = code;
this.message = message;
}
public ResultVO(Integer code, String message, T data) {
this.code = code;
this.message = message;
this.data = data;
}
public Integer getCode() {
return code;
}
public void setCode(Integer code) {
this.code = code;
}
public String getMessage() {
return message;
}
public void setMessage(String message) {
this.message = message;
}
public T getData() {
return data;
}
public void setData(T data) {
this.data = data;
}
}
3、将发送Post请求的部分封装如下
Utils.java
package com.seven.site.utils;
import com.seven.site.VO.ResultVO;
import org.springframework.http.*;
import org.springframework.util.MultiValueMap;
import org.springframework.web.client.RestTemplate;
/**
* @author: Seven.wk
* @description: 辅助工具类
* @create: 2018/07/04
*/
public class Utils {
/**
* 向目的URL发送post请求
* @param url 目的url
* @param params 发送的参数
* @return ResultVO
*/
public static ResultVO sendPostRequest(String url, MultiValueMap<String, String> params){
RestTemplate client = new RestTemplate();
HttpHeaders headers = new HttpHeaders();
HttpMethod method = HttpMethod.POST;
// 以表单的方式提交
headers.setContentType(MediaType.APPLICATION_FORM_URLENCODED);
//将请求头部和参数合成一个请求
HttpEntity<MultiValueMap<String, String>> requestEntity = new HttpEntity<>(params, headers);
//执行HTTP请求,将返回的结构使用ResultVO类格式化
ResponseEntity<ResultVO> response = client.exchange(url, method, requestEntity, ResultVO.class);
return response.getBody();
}
}
4、UserInfo对象
UserInfo.java
package com.seven.site.entity;
import javax.persistence.Entity;
import javax.persistence.GeneratedValue;
import javax.persistence.GenerationType;
import javax.persistence.Id;
import java.util.Date;
/**
* @author: Seven.wk
* @description: 用户信息实体
* @create: 2018/07/04
*/
@Entity
public class UserInfo {
@Id
@GeneratedValue(strategy = GenerationType.IDENTITY)
private Integer userId; //用户标识id
private String userName; //用户姓名
private String userAccount; //用户账号
private String userPassword; //用户密码
private Date createTime = new Date(System.currentTimeMillis()); //创建时间
public UserInfo() {
}
public UserInfo(Object userAccount, Object userName) {
}
public UserInfo(String userAccount, String userName) {
this.userName = userName;
this.userAccount = userAccount;
}
public UserInfo(String userAccount, String userName, String userPassword) {
this.userName = userName;
this.userAccount = userAccount;
this.userPassword = userPassword;
}
public Integer getUserId() {
return userId;
}
public void setUserId(Integer userId) {
this.userId = userId;
}
public String getUserName() {
return userName;
}
public void setUserName(String userName) {
this.userName = userName;
}
public String getUserAccount() {
return userAccount;
}
public void setUserAccount(String userAccount) {
this.userAccount = userAccount;
}
public String getUserPassword() {
return userPassword;
}
public void setUserPassword(String userPassword) {
this.userPassword = userPassword;
}
public Date getCreateTime() {
return createTime;
}
public void setCreateTime(Date createTime) {
this.createTime = createTime;
}
@Override
public String toString() {
return "UserInfo{" +
"userId=" + userId +
", userName='" + userName + '\'' +
", userAccount='" + userAccount + '\'' +
", userPassword='" + userPassword + '\'' +
", createTime=" + createTime +
'}';
}
}
5、在Service层封装将要发送的参数
并调用该方法,将返回的结果格式化成UserInfo对象,其中的异常处理部分就不详述了。
注:其中的URL地址一定要加上协议前缀(http,https等)
UserInfoServiceImpl.java
public UserInfo getUserInfoFromAuthority(String domain, String account, String key) {
String authorizeUrl = "http://localhost:8081/authority/authorize";
MultiValueMap<String, String> params = new LinkedMultiValueMap<>();
params.add("domain", domain);
params.add("account", account);
params.add("key", key);
//发送Post数据并返回数据
ResultVO resultVo = Utils.sendPostRequest(authorizeUrl, params);
if(resultVo.getCode() != 20){ //进行异常处理
switch (resultVo.getCode()){
case 17: throw new SiteException(ResultEnum.AUTHORIZE_DOMAIN_NOT_EXIST);
case 18: throw new SiteException(ResultEnum.AUTHORIZE_USER_NOT_EXIST);
case 19: throw new SiteException(ResultEnum.AUTHORIZE_USER_INFO_INCORRECT);
default: throw new SiteException(ResultEnum.SYSTEM_ERROR);
}
}
LinkedHashMap infoMap = (LinkedHashMap) resultVo.getData();
return new UserInfo((String) infoMap.get("userAccount"), (String) infoMap.get("userName"), key);
}
6、在控制器中调用service中的方法,并返回数据
IndexController.java
/**
* 获取用户信息
* @param domain 域名
* @param account 用户输入的账号
* @param password 用户输入的密码
* @return ResultVO
*/
@PostMapping("/getInfo")
@ResponseBody
public ResultVO getInfo(@RequestParam("domain") String domain,
@RequestParam("account") String account,
@RequestParam("password") String password) {
UserInfo userInfo;
try{
userInfo = userInfoService.getUserInfoFromAuthority(domain, account, password);
}catch(SiteException e){
return new ResultVO(e.getCode(), e.getMessage());
}
return new ResultVO<>(20, "登录成功", userInfo);
}
7、测试效果
我们访问该控制器的地址:localhost:8082/site/getInfo,返回结果如下:
正确返回结果,测试成功。
之后我们就可以返回的UserInfo对象做其他的业务了。
来源:https://blog.csdn.net/zai_xia/article/details/80926157
0
投稿
猜你喜欢
- 安全无处不在,趁着放假读了一下 Shiro 文档,并记录一下 Shiro 整合 Spring Boot 在数据库中根据角色控制访问权限简介A
- 第一部分 问题描述1.1 具体任务本次作业任务是轨迹压缩,给定一个GPS数据记录文件,每条记录包含经度和维度两个坐标字段,所有记录的经纬度坐
- springboot项目启动慢的问题排查springboot项目,随着时间的推移,启动耗时逐步增加,从几分钟慢慢的达到30多分钟,有点恐怖!
- 一、前言最近自己在学习Spring boot的过程中开发了一个组件 multithreadpool-spring-boot-starter,
- 本文实例讲述了Android中断线程的处理方法。分享给大家供大家参考。具体方法如下:我现在对一个用户注册的功能1.用ProgressDial
- XY个人记SparkSQL是spark的一个模块,主入口是SparkSession,将SQL查询与Spark程序无缝混合。DataFrame
- @RequestBody部分属性丢失问题描述JavaBean实现public class VerifyNewFriendApplyReq i
- 委托定义类型,类型指定特定方法签名。可将满足此签名的方法(静态或实例)分配给该类型的变量,然后(使用适当参数)直接调用该方法,或将其作为参数
- ftp/sftp概念及搭建ftp是一种文件传输协议,让客户端和服务端能够互相传递文件,图片等数据;方便快捷;sftp是ssh file tr
- 前言入职新公司到现在也有一个月了,完成了手头的工作,前几天终于有时间研究下公司旧项目的代码。在研究代码的过程中,发现项目里用到了Spring
- 目录1.问题引出2.解决办法3.另外一种自定义序列化机制(介绍Externalizable)1.问题引出在某些情况下,我们可能不想对于一个对
- 一、前言问题阐述:在某一场景下,我们的代码在 Service 实现相同,但却在 Controller 层访问时却希望不同的前缀可以访问。如下
- JVM自带的类加载器:其关系如下:其中,类加载器在加载类的时候是使用了所谓的“父委托”机制。其中,除了根类加载器以外,其他的类加载器都有且只
- 刚开始做开发学习的小伙伴可能在有一个知识上面有错误的认知,我们天天写程序是在Idea下写的,运行也是在Idea下运行的。但是实际开发完成后,
- 1.SQL注入:程序向后台数据库传递SQL时,用户提交的数据直接拼接到SQL语句中并执行,从而导入SQL注入攻击。字符型注入:黑色部分为拼接
- 拆分实现流程请看下面这张图首先我们得对线程池进行一个功能拆分Thread Pool 就是我们的线程池,t1,t2,t3代表三个线程Block
- spring data jpa @query返回map踩坑记录最近用spring data jpa,网上看的一些教程,有的说是返回的Obje
- byte:java中最小的数据类型。1字节/8位。-128(2^7)~127(2^7-1),默认值0。short:短整型,2字节/16位,取
- 每种编程语言都有自己操作内存中元素的方式,例如在 C 和 C++ 里是通过指针,而在 Java 中则是通过“引用”。在 JDK.1.2 之后
- [LeetCode] 9. Palindrome Number 验证回文数字Determine whether an integer is