Spring Boot 整合 RestTemplate：详解与实战

本文将深入讲解如何在 Spring Boot 应用中整合 RestTemplate，包括依赖添加、实例创建、请求发送、响应处理以及一些高级用法。通过本文的学习，将能够熟练地在 Spring Boot 应用中调用远程 RESTful 服务。

一、引言

企业使用 RESTful API 来实现前后端分离。Spring Boot 提供了便捷的方式来整合 RestTemplate，使能够轻松地调用远程 RESTful 服务。本文将详细讲解 Spring Boot 整合 RestTemplate 的方法。

二、依赖添加

在开始之前，需要确保项目中包含了 RestTemplate 的依赖。以下是使用 Maven 和 Gradle 添加依赖的示例：

Maven 示例：

    <dependencies>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-web</artifactId>
        </dependency>
    </dependencies>
1
2
3
4
5
6

Gradle 示例：

    dependencies {
        implementation 'org.springframework.boot:spring-boot-starter-web'
    }
1
2
3

三、创建 RestTemplate 实例

在 Spring Boot 应用中，可以通过以下方式创建 RestTemplate 实例：

    import org.springframework.beans.factory.annotation.Autowired;
    import org.springframework.http.HttpEntity;
    import org.springframework.http.HttpMethod;
    import org.springframework.http.ResponseEntity;
    import org.springframework.web.client.RestTemplate;
    
    public class MyService {
    
        @Autowired
        private RestTemplate restTemplate;
    
        public String callRemoteService(String url) {
            HttpEntity<String> entity = new HttpEntity<>("parameters", null);
            ResponseEntity<String> response = restTemplate.exchange(
                url,
                HttpMethod.GET,
                entity,
                String.class
            );
            return response.getBody();
        }
    }
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22

四、使用 RestTemplate 发起请求

在 callRemoteService 方法中，RestTemplate 的 exchange 方法发起 HTTP 请求。exchange 方法接收以下参数：

• HttpMethod：请求方法（GET, POST, PUT, DELETE 等）。
• HttpEntity：包含请求头和请求体的实体对象。
• Class<T>：期望的响应类型。

五、处理响应

exchange 方法返回一个 ResponseEntity 对象，它包含了响应的状态码、头信息和响应体。你可以根据需要处理这些信息：

  public class MyService {
    
        // ...
    
        public ResponseEntity<String> callRemoteServiceWithResponse(String url) {
            HttpEntity<String> entity = new HttpEntity<>("parameters", null);
            ResponseEntity<String> response = restTemplate.exchange(
                url,
                HttpMethod.GET,
                entity,
                String.class
            );
            return response;
        }
    }
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15

六、高级用法

1. 自定义 RestTemplate 实例

在某些情况下，可能需要自定义 RestTemplate 实例，例如添加拦截器、设置连接超时等。以下是一个自定义 RestTemplate 实例的示例：

    import org.springframework.http.client.HttpComponentsClientHttpRequestFactory;
    import org.springframework.web.client.RestTemplate;
    
    public RestTemplate createCustomRestTemplate() {
        HttpComponentsClientHttpRequestFactory requestFactory = new HttpComponentsClientHttpRequestFactory();
        requestFactory.setConnectTimeout(5000); // 设置连接超时时间
        requestFactory.setReadTimeout(5000); // 设置读取超时时间
    
        return new RestTemplate(requestFactory);
    }
1
2
3
4
5
6
7
8
9
10

---

2. 文件上传、下载以及常见的 HTTP 请求

2.1. 配置 RestTemplate

---

首先，需要在 Spring Boot 项目中配置 RestTemplate。在 application.properties 文件中添加以下配置：

# application.properties
spring.resttemplate.connect-timeout=5000
spring.resttemplate.read-timeout=5000
1
2
3

然后在配置类中创建一个 RestTemplate Bean：

    import org.springframework.context.annotation.Bean;
    import org.springframework.context.annotation.Configuration;
    import org.springframework.web.client.RestTemplate;
    
    @Configuration
    public class AppConfig {
    
        @Bean
        public RestTemplate restTemplate() {
            return new RestTemplate();
        }
    }
1
2
3
4
5
6
7
8
9
10
11
12

2.2. 实现文件上传

文件上传是一个常见的需求，特别是在处理用户上传的图片、文档等资源时。以下是一个使用 RestTemplate 实现文件上传的示例：

    import org.springframework.beans.factory.annotation.Autowired;
    import org.springframework.core.io.FileSystemResource;
    import org.springframework.http.HttpEntity;
    import org.springframework.http.HttpHeaders;
    import org.springframework.http.MediaType;
    import org.springframework.util.LinkedMultiValueMap;
    import org.springframework.util.MultiValueMap;
    import org.springframework.web.client.RestTemplate;
    
    public class FileService {
    
        @Autowired
        private RestTemplate restTemplate;
    
        public void uploadFile(String url, String filePath) {
            FileSystemResource file = new FileSystemResource(filePath);
            MultiValueMap<String, Object> body = new LinkedMultiValueMap<>();
            body.add("file", file);
    
            HttpHeaders headers = new HttpHeaders();
            headers.setContentType(MediaType.MULTIPART_FORM_DATA);
    
            HttpEntity<MultiValueMap<String, Object>> requestEntity = new HttpEntity<>(body, headers);
    
            restTemplate.postForObject(url, requestEntity, String.class);
        }
    }
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27

