如何用spring-boot集成httpClient實(shí)現(xiàn)遠(yuǎn)程調(diào)用

　如何用spring-boot集成httpClient實(shí)現(xiàn)遠(yuǎn)程調(diào)用？這篇文章運(yùn)用了實(shí)例代碼展示，代碼非常詳細(xì)，可供感興趣的小伙伴們參考借鑒，希望對(duì)大家有所幫助。

創(chuàng)新互聯(lián)堅(jiān)持“要么做到，要么別承諾”的工作理念，服務(wù)領(lǐng)域包括：成都做網(wǎng)站、成都網(wǎng)站建設(shè)、企業(yè)官網(wǎng)、英文網(wǎng)站、手機(jī)端網(wǎng)站、網(wǎng)站推廣等服務(wù)，滿足客戶于互聯(lián)網(wǎng)時(shí)代的黃埔網(wǎng)站設(shè)計(jì)、移動(dòng)媒體設(shè)計(jì)的需求，幫助企業(yè)找到有效的互聯(lián)網(wǎng)解決方案。努力成為您成熟可靠的網(wǎng)絡(luò)建設(shè)合作伙伴！

引入相關(guān)依賴：

org.apache.httpcomponents

httpclient

4.5.9

com.alibaba

fastjson

1.2.47

org.springframework.boot

spring-boot-configuration-processor

true

創(chuàng)建HttpClientUtil工具類，代碼如下：

package com.test.demo;

import com.alibaba.fastjson.JSON;

import com.test.demo.model.User;

import org.apache.http.HttpEntity;

import org.apache.http.NameValuePair;

import org.apache.http.ParseException;

import org.apache.http.client.ClientProtocolException;

import org.apache.http.client.config.RequestConfig;

import org.apache.http.client.methods.CloseableHttpResponse;

import org.apache.http.client.methods.HttpGet;

import org.apache.http.client.methods.HttpPost;

import org.apache.http.client.utils.URIBuilder;

import org.apache.http.entity.StringEntity;

import org.apache.http.impl.client.CloseableHttpClient;

import org.apache.http.impl.client.HttpClientBuilder;

import org.apache.http.util.EntityUtils;

import org.springframework.beans.factory.annotation.Autowired;

import org.springframework.stereotype.Component;

import java.io.IOException;

import java.net.URI;

import java.net.URISyntaxException;

import java.util.List;

