springboot集成RestTemplate及常見的用法說明
一、背景介紹
在微服務(wù)都是以HTTP接口的形式暴露自身服務(wù)的，因此在調(diào)用遠(yuǎn)程服務(wù)時(shí)就必須使用HTTP客戶端。我們可以使用JDK原生的URLConnection、Apache的Http Client、Netty的異步HTTP Client, Spring的RestTemplate。
這里介紹的是RestTemplate。RestTemplate底層用還是HttpClient，對(duì)其做了封裝，使用起來更簡單。
1、什么是RestTemplate？
RestTemplate是Spring提供的用于訪問Rest服務(wù)的客戶端，RestTemplate提供了多種便捷訪問遠(yuǎn)程Http服務(wù)的方法,能夠大大提高客戶端的編寫效率。
調(diào)用RestTemplate的默認(rèn)構(gòu)造函數(shù)，RestTemplate對(duì)象在底層通過使用java.net包下的實(shí)現(xiàn)創(chuàng)建HTTP 請(qǐng)求，可以通過使用ClientHttpRequestFactory指定不同的HTTP請(qǐng)求方式。
ClientHttpRequestFactory接口主要提供了兩種實(shí)現(xiàn)方式
1、一種是SimpleClientHttpRequestFactory，使用J2SE提供的方式（既java.net包提供的方式）創(chuàng)建底層的Http請(qǐng)求連接。
2、一種方式是使用HttpComponentsClientHttpRequestFactory方式，底層使用HttpClient訪問遠(yuǎn)程的Http服務(wù)，使用HttpClient可以配置連接池和證書等信息。
其實(shí)spring并沒有真正的去實(shí)現(xiàn)底層的http請(qǐng)求（3次握手），而是集成了別的http請(qǐng)求，spring只是在原有的各種http請(qǐng)求進(jìn)行了規(guī)范標(biāo)準(zhǔn)，讓開發(fā)者更加簡單易用，底層默認(rèn)用的是jdk的http請(qǐng)求。
2、RestTemplate的優(yōu)缺點(diǎn)
- 優(yōu)點(diǎn)：連接池、超時(shí)時(shí)間設(shè)置、支持異步、請(qǐng)求和響應(yīng)的編解碼
- 缺點(diǎn)：依賴別的spring版塊、參數(shù)傳遞不靈活
RestTemplate默認(rèn)是使用SimpleClientHttpRequestFactory，內(nèi)部是調(diào)用jdk的HttpConnection，默認(rèn)超時(shí)為-1
@Autowired RestTemplate simpleRestTemplate; @Autowired RestTemplate restTemplate;
二、配置RestTemplate
1、引入依賴
<dependency>
<groupId>org.apache.httpcomponents</groupId>
<artifactId>httpclient</artifactId>
<version>4.5.6</version>
</dependency>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-web</artifactId>
</dependency>
2、連接池配置
#最大連接數(shù) http.maxTotal: 100 #并發(fā)數(shù) http.defaultMaxPerRoute: 20 #創(chuàng)建連接的最長時(shí)間 http.connectTimeout: 1000 #從連接池中獲取到連接的最長時(shí)間 http.connectionRequestTimeout: 500 #數(shù)據(jù)傳輸?shù)淖铋L時(shí)間 http.socketTimeout: 10000 #提交請(qǐng)求前測(cè)試連接是否可用 http.staleConnectionCheckEnabled: true #可用空閑連接過期時(shí)間,重用空閑連接時(shí)會(huì)先檢查是否空閑時(shí)間超過這個(gè)時(shí)間，如果超過，釋放socket重新建立 http.validateAfterInactivity: 3000000
3、初始化連接池
package com.example.demo.config;
import org.apache.http.client.HttpClient;
import org.apache.http.client.config.RequestConfig;
import org.apache.http.config.Registry;
import org.apache.http.config.RegistryBuilder;
import org.apache.http.conn.socket.ConnectionSocketFactory;
import org.apache.http.conn.socket.PlainConnectionSocketFactory;
import org.apache.http.conn.ssl.SSLConnectionSocketFactory;
import org.apache.http.impl.client.HttpClientBuilder;
import org.apache.http.impl.conn.PoolingHttpClientConnectionManager;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.http.client.ClientHttpRequestFactory;
import org.springframework.http.client.HttpComponentsClientHttpRequestFactory;
import org.springframework.web.client.RestTemplate;
@Configuration
public class RestTemplateConfig {
@Value("${http.maxTotal}")
private Integer maxTotal;
@Value("${http.defaultMaxPerRoute}")
private Integer defaultMaxPerRoute;
@Value("${http.connectTimeout}")
private Integer connectTimeout;
@Value("${http.connectionRequestTimeout}")
private Integer connectionRequestTimeout;
@Value("${http.socketTimeout}")
private Integer socketTimeout;
@Value("${http.staleConnectionCheckEnabled}")
private boolean staleConnectionCheckEnabled;
@Value("${http.validateAfterInactivity}")
private Integer validateAfterInactivity;
@Bean
public RestTemplate restTemplate() {
return new RestTemplate(httpRequestFactory());
}
@Bean
public ClientHttpRequestFactory httpRequestFactory() {
return new HttpComponentsClientHttpRequestFactory(httpClient());
}
@Bean
public HttpClient httpClient() {
Registry<ConnectionSocketFactory> registry = RegistryBuilder.<ConnectionSocketFactory>create()
.register("http", PlainConnectionSocketFactory.getSocketFactory())
.register("https", SSLConnectionSocketFactory.getSocketFactory())
.build();
PoolingHttpClientConnectionManager connectionManager = new PoolingHttpClientConnectionManager(registry);
connectionManager.setMaxTotal(maxTotal); // 最大連接數(shù)
connectionManager.setDefaultMaxPerRoute(defaultMaxPerRoute); //單個(gè)路由最大連接數(shù)
connectionManager.setValidateAfterInactivity(validateAfterInactivity); // 最大空間時(shí)間
RequestConfig requestConfig = RequestConfig.custom()
.setSocketTimeout(socketTimeout) //服務(wù)器返回?cái)?shù)據(jù)(response)的時(shí)間，超過拋出read timeout
.setConnectTimeout(connectTimeout) //連接上服務(wù)器(握手成功)的時(shí)間，超出拋出connect timeout
.setStaleConnectionCheckEnabled(staleConnectionCheckEnabled) // 提交前檢測(cè)是否可用
.setConnectionRequestTimeout(connectionRequestTimeout)//從連接池中獲取連接的超時(shí)時(shí)間，超時(shí)間未拿到可用連接，會(huì)拋出org.apache.http.conn.ConnectionPoolTimeoutException: Timeout waiting for connection from pool
.build();
return HttpClientBuilder.create()
.setDefaultRequestConfig(requestConfig)
.setConnectionManager(connectionManager)
.build();
}
}
4、使用示例
RestTemplate是對(duì)HttpCilent的封裝，所以，依HttpCilent然可以繼續(xù)使用HttpCilent。看下兩者的區(qū)別
HttpCilent：
@RequestMapping("/testHttpClient")
@ResponseBody
public Object getUser(String msg) throws IOException {
CloseableHttpClient closeableHttpClient = HttpClients.createDefault();
HttpGet get = new HttpGet("http://192.168.1.100:8080/User/getAllUser");
CloseableHttpResponse response = closeableHttpClient.execute(get);
return EntityUtils.toString(response.getEntity(), "utf-8");
}
RestTemplate：
@RequestMapping("/testRestTemplate")
@ResponseBody
public Object testRestTemplate() throws IOException {
ResponseEntity result = restTemplate.getForEntity("http://192.168.1.100:8080/User/getAllUser",ResponseEntity.class;
return result.getBody();
}
RestTemplate更簡潔了。
三、RestTemplate常用方法
1、getForEntity
getForEntity方法的返回值是一個(gè)ResponseEntity<T>，ResponseEntity<T>是Spring對(duì)HTTP請(qǐng)求響應(yīng)的封裝，包括了幾個(gè)重要的元素，如響應(yīng)碼、contentType、contentLength、響應(yīng)消息體等。比如下面一個(gè)例子：
@RequestMapping("/sayhello")
public String sayHello() {
ResponseEntity<String> responseEntity = restTemplate.getForEntity("http://HELLO-SERVICE/sayhello?name={1}", String.class, "張三");
return responseEntity.getBody();
}
@RequestMapping("/sayhello2")
public String sayHello2() {
Map<String, String> map = new HashMap<>();
map.put("name", "李四");
ResponseEntity<String> responseEntity = restTemplate.getForEntity("http://HELLO-SERVICE/sayhello?name={name}", String.class, map);
return responseEntity.getBody();
}
2、getForObject
getForObject函數(shù)實(shí)際上是對(duì)getForEntity函數(shù)的進(jìn)一步封裝，如果你只關(guān)注返回的消息體的內(nèi)容，對(duì)其他信息都不關(guān)注，此時(shí)
可以使用getForObject，舉一個(gè)簡單的例子，如下：
@RequestMapping("/book2")
public Book book2() {
Book book = restTemplate.getForObject("http://HELLO-SERVICE/getbook1", Book.class);
return book;
}
3、postForEntity
@RequestMapping("/book3")
public Book book3() {
Book book = new Book();
book.setName("紅樓夢(mèng)");
ResponseEntity<Book> responseEntity = restTemplate.postForEntity("http://HELLO-SERVICE/getbook2", book, Book.class);
return responseEntity.getBody();
}
- 方法的第一參數(shù)表示要調(diào)用的服務(wù)的地址
- 方法的第二個(gè)參數(shù)表示上傳的參數(shù)
- 方法的第三個(gè)參數(shù)表示返回的消息體的數(shù)據(jù)類型
4、postForObject
如果你只關(guān)注，返回的消息體，可以直接使用postForObject。用法和getForObject一致。
5、postForLocation
postForLocation也是提交新資源，提交成功之后，返回新資源的URI，postForLocation的參數(shù)和前面兩種的參數(shù)基本一致，只不過該方法的返回值為Uri，這個(gè)只需要服務(wù)提供者返回一個(gè)Uri即可，該Uri表示新資源的位置。
6、PUT請(qǐng)求
在RestTemplate中，PUT請(qǐng)求可以通過put方法調(diào)用，put方法的參數(shù)和前面介紹的postForEntity方法的參數(shù)基本一致，只是put方法沒有返回值而已。舉一個(gè)簡單的例子，如下：
@RequestMapping("/put")
public void put() {
Book book = new Book();
book.setName("紅樓夢(mèng)");
restTemplate.put("http://HELLO-SERVICE/getbook3/{1}", book, 99);
}
7、DELETE請(qǐng)求
delete請(qǐng)求我們可以通過delete方法調(diào)用來實(shí)現(xiàn)，如下例子：
@RequestMapping("/delete")
public void delete() {
restTemplate.delete("http://HELLO-SERVICE/getbook4/{1}", 100);
}
以上為個(gè)人經(jīng)驗(yàn)，希望能給大家一個(gè)參考，也希望大家多多支持腳本之家。
相關(guān)文章
java中實(shí)現(xiàn)創(chuàng)建目錄與創(chuàng)建文件的操作實(shí)例
用Java創(chuàng)建文件或目錄非常簡單,下面這篇文章主要給大家介紹了關(guān)于java中實(shí)現(xiàn)創(chuàng)建目錄與創(chuàng)建文件的操作實(shí)例,文中通過實(shí)例代碼介紹的非常詳細(xì),需要的朋友可以參考下2023-01-01
優(yōu)秀的文章也不少，但是Java完整版的好像不多，我把所有的寫一遍鞏固下，同時(shí)也真誠的希望閱讀到這篇文章的小伙伴們可以自己去從頭敲一遍，不要粘貼復(fù)制！希望我的文章對(duì)你有所幫助，每天進(jìn)步一點(diǎn)點(diǎn)2021-07-07
MyBatis注解開發(fā)之實(shí)現(xiàn)自定義映射關(guān)系和關(guān)聯(lián)查詢
本文主要詳細(xì)介紹了MyBatis注解開發(fā)中，實(shí)現(xiàn)自定義映射關(guān)系和關(guān)聯(lián)查詢，文中有詳細(xì)的代碼示例，對(duì)學(xué)習(xí)MyBatis有一定的參考價(jià)值，需要的朋友可以參考閱讀2023-04-04
java開啟遠(yuǎn)程debug竟有兩種參數(shù)(最新推薦)
這篇文章主要介紹了java開啟遠(yuǎn)程debug竟有兩種參數(shù),本文結(jié)合實(shí)例代碼給大家介紹的非常詳細(xì)，對(duì)大家的學(xué)習(xí)或工作具有一定的參考借鑒價(jià)值，需要的朋友可以參考下2023-07-07
這篇文章主要為大家詳細(xì)介紹了使用aop實(shí)現(xiàn)全局異常處理，文中示例代碼介紹的非常詳細(xì)，具有一定的參考價(jià)值，感興趣的小伙伴們可以參考一下2022-07-07
這篇文章主要介紹了ActiveMQ安裝及部署教程圖解,文中通過示例代碼介紹的非常詳細(xì)，對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值,需要的朋友可以參考下2020-07-07
實(shí)例講解Java的MyBatis框架對(duì)MySQL中數(shù)據(jù)的關(guān)聯(lián)查詢
這里我們來以實(shí)例講解Java的MyBatis框架對(duì)MySQL中數(shù)據(jù)的關(guān)聯(lián)查詢,包括一對(duì)多、多對(duì)一的關(guān)聯(lián)查詢以及自身關(guān)聯(lián)映射的方法等,需要的朋友可以參考下2016-06-06
這篇文章主要為大家詳細(xì)介紹了java實(shí)現(xiàn)微信搶紅包算法，文中示例代碼介紹的非常詳細(xì)，具有一定的參考價(jià)值，感興趣的小伙伴們可以參考一下2020-09-09
這篇文章主要為大家詳細(xì)介紹了java生成圖片驗(yàn)證碼示例代碼，文中示例代碼介紹的非常詳細(xì)，具有一定的參考價(jià)值，感興趣的小伙伴們可以參考一下2016-08-08
mybatis,foreach,找不到參數(shù)報(bào)錯(cuò)問題及解決
這篇文章主要介紹了mybatis,foreach,找不到參數(shù)報(bào)錯(cuò)問題及解決,具有很好的參考價(jià)值,希望對(duì)大家有所幫助,如有錯(cuò)誤或未考慮完全的地方,望不吝賜教2024-03-03