摘要：調(diào)用的默認(rèn)構(gòu)造函數(shù)，對(duì)象在底層通過使用包下的實(shí)現(xiàn)創(chuàng)建請(qǐng)求，可以通過使用指定不同的請(qǐng)求方式。接口主要提供了兩種實(shí)現(xiàn)方式一種是，使用提供的方式既包提供的方式創(chuàng)建底層的請(qǐng)求連接。

自從RESTFul API興起后，Spring就給開發(fā)者提供了一個(gè)訪問Rest的客服端，RestTemplate不僅可以很方便的調(diào)用http接口，還可以調(diào)用同一注冊(cè)中心下的微服務(wù)，同時(shí)還有負(fù)載均衡和熔斷機(jī)制。當(dāng)然我也聽說OKhttp，HTTPClient之類的網(wǎng)絡(luò)框架，但是我們這里重點(diǎn)講的是RestTemplate(其中一種實(shí)現(xiàn)就是基于HTTPClient實(shí)現(xiàn)的)，因?yàn)檫@是SpringBoot自帶，而且基本使用場(chǎng)景都覆蓋了。

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可以配置連接池和證書等信息。

@Configuration
class RestTemplateConfig {

    /**
     * 構(gòu)建一個(gè)使用默認(rèn)配置RestTemplate Bean
     */
    @Bean
    fun restTemplate():RestTemplate {
        return RestTemplateBuilder().build()
    }
}

@Component
class RestTemplateClient {

    @Autowired lateinit var restTemplate: RestTemplate

    val logger:Logger = LoggerFactory.getLogger(this.javaClass)

    /**
     * 發(fā)送POST請(qǐng)求，通過Form表單提交參數(shù)
     */
    fun  postForm(params: Map, url: String, t:T) : ResultDTO? {
        logger.info("請(qǐng)求URL===========:{}", url)
        logger.info("請(qǐng)求參數(shù)===========:{}", params)
        val httpHeaders = HttpHeaders()
        httpHeaders.contentType = MediaType.APPLICATION_FORM_URLENCODED
        val requestParams = LinkedMultiValueMap()
        params.forEach(requestParams::add)
        val httpEntity = HttpEntity>(requestParams, httpHeaders)
        return restTemplate.postForObject(url, httpEntity, ResultDTO().javaClass)
    }
}

@RestController
@RequestMapping("/api")
class LotteryController {

    @Autowired lateinit var restTemplateClient: RestTemplateClient

    /**
     * 彩票類型查詢
     */
    @PostMapping("/lottery/types")
    fun lotteryTypes(@RequestBody params:Map) : ResultDTO? {
        return restTemplateClient.postForm(params, UrlEnums.DEMO1.url, LotteryDTO())
    }
}

/**
 * 發(fā)送POST請(qǐng)求，通過Form表單提交參數(shù)
 */
fun  postBody(params: Map, url: String, t:T) : ResultDTO? {
    logger.info("請(qǐng)求URL===========:{}", url)
    logger.info("請(qǐng)求參數(shù)===========:{}", params)
    val httpHeaders = HttpHeaders()
    httpHeaders.contentType = MediaType.APPLICATION_JSON_UTF8
    val httpEntity = HttpEntity(params, httpHeaders)
    return restTemplate.postForObject(url, httpEntity, ResultDTO().javaClass)
}

/**
 * 發(fā)送POST請(qǐng)求，通過Form表單提交參數(shù)
 */
fun  get(params: Map, url: String, t:T) : ResultDTO? {
    logger.info("請(qǐng)求URL===========:{}", url)
    logger.info("請(qǐng)求參數(shù)===========:{}", params)
    val builder = StringBuilder()
    params.forEach{k, v -> builder.append(k).append("=").append(v).append("&") }
    val param : String = builder.toString().substring(0, builder.length - 1)
    return restTemplate.getForObject(url.plus(param), ResultDTO().javaClass)
}

/**
 * 下載資源
 */
fun downGet(url: String, headerParams: Map) : ByteArray? {
    logger.info("資源URL==========>:{}", url)
    val httpHeaders = HttpHeaders()
    if (!CollectionUtils.isEmpty(headerParams)) {
        headerParams.forEach(httpHeaders::add)
    }
    val httpEntity = HttpEntity(LinkedMultiValueMap().putAll(httpHeaders))
    return restTemplate.exchange(url, HttpMethod.GET, httpEntity, ByteArray::class.java).body
}

我們?cè)陂_發(fā)微服務(wù)應(yīng)用的時(shí)候，有時(shí)候一個(gè)應(yīng)用可能會(huì)部署很多臺(tái)，而且還是不在不通的機(jī)器上，這個(gè)時(shí)候我們可以用Nginx做一個(gè)負(fù)載均衡，但是我們這里推薦使用的是SpringCloud提供的負(fù)載均衡，只要在Bean上面加一個(gè)注解即可@LoadBalanced,如下所示:

@Bean
@LoadBalanced
fun restTemplate():RestTemplate {
    return RestTemplateBuilder().build()
}

和調(diào)用普通的http請(qǐng)求有點(diǎn)不同的地方是，調(diào)用微服務(wù)是http://application.name/xxx,我們?cè)L問的路徑是微服務(wù)應(yīng)用名稱+業(yè)務(wù)路由，因?yàn)榉?wù)會(huì)注冊(cè)到注冊(cè)中心，注冊(cè)中心會(huì)維護(hù)這個(gè)應(yīng)用名稱，當(dāng)我們通過應(yīng)用去訪問時(shí)，就可以知道這個(gè)應(yīng)用在那臺(tái)機(jī)器上了。

基礎(chǔ)使用講完了，但是這里還存在一個(gè)問題，因?yàn)槲覀兪褂玫氖亲詈?jiǎn)單的配置，在這里我們沒有設(shè)置默認(rèn)超時(shí)時(shí)間，官方默認(rèn)的是60S,但是我們業(yè)務(wù)中通常對(duì)響應(yīng)速度是有要求，一分鐘的等待時(shí)間對(duì)于用戶來(lái)說太長(zhǎng)了，這個(gè)時(shí)候我們就需要有一個(gè)超時(shí)機(jī)制，具體的設(shè)置如下:

package io.intodream.kotlin05.config

import org.apache.http.impl.client.HttpClientBuilder
import org.springframework.beans.factory.annotation.Value
import org.springframework.boot.context.properties.ConfigurationProperties
import org.springframework.boot.web.client.RestTemplateBuilder
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.http.client.SimpleClientHttpRequestFactory
import org.springframework.http.converter.HttpMessageConverter
import org.springframework.http.converter.StringHttpMessageConverter
import org.springframework.stereotype.Component
import org.springframework.web.client.RestTemplate
import java.nio.charset.StandardCharsets

/**
 * @description
 * RestTemplate 配置
 * @author Jwenk
 * @copyright intoDream.io 筑夢(mèng)科技
 * @email xmsjgzs@163.com
 * @date 2019-04-05,22:42
 */
@Configuration
class RestTemplateConfig {

    @Value("${remote.maxTotalConnect}")
    val maxTotalConnect: Int = 0
    @Value("${remote.maxConnectPerRoute}")
    val maxConnectPerRoute: Int = 200
    @Value("${remote.connectTimeout}")
    val connectTimeout: Int = 2000
    @Value("${remote.readTimeout}")
    val readTimeout: Int = 3000

    /**
     * 創(chuàng)建HTTP客戶端工廠
     */
    private fun createFactory() : ClientHttpRequestFactory {
        if (this.maxTotalConnect <= 0) {
            val factory = SimpleClientHttpRequestFactory()
            factory.setReadTimeout(this.readTimeout)
            factory.setConnectTimeout(this.connectTimeout)
            return factory
        }
        val httpClient = HttpClientBuilder.create()
                .setMaxConnTotal(this.maxTotalConnect)
                .setMaxConnPerRoute(this.maxConnectPerRoute).build()
        val factory = HttpComponentsClientHttpRequestFactory(httpClient)
        factory.setConnectTimeout(this.connectTimeout)
        factory.setReadTimeout(this.readTimeout)
        return factory
    }

    /**
     * 構(gòu)建一個(gè)使用默認(rèn)配置RestTemplate Bean
     */
    @Bean
    fun restTemplate():RestTemplate {
        val restTemplate = RestTemplate(this.createFactory())
        val converterList : MutableList> = restTemplate.messageConverters
        var converterTarget : HttpMessageConverter<*>? = null
        /**
         * 重新設(shè)置StringHttpMessageConverter字符集為UTF-8，解決中文亂碼問題
         */
        for (item: HttpMessageConverter<*> in converterList) {
            if (StringHttpMessageConverter::class.java == item.javaClass) {
                converterTarget = item
                break
            }
        }
        if (null != converterTarget) {
            converterList.remove(converterTarget)
        }
        converterList.add(1, StringHttpMessageConverter(StandardCharsets.UTF_8))
        return restTemplate
    }
}

記得在pom.xml里面引入HttpClient的jar，不然啟動(dòng)會(huì)報(bào)錯(cuò)的

    org.apache.httpcomponents
    httpclient
    4.5.6

關(guān)于RestTemplate的一些使用及配置優(yōu)化到此就結(jié)束了，喜歡的朋友可以關(guān)注本人的博客https://www.tisnz.com，如果有不對(duì)的地方歡迎指正。