/**

* ClassName: HttpClientTest

* Package: com.test.demo

* Description: httpClient方法封裝

* Datetime: 2020/1/13 10:45

* Author: zhoukaishun

@Component

public class HttpClientUtil {

@Autowired

private HttpClientConfigure httpClientConfigure;

/**

* @description GET封裝

* @author zhoukaishun

* @date 2020/1/13 13:12

public void doGetHttp(List params,Boolean haveParams) {

// 獲得Http客戶端

CloseableHttpClient httpClient = HttpClientBuilder.create().build();

// 參數(shù)

URI uri = null;

try {

// 設(shè)置uri信息,并將參數(shù)集合放入uri;

if(haveParams){//有參調(diào)用

uri = new URIBuilder().setScheme(httpClientConfigure.getScheme()).setHost(httpClientConfigure.getHost())

.setPort(httpClientConfigure.getPort()).setPath(httpClientConfigure.getMapPath().get("interface2"))

.setParameters(params).build();

}else{//無(wú)參調(diào)用

uri = new URIBuilder().setScheme(httpClientConfigure.getScheme()).setHost(httpClientConfigure.getHost())

.setPort(httpClientConfigure.getPort()).setPath(httpClientConfigure.getMapPath().get("interface1"))

.build();

}

} catch (URISyntaxException e1) {

e1.printStackTrace();

}

// 創(chuàng)建Get請(qǐng)求

HttpGet httpGet = new HttpGet(uri);

// 響應(yīng)模型

CloseableHttpResponse response = null;

try {

// 配置信息

RequestConfig requestConfig = RequestConfig.custom()

// 設(shè)置連接超時(shí)時(shí)間(單位毫秒)

.setConnectTimeout(5000)

// 設(shè)置請(qǐng)求超時(shí)時(shí)間(單位毫秒)

.setConnectionRequestTimeout(5000)

// socket讀寫超時(shí)時(shí)間(單位毫秒)

.setSocketTimeout(5000)

// 設(shè)置是否允許重定向(默認(rèn)為true)

.setRedirectsEnabled(true).build();

// 將上面的配置信息運(yùn)用到這個(gè)Get請(qǐng)求里

httpGet.setConfig(requestConfig);

// 由客戶端執(zhí)行(發(fā)送)Get請(qǐng)求

response = httpClient.execute(httpGet);

// 從響應(yīng)模型中獲取響應(yīng)實(shí)體

HttpEntity responseEntity = response.getEntity();

System.out.println("響應(yīng)狀態(tài)為:" + response.getStatusLine());

if (responseEntity != null) {

System.out.println("響應(yīng)內(nèi)容長(zhǎng)度為:" + responseEntity.getContentLength());

System.out.println("響應(yīng)內(nèi)容為:" + EntityUtils.toString(responseEntity));

}

} catch (ClientProtocolException e) {

e.printStackTrace();

} catch (ParseException e) {

e.printStackTrace();

} catch (IOException e) {

e.printStackTrace();

} finally {

try {

// 釋放資源

if (httpClient != null) {

httpClient.close();

}

if (response != null) {

response.close();

}

} catch (IOException e) {

e.printStackTrace();

}

/**

* @description POST封裝

* @author zhoukaishun

* @date 2020/1/13 14:01

public void doPostHttp(User user,Boolean haveParam) {

// 獲得Http客戶端

CloseableHttpClient httpClient = HttpClientBuilder.create().build();

URI uri = null;

try {

// 設(shè)置uri信息,并將參數(shù)集合放入uri;

uri = new URIBuilder().setScheme(httpClientConfigure.getScheme()).setHost(httpClientConfigure.getHost())

.setPort(httpClientConfigure.getPort())

.setPath(haveParam?httpClientConfigure.getMapPath().get("interface4"):httpClientConfigure.getMapPath().get("interface3"))

.build();

} catch (URISyntaxException e1) {

e1.printStackTrace();

}

// 創(chuàng)建Post請(qǐng)求

HttpPost httpPost = new HttpPost(uri);

if(haveParam){

//入?yún)?/p>

// 利用阿里的fastjson，將Object轉(zhuǎn)換為json字符串;

// (需要導(dǎo)入com.alibaba.fastjson.JSON包)

String jsonString = JSON.toJSONString(user);

StringEntity entity = new StringEntity(jsonString, "UTF-8");

// post請(qǐng)求是將參數(shù)放在請(qǐng)求體里面?zhèn)鬟^去的;這里將entity放入post請(qǐng)求體中

httpPost.setEntity(entity);

httpPost.setHeader("Content-Type", "application/json;charset=utf8");

}

// 響應(yīng)模型

CloseableHttpResponse response = null;

try {

// 由客戶端執(zhí)行(發(fā)送)Post請(qǐng)求

response = httpClient.execute(httpPost);

// 從響應(yīng)模型中獲取響應(yīng)實(shí)體

HttpEntity responseEntity = response.getEntity();

System.out.println("響應(yīng)狀態(tài)為:" + response.getStatusLine());

if (responseEntity != null) {

System.out.println("響應(yīng)內(nèi)容長(zhǎng)度為:" + responseEntity.getContentLength());

System.out.println("響應(yīng)內(nèi)容為:" + EntityUtils.toString(responseEntity));

}鄭州婦科醫(yī)院哪家好 https://yiyuan.120ask.com/zzfck/

} catch (ClientProtocolException e) {

e.printStackTrace();

} catch (ParseException e) {

e.printStackTrace();

} catch (IOException e) {

e.printStackTrace();

} finally {

try {

// 釋放資源

if (httpClient != null) {

httpClient.close();

}

if (response != null) {

response.close();

}

} catch (IOException e) {

e.printStackTrace();

}

其中大部分代碼基本不變，只有對(duì)url的拼接做了一些處理，可以看到我們注入了一個(gè)HttpClientConfigure實(shí)例，因?yàn)槲覀冃枰L問的路徑情況有很多種，但是我們不可能每次都去改util下的url拼接代碼，所以引入一個(gè)HttpClientConfigure，這是我自定義的一個(gè)類，用于存儲(chǔ)我們拼接url可能遇到的情況。代碼如下：

package com.test.demo;

import lombok.Data;

import org.springframework.boot.context.properties.ConfigurationProperties;

import org.springframework.stereotype.Component;

import java.util.HashMap;

import java.util.Map;

/**

* ClassName: HttpClientConfigure

* Package: com.test.demo

* Description: 接收配置信息

* Datetime: 2020/1/13 14:41

* Author: zhoukaishun

@Component

@ConfigurationProperties(prefix="httpclientconfigure")

@Data

public class HttpClientConfigure {

private Map mapPath = new HashMap<>();

private String scheme;

private String host;

private Integer port;

}

其中的@ConfigurationProperties注解前面提到過，在pom中，其中屬性值配置在yml文件中，如下(具體內(nèi)容根據(jù)自己的需求來(lái)定)：

到這里就可以開始測(cè)試了，可以在本地啟動(dòng)兩個(gè)服務(wù)(一個(gè)服務(wù)也行)，根據(jù)自己controller里面的訪問路徑配置httpclientconfigure,然后直接調(diào)用自己controller里方法即可。

以我的demo為例，調(diào)用者controller代碼如下：

@GetMapping

@RequestMapping("/doGetHaveNoParam")

public void doGetHaveNoParam(){

httpClientUtil.doGetHttp(null,false);

}

@GetMapping

@RequestMapping("/doGetHaveParam")

public void doGetHaveParam(){

System.out.println("調(diào)用有參Get請(qǐng)求，當(dāng)前時(shí)間："+System.currentTimeMillis());

List params = new ArrayList<>();

params.add(new BasicNameValuePair("name", "&"));

params.add(new BasicNameValuePair("age", "22"));

httpClientUtil.doGetHttp(params,true);

}

@PostMapping

@RequestMapping("/doPostHaveNoParam")

public void doPostHaveNoParam(){

httpClientUtil.doPostHttp(null,false);

}

@PostMapping

@RequestMapping("/doPostHaveParam")

public void doPostHaveParam(){

httpClientUtil.doPostHttp(new User("name",11),true);

}

被調(diào)用者controller代碼如下：

@RequestMapping("/doGetHaveNoParam")

public String doGetHaveNoParam(){

return "doGetHaveNoParam successful";

}

@RequestMapping("/doGetHaveParam")

public List doGetHaveParam(String name,Integer age){

return getUserByAge(name,age);

}

@PostMapping

@RequestMapping("/doPostHaveNoParam")

public String doPostHaveNoParam(){

return "doPostHaveNoParam successful";

}

@PostMapping

@RequestMapping("/doPostHaveParam")

public String doHttpPostParam(@RequestBody User user){

return "do Post params:name="+user.getName()+",age="+user.getAge();

使用postman測(cè)試如下：

請(qǐng)求路徑分別為：

http://localhost:8081/user/doGetHaveNoParam

http://localhost:8081/user/doGetHaveParam

http://localhost:8081/user/doPostHaveNoParam

http://localhost:8081/user/doPostHaveParam

以上就是用spring-boot集成httpClient實(shí)現(xiàn)遠(yuǎn)程調(diào)用的方法，代碼詳細(xì)清楚，如果在日常工作遇到這個(gè)問題，希望你能通過這篇文章解決問題。如果想了解更多相關(guān)內(nèi)容，歡迎關(guān)注創(chuàng)新互聯(lián)行業(yè)資訊頻道！

當(dāng)前文章：如何用spring-boot集成httpClient實(shí)現(xiàn)遠(yuǎn)程調(diào)用
網(wǎng)頁(yè)網(wǎng)址：http://m.kartarina.com/article36/pphosg.html

成都網(wǎng)站建設(shè)公司_創(chuàng)新互聯(lián)，為您提供自適應(yīng)網(wǎng)站、移動(dòng)網(wǎng)站建設(shè)、定制開發(fā)、網(wǎng)站制作、定制網(wǎng)站、手機(jī)網(wǎng)站建設(shè)

聲明：本網(wǎng)站發(fā)布的內(nèi)容（圖片、視頻和文字）以用戶投稿、用戶轉(zhuǎn)載內(nèi)容為主，如果涉及侵權(quán)請(qǐng)盡快告知，我們將會(huì)在第一時(shí)間刪除。文章觀點(diǎn)不代表本網(wǎng)站立場(chǎng)，如需處理請(qǐng)聯(lián)系客服。電話：028-86922220；郵箱：631063699@qq.com。內(nèi)容未經(jīng)允許不得轉(zhuǎn)載，或轉(zhuǎn)載時(shí)需注明來(lái)源：創(chuàng)新互聯(lián)

猜你還喜歡下面的內(nèi)容