SpringBoot整合RestTemplate用法的实现

 更新时间:2023年08月20日 11:30:11   作者:黄团团  
本篇主要介绍了RestTemplate中的GET,POST,PUT,DELETE、文件上传和文件下载6大常用的功能,具有一定的参考价值,感兴趣的可以了解一下

前言:本篇主要介绍了RestTemplate中的GET,POST,PUT,DELETE、文件上传和文件下载6大常用的功能,每一个方法和每一行代码都进行了详细的讲解,代码都是亲自测试过的,整篇博客写完以后自己也是受益匪浅,于是在这做个技术分享!

一、RestTemplate简介

RestTemplate是Spring框架用来访问RESTFUL服务的客户端模板类,主要功能有:

1、发起HTTP请求,包括GET,POST,PUT,DELETE等方法。

2、自动将响应结果映射为对象,不用手动解析JSON或XML。

3、设置请求头、消息转码、Cookie等功能。

4、对不同的输入/输出类型提供对应的方法,如字符串、对象、多部分等。

5、支持远程调用,不受同源策略限制。

二、基础配置

2.1、先导入pom.xml依赖

    <dependencies>
        <!-- RestTemplate需要的依赖 -->
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-web</artifactId>
        </dependency>
        <!-- Lombok依赖 -->
        <dependency>
            <groupId>org.projectlombok</groupId>
            <artifactId>lombok</artifactId>
            <optional>true</optional>
        </dependency>
        <!-- 单元测试依赖 -->
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-test</artifactId>
            <scope>test</scope>
        </dependency>
    </dependencies>

2.2、创建RestTemplateConfig配置类

@Configuration
public class RestTemplateConfig {
    @Bean
    public RestTemplate restTemplate() {
        return new RestTemplate();
    }
}

2.3、User实体类

package com.example.resttemplate.domain;
public class User {
    public String getUsername() {
        return username;
    }
    public void setUsername(String username) {
        this.username = username;
    }
    public String getPassword() {
        return password;
    }
    public void setPassword(String password) {
        this.password = password;
    }
    public int getSex() {
        return sex;
    }
    public void setSex(int sex) {
        this.sex = sex;
    }
    public String getAddress() {
        return address;
    }
    public void setAddress(String address) {
        this.address = address;
    }
    public String getPhone() {
        return phone;
    }
    public void setPhone(String phone) {
        this.phone = phone;
    }
    public String getRemark() {
        return remark;
    }
    public void setRemark(String remark) {
        this.remark = remark;
    }
    public int getId() {
        return id;
    }
    public void setId(int id) {
        this.id = id;
    }
    private int id;
    private String username;
    private String password;
    private int sex;
    private String address;
    private String phone;
    private String remark;
}

三、对象和方法讲解

3.1、getForEntity()方法

方法简介:

执行HTTP GET请求,并将返回结果自动封装为指定的Java对象。

方法签名:

<T> ResponseEntity<T> getForEntity(String url, Class<T> responseType, Object... uriVariables)

参数含义:

url:请求的URL。

responseType:响应结果的类型。指定要封装成哪个Java对象,它可以是POJO或者任何Java类型。

uriVariables:URL中的变量,如果URL中有{id}这样的变量,这里就传入具体的值。

3.2、postForObject() 方法

方法简介:

执行HTTP POST请求,并自动将响应结果封装为指定的Java对象。

方法签名:

public <T> T postForObject(String url, Object request, Class<T> responseType, Object... uriVariables) 

参数含义:

url:请求的URL。

request:POST请求的实体,可以是任何Java对象。

responseType:响应结果的类型,指定要封装成哪个Java对象。

uriVariables:URL中的变量替换值。

3.3、exchange()方法

方法简介:

执行HTTP请求,并返回ResponseEntity对象。

方法签名:

public <T> ResponseEntity<T> exchange(URI url, 
                                      HttpMethod method, 
                                      HttpEntity<?> requestEntity,
                                      Class<T> responseType,
                                      Object... uriVariables)

参数含义: 

url:请求的URL。

method:请求的HTTP方法,如GET、POST等。

requestEntity:请求的实体,包含请求头和请求体。

responseType:响应结果的类型。

uriVariables:URL中的变量替换值。

3.4、execute()方法

方法简介:

执行HTTP请求,允许高度定制HTTP请求。

参数含义: 

url:请求的URL,可以是String或URL对象。

method:HTTP方法,如GET、POST、PUT等。

requestCallback:处理Request的Callback对象,用于定义Request,如设置请求头、查询字符串参数等等。

responseExtractor:处理Response的Callback对象,用于提取Response内容。

3.5、HttpEntity对象

对象简介:

Spring框架定义的数据结构,它表示一个完整的HTTP请求或响应。

它主要有两个作用:

1、表示HTTP请求:当表示HTTP请求时,HttpEntity有两个主要组成部分:请求头和请求体。

2、表示HTTP响应当表示HTTP响应时,有三个部分:状态码、响应头和响应体。

通过HttpEntity我们可以方便的构建和处理HTTP请求和响应。

主要参数:

headers:HttpHeaders类型,包括所有头信息。

body:请求或响应体,可以是任何对象。

statusCode:HttpStatus类型,只有在表示响应时才有效。

3.6、RequestCallback对象

RequestCallback是Spring RestTemplate中用来定制HTTP请求的一个接口,可以设置请求头、请求体、查询字符串参数。Callback接口只有一个方法:

void doWithRequest(ClientHttpRequest request) throws IOException

在该方法中可以调用ClientHttpRequest对象的方法来定制Request。

如设置请求头:

new RequestCallback() {
    public void doWithRequest(ClientHttpRequest request) {
        request.getHeaders().set("myHeader", "myValue");
    }
}

设置请求体:

new RequestCallback() {      
    public void doWithRequest(ClientHttpRequest request) {
       request.getBody() 
             .write(("some data".getBytes());
    }
}

设置查询参数:

new RequestCallback() {
    public void doWithRequest(ClientHttpRequest request) {
        MultiValueMap<String, String> map= new LinkedMultiValueMap<>();
        map.add("param1", "value1");
        request.setURI(request.getURI(), map);
    }
}

四、发送Get请求

请求层是这样写的

@RestController
@RequestMapping("/user")
public class UserController {
    @GetMapping("/getUserByUsername")
    public User getUserById(@RequestParam("username") String username,
                              @RequestParam("address") String address){
        ....//业务代码   
        return user;
    }
}

这样写也可以:

@RestController
@RequestMapping("/user")
public class UserController {
    @GetMapping("/getUserByUsername")
    public User getUserById(User user){
        ....//业务代码   
        return user;
    }
}

4.1、参数拼接 

直接把参数拼接在url上面:

    @Resource
    private RestTemplate restTemplate;
    public void sendGet(){
        String url = "http://localhost:8080/user/getUserByUsername?username=张三&&address=上海";
        ResponseEntity<String> result = restTemplate.getForEntity(url, String.class);
        System.out.println(result.getStatusCode());
        System.out.println(result.getBody());
        System.out.println(result.getHeaders());
    }

执行结果如下:

4.2、占位符传参

直接在方法中指定参数:

    @Resource
    private RestTemplate restTemplate;
    public void sendGet(){
        String url = "http://localhost:8080/user/getUserByUsername?username={name}&address={address}";
        ResponseEntity<String> result = restTemplate.getForEntity(url, String.class,"李四","广东");
        System.out.println(result.getStatusCode());
        System.out.println(result.getBody());
        System.out.println(result.getHeaders());
    }

执行结果如下:

通过Map集合传递参数,此种方式必须使用占位符,并且map中的key值,要与请求路径中的占位符一致 : 

    @Resource
    private RestTemplate restTemplate;
    public void sendGet(){
        String url = "http://localhost:8080/user/getUserByUsername?username={username}&address={address}";
        Map<String, Object> map = new HashMap<>();
        map.put("username", "李四");
        map.put("address", "广东");
        ResponseEntity<String> result = restTemplate.getForEntity(url,String.class,map);
        System.out.println(result.getStatusCode());
        System.out.println(result.getBody());
        System.out.println(result.getHeaders());
    }

执行结果如下:

4.3、请求头携带Token

定义头信息:

HttpHeaders headers = new HttpHeaders();
headers.add("token", UUID.randomUUID().toString());

创建一个HttpEntity对象,用于封装HTTP请求的头信息:

HttpEntity<Object> entity = new HttpEntity<>(headers);

使用exchange方法发送Get请求:

ResponseEntity<String> result = restTemplate.exchange(url, HttpMethod.GET,entity, String.class);

完整代码:

    @Resource
    private RestTemplate restTemplate;
    public void sendGet(){
        HttpHeaders headers = new HttpHeaders();
        headers.add("token", UUID.randomUUID().toString());
        String url = "http://localhost:8080/user/getUserByUsername?username=李四&&address=广东";
        HttpEntity<Object> entity = new HttpEntity<>(headers);
        ResponseEntity<String> result = restTemplate.exchange(url, HttpMethod.GET,entity, String.class);
        System.out.println(result.getStatusCode());
        System.out.println(result.getBody());
        System.out.println(result.getHeaders());
    }

执行结果如图: 

4.4、请求头携带Cookie

创建一个Cookie:

Cookie cookie = new Cookie("cookie", UUID.randomUUID().toString());

放入请求头当中 :

HttpHeaders headers = new HttpHeaders();
headers.add(HttpHeaders.COOKIE, cookie.toString());

完整代码:

    @Resource
    private RestTemplate restTemplate;
    public void sendGet(){
        Cookie cookie = new Cookie("cookie", UUID.randomUUID().toString());
        HttpHeaders headers = new HttpHeaders();
        headers.add(HttpHeaders.COOKIE, cookie.toString());
        String url = "http://localhost:8080/user/getUserByUsername?username=李四&&address=广东";
        HttpEntity<Object> entity = new HttpEntity<>(headers);
        ResponseEntity<String> result = restTemplate.exchange(url, HttpMethod.GET,entity, String.class);
        System.out.println(result.getStatusCode());
        System.out.println(result.getBody());
        System.out.println(result.getHeaders());
    }

执行结果如图:

五、发送Post请求   

请求层用到了@RequestBody注解接收参数,具体是这么写的:

@RestController
@RequestMapping("/user")
public class UserController {
    @PostMapping("/insert")
    public String insertUser(@RequestBody User user){
        ...//逻辑代码
        return message;
    }
}

下面进行发送Post请求测试。 

5.1、带@RequestBody

如果请求层是带有@RequestBody注解的,可以通过Json格式进行传参:

    @Resource
    private RestTemplate restTemplate;
    public void sendPost(){
        User user = new User();
        user.setId(2);
        user.setUsername("赵七");
        user.setSex(1);
        user.setPassword("123456");
        user.setAddress("江苏");
        user.setPhone("123123123");
        user.setRemark("无");
        String url = "http://localhost:8080/user/insert";
        String result = restTemplate.postForObject(url, user, String.class);
        System.out.println(result);
    }

运行结果如下:

我们也可以通过Map集合进行传参,效果是一样的:

    @Resource
    private RestTemplate restTemplate;
    public void sendPost(){
        Map<String, Object> map = new HashMap<>();
        map.put("id", 5);
        map.put("username","赵七");
        map.put("sex",1);
        map.put("password","123456");
        map.put("address","江苏");
        map.put("phone","123123123");
        map.put("remark","无");
        String url = "http://localhost:8080/user/insert";
        String result = restTemplate.postForObject(url, map, String.class);
        System.out.println(result);
    }

执行结果如下:

5.2、不带@RequestBody  

如果请求层不带这个注解,用上面的两种方法来传递参数是获取不到!

MultiValueMap常用于封装HTTP请求头或查询参数,它可以同一个key下面放多个value,我们也可以通过MultiValueMap集合来进行传递参数:

    @Resource
    private RestTemplate restTemplate;    
    public void sendPost(){
        MultiValueMap<String, Object> map = new LinkedMultiValueMap<>();
        map.add("id", 5);
        map.add("username","赵七");
        map.add("sex",1);
        map.add("password","123456");
        map.add("address","江苏");
        map.add("phone","123123123");
        map.add("remark","无");
        String url = "http://localhost:8080/user/insert";
        String result = restTemplate.postForObject(url, map, String.class);
        System.out.println(result);
    }

运行结果如下:

5.3、请求头携带Token

定义头信息:

HttpHeaders headers = new HttpHeaders();
headers.add("token", UUID.randomUUID().toString());

使用HttpEntity把请求对象user和header进行组装:

HttpEntity<User> userHttpEntity = new HttpEntity<>(user, headers);

完整代码如下:

    @Resource
    private RestTemplate restTemplate;    
    public void sendPost(){
        HttpHeaders headers = new HttpHeaders();
        headers.add("token", UUID.randomUUID().toString());
        User user = new User();
        user.setId(2);
        user.setUsername("赵七");
        user.setSex(1);
        user.setPassword("123456");
        user.setAddress("江苏");
        user.setPhone("123123123");
        user.setRemark("无");
        String url = "http://localhost:8080/user/insert";
        // 使用 HttpEntity 把请求对象user 和 header 进行组装
        HttpEntity<User> userHttpEntity = new HttpEntity<>(user, headers);
        String result = restTemplate.postForObject(url, userHttpEntity, String.class);
        System.out.println(result);
    }

运行结果如下:

六、发送Put请求

请求层是这么写的:

@RestController
@RequestMapping("/user")
public class UserController {
    @PutMapping
    public String update(@RequestBody User user){
        ...//业务代码
        return message;
    }
}

6.1、无返回值

直接调用put方式是不带返回值的:

    @Resource
    private RestTemplate restTemplate;    
    public void update(){
        String url = "http://localhost:8080/user";
        User user = new User();
        user.setId(2);
        user.setUsername("赵七");
        user.setSex(1);
        user.setPassword("123456");
        restTemplate.put(url, user);
    }

2、执行结果如下:

6.2、带返回值 

我们使用exchange方法就可以了,具体代码如下:

    @Resource
    private RestTemplate restTemplate; 
    public void update(){
        String url = "http://localhost:8080/user";
        User user = new User();
        user.setId(2);
        user.setUsername("赵七");
        user.setSex(1);
        user.setPassword("123456");
        HttpEntity<User> body = new HttpEntity<>(user);
        ResponseEntity<String> result = restTemplate.exchange(url, HttpMethod.PUT,body,String.class);
        System.out.println(result);
    }

执行结果如图:

6.3、请求头携带Token

定义头信息:

HttpHeaders headers = new HttpHeaders();
headers.add("token", UUID.randomUUID().toString());

使用HttpEntity把请求对象user和header进行组装,然后调用exchange方法即可:

HttpEntity<User> body = new HttpEntity<>(user,headers);
ResponseEntity<String> result = restTemplate.exchange(url, HttpMethod.PUT,body,String.class);

七、发送Delete请求 

请求层是这样写的:

@RestController
@RequestMapping("/user")
public class UserController {
    @DeleteMapping("{id}")
    public String delete(@PathVariable String id){
        ...//业务代码
        return message;
    }
}

7.1、无返回值

直接调用delete方式是不带返回值的:

    @Resource
    private RestTemplate restTemplate;
    public void update(){
        String url = "http://localhost:8080/user/{id}";
        restTemplate.delete(url,1);
    }

执行结果如图:

7.2、有返回值

使用exchange方法执行即可,具体代码如下:

    @Resource
    private RestTemplate restTemplate;
    public void update(){
        String url = "http://localhost:8080/user/1";
        ResponseEntity<String> result = restTemplate.exchange(url, HttpMethod.DELETE,null,String.class);
        System.out.println(result);
    }

执行结果如下:

7.3、请求头携带Token 

定义头信息

HttpHeaders headers = new HttpHeaders();
headers.add("token", UUID.randomUUID().toString());

使用HttpEntity把请求对象user和header进行组装,然后调用exchange方法即可:

HttpEntity<User> body = new HttpEntity<>(headers);
ResponseEntity<String> result = restTemplate.exchange(url, HttpMethod.DELETE,body,String.class);

八、文件上传 

请求层代码:

@RestController
@RequestMapping("/user")
public class UserController {
    @PostMapping("/upload")
    public String upload(MultipartFile file){
        return file.getOriginalFilename();
    }
}

设置请求头:

HttpHeaders headers = new HttpHeaders();
headers.add("token", UUID.randomUUID().toString());

创建一个FileSystemResource,将文件封装为resource:

File file = new File("F:/test.jar");
FileSystemResource resource = new FileSystemResource(file);

创建一个MultiValueMap,将文件添加进去,键名是"file":

MultiValueMap<String, Object> multiValueMap = new LinkedMultiValueMap<>();
multiValueMap.add("file", resource);

使用MultiValueMap和headers创建HttpEntity,表示这是个POST请求,且请求体是文件,发送POST请求到url,请求体是前面创建的HttpEntity:

HttpEntity< MultiValueMap<String, Object>> request = new HttpEntity<>(multiValueMap, headers);
ResponseEntity<String> exchange = restTemplate.exchange(url, HttpMethod.POST, request, String.class);

完整代码:

    @Resource
    private RestTemplate restTemplate;
    public void sendFile(){
        String url = "http://localhost:8080/user/upload";
        HttpHeaders headers = new HttpHeaders();
        headers.add("token", UUID.randomUUID().toString());
        File file = new File("F:/test.jar");
        FileSystemResource resource = new FileSystemResource(file);
        MultiValueMap<String, Object> multiValueMap = new LinkedMultiValueMap<>();
        multiValueMap.add("file", resource);
        HttpEntity< MultiValueMap<String, Object>> request = new HttpEntity<>(multiValueMap, headers);
        ResponseEntity<String> exchange = restTemplate.exchange(url, HttpMethod.POST, request, String.class);
        System.out.println(exchange);
    }

7、执行结果如图:

九、文件下载 

请求层具体是这么写的:

@RestController
@RequestMapping("/user")
public class UserController {
    @GetMapping("/download")
    public void download(HttpServletResponse response) throws IOException {
        File file = new File("D:\\test.jar");
        response.setContentType("application/octet-stream");
        response.setHeader("Content-Disposition", "attachment; filename=test.jar");
        InputStream in = new FileInputStream(file);
        IOUtils.copy(in, response.getOutputStream());
    }
}

定义请求头,申明可以接收所有类型的响应内容:

RequestCallback requestCallback = request -> request.getHeaders()
        .setAccept(Arrays.asList(MediaType.APPLICATION_OCTET_STREAM, MediaType.ALL));

使用流的方式读取响应内容,而不是将响应内容全部加载到内存中 :

restTemplate.execute(url, HttpMethod.GET, requestCallback, clientHttpResponse -> {
    Files.copy(clientHttpResponse.getBody(), Paths.get(targetPath));
    return null;
});

完整代码:

    @Resource
    private RestTemplate restTemplate;
    public void download() throws MalformedURLException {
        String url = "http://localhost:8080/user/download";
        String targetPath = "test.jar";
        RequestCallback requestCallback = request -> request.getHeaders()
                .setAccept(Arrays.asList(MediaType.APPLICATION_OCTET_STREAM, MediaType.ALL));
        restTemplate.execute(url, HttpMethod.GET, requestCallback, clientHttpResponse -> {
            Files.copy(clientHttpResponse.getBody(), Paths.get(targetPath));
            return null;
        });
    }

执行结果如下:

十、总结

到此这篇关于SpringBoot整合RestTemplate用法的实现的文章就介绍到这了,更多相关SpringBoot整合RestTemplate内容请搜索脚本之家以前的文章或继续浏览下面的相关文章希望大家以后多多支持脚本之家!

您可能感兴趣的文章:

相关文章

  • Springboot项目对数据库用户名密码实现加密过程解析

    Springboot项目对数据库用户名密码实现加密过程解析

    这篇文章主要介绍了Springboot项目对数据库用户名密码实现加密过程解析,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友可以参考下
    2020-06-06
  • springboot 加载 META-INF/spring.factories方式

    springboot 加载 META-INF/spring.factories方式

    这篇文章主要介绍了springboot 加载 META-INF/spring.factories方式,具有很好的参考价值,希望对大家有所帮助。如有错误或未考虑完全的地方,望不吝赐教
    2021-10-10
  • Java正则表达式的实例操作指南

    Java正则表达式的实例操作指南

    这篇文章主要给大家介绍了关于Java正则表达式的实例操作指南,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友们下面随着小编来一起学习学习吧
    2020-09-09
  • java中基本注解的知识点总结

    java中基本注解的知识点总结

    在本篇文章里小编给大家整理的是一篇关于java中基本注解的知识点总结,有需要的朋友们可以跟着学习下。
    2021-06-06
  • elasticsearch 8.2.3 安装及springboot简单使用

    elasticsearch 8.2.3 安装及springboot简单使用

    这篇文章主要介绍了elasticsearch 8.2.3 安装及springboot简单使用,本文通过示例代码给大家介绍的非常详细,对大家的学习或工作具有一定的参考借鉴价值,需要的朋友可以参考下
    2023-06-06
  • 学习Java内存模型JMM心得

    学习Java内存模型JMM心得

    这篇文章主要介绍了学习Java内存模型JMM的心得以及对其原理做了深入的介绍,有兴趣的朋友学习下吧。
    2017-12-12
  • 详解Java中的增强 for 循环 foreach

    详解Java中的增强 for 循环 foreach

    foreach 是 Java 中的一种语法糖,几乎每一种语言都有一些这样的语法糖来方便程序员进行开发,编译期间以特定的字节码或特定的方式来对这些语法进行处理。能够提高性能,并减少代码出错的几率。
    2017-05-05
  • Java调度线程池ScheduledThreadPoolExecutor不执行问题分析

    Java调度线程池ScheduledThreadPoolExecutor不执行问题分析

    最近项目上反馈某个重要的定时任务突然不执行了,很头疼,开发环境和测试环境都没有出现过这个问题。定时任务采用的是ScheduledThreadPoolExecutor,后来一看代码发现踩了一个大坑。本文就来和大家聊聊这次的踩坑记录与解决方法,需要的可以参考一下
    2023-03-03
  • 深入了解Java Object类的使用

    深入了解Java Object类的使用

    java继承中说到的Object类是java中一个特殊的类,所有的类都是直接或者间接的继承自Object类。本文就和大家详细讲讲Java Object类的使用,感兴趣的可以了解一下
    2022-07-07
  • Java以struts2为例介绍如何实现图片上传

    Java以struts2为例介绍如何实现图片上传

    这篇文章主要介绍了Java struts2中如何实现图片上传的相关资料,需要的朋友可以参考下
    2015-11-11

最新评论