在这个示例中，首先创建了一个 FileSystemResource 对象来表示要上传的文件，然后将其添加到 MultiValueMap 中。接着，设置了请求头的 Content-Type 为 multipart/form-data，最后通过 RestTemplate 发送 POST 请求。

2.3. 实现文件下载

---

文件下载同样是一个常见的需求，特别是在提供资源给用户时。以下是一个使用 RestTemplate 实现文件下载的示例：

    import org.springframework.beans.factory.annotation.Autowired;
    import org.springframework.http.HttpEntity;
    import org.springframework.http.HttpHeaders;
    import org.springframework.http.HttpMethod;
    import org.springframework.http.ResponseEntity;
    import org.springframework.web.client.RestTemplate;
    
    import java.io.File;
    import java.util.Arrays;
    
    public class FileService {
    
        @Autowired
        private RestTemplate restTemplate;
    
        public void downloadFile(String url, String savePath) {
            HttpHeaders headers = new HttpHeaders();
            headers.setAccept(Arrays.asList(MediaType.APPLICATION_OCTET_STREAM));
    
            HttpEntity<String> requestEntity = new HttpEntity<>(headers);
    
            ResponseEntity<byte[]> response = restTemplate.exchange(url, HttpMethod.GET, requestEntity, byte[].class);
    
            if (response.getStatusCode().is2xxSuccessful()) {
                byte[] fileBytes = response.getBody();
                // 将文件字节数组保存到指定路径
                FileUtils.writeByteArrayToFile(new File(savePath), fileBytes);
            }
        }
    }
    
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31

在这个示例中，设置了请求头的 Accept 为 application/octet-stream，以接收二进制文件数据。然后通过 RestTemplate 发送 GET 请求，并将响应的文件字节数组保存到指定路径。

2.4. 实现 GET、PUT 和 DELETE 请求

---

除了文件上传和下载，还需要处理常见的 HTTP 请求，如 GET、PUT 和 DELETE。以下是这些请求的实现示例：

GET 请求

    import org.springframework.beans.factory.annotation.Autowired;
    import org.springframework.http.HttpEntity;
    import org.springframework.http.HttpHeaders;
    import org.springframework.http.HttpMethod;
    import org.springframework.http.ResponseEntity;
    import org.springframework.web.client.RestTemplate;
    
    import java.util.Arrays;
    
    public class FileService {
    
        @Autowired
        private RestTemplate restTemplate;
    
        public String getRequest(String url) {
            HttpHeaders headers = new HttpHeaders();
            headers.setAccept(Arrays.asList(MediaType.APPLICATION_JSON));
    
            HttpEntity<String> requestEntity = new HttpEntity<>(headers);
    
            ResponseEntity<String> response = restTemplate.exchange(url, HttpMethod.GET, requestEntity, String.class);
    
            if (response.getStatusCode().is2xxSuccessful()) {
                return response.getBody();
            } else {
                return null;
            }
        }
    }
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29

PUT 请求

    import org.springframework.beans.factory.annotation.Autowired;
    import org.springframework.http.HttpEntity;
    import org.springframework.http.HttpHeaders;
    import org.springframework.http.MediaType;
    import org.springframework.web.client.RestTemplate;
    
    public class FileService {
    
        @Autowired
        private RestTemplate restTemplate;
    
        public void putRequest(String url, String requestBody) {
            HttpHeaders headers = new HttpHeaders();
            headers.setContentType(MediaType.APPLICATION_JSON);
    
            HttpEntity<String> requestEntity = new HttpEntity<>(requestBody, headers);
    
            restTemplate.put(url, requestEntity);
        }
    }
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20

DELETE 请求

    import org.springframework.beans.factory.annotation.Autowired;
    import org.springframework.http.HttpEntity;
    import org.springframework.http.HttpHeaders;
    import org.springframework.web.client.RestTemplate;
    
    public class FileService {
    
        @Autowired
        private RestTemplate restTemplate;
    
        public void deleteRequest(String url) {
            HttpHeaders headers = new HttpHeaders();
    
            HttpEntity<String> requestEntity = new HttpEntity<>(headers);
    
            restTemplate.delete(url, requestEntity);
        }
    }
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18

七、总结

本文详细讲解了 Spring Boot 整合 RestTemplate 的方法，包括依赖添加、实例创建、请求发送、响应处理以及一些高级用法。