您好,登錄后才能下訂單哦!
這篇文章主要介紹了SpringCloud怎么利用Feign訪問外部http請(qǐng)求的相關(guān)知識(shí),內(nèi)容詳細(xì)易懂,操作簡(jiǎn)單快捷,具有一定借鑒價(jià)值,相信大家閱讀完這篇SpringCloud怎么利用Feign訪問外部http請(qǐng)求文章都會(huì)有所收獲,下面我們一起來看看吧。
大家好,目前接手了一個(gè)項(xiàng)目,具體的邏輯并不復(fù)雜,主要是一個(gè)"中間商"角色, 比如客戶端通過我訪問高德地圖API,就不需要帶秘鑰,直接帶高德API所需的入?yún)⒑蛈rl后綴,就可以訪問。
目前遇到這樣一個(gè)問題,項(xiàng)目架構(gòu)師要求所有的項(xiàng)目自己寫的htttpClintUtils或者其他工具,需要替換到feign的形式來完成調(diào)用,但是,目前這個(gè)項(xiàng)目訪問外部的http接口很多,比如,提供的高德服務(wù)就有10多種,一共有大幾十類型,這樣的話,如果按照以前的方式,一個(gè)接口指定一個(gè)高德子服務(wù),那豈不是要累死 = =!
@FeignClient(value = "test",url = "http://ip:port") public interface TestFeign { /** * @return 高德服務(wù)接口 * @description 訪問高德地理編碼服務(wù) */ @PostMapping(value = "/Amap/geo") Object geo(@RequestBody GeoEntity entity); /** * @return 高德服務(wù)接口 * @description 訪問高德逆地理編碼服務(wù) */ @PostMapping(value = "/Amap/regeo") Object regeo(@RequestBody RegeoEntity entity); ......... ........... }
然后如果我除了高德服務(wù)還有其他外部服務(wù),并且其他外部服務(wù)下的子接口,不一定就兩個(gè),那這樣寫的話,要頭大死,并且這樣的寫法,在服務(wù)的內(nèi)部,不能做秘鑰和權(quán)限的動(dòng)態(tài)配置,只能在url上做指定,比較笨拙,所以就需要一種可以靈活訪問外部httpClient的Feign接口,只需要我指定一個(gè)url,指定下提交的post數(shù)據(jù),就可以得到返回結(jié)果,豈不是美滋滋?
<dependency> <groupId>org.springframework.cloud</groupId> <artifactId>spring-cloud-starter-openfeign</artifactId> <version>2.0.1.RELEASE</version> </dependency> <dependency> <groupId>org.springframework.cloud</groupId> <artifactId>spring-cloud-starter-netflix-hystrix</artifactId> <version>2.0.1.RELEASE</version> </dependency> <!-- 引入 httpclient --> <dependency> <groupId>org.apache.httpcomponents</groupId> <artifactId>httpclient</artifactId> </dependency> <dependency> <groupId>com.netflix.feign</groupId> <artifactId>feign-httpclient</artifactId> <version>8.18.0</version> </dependency>
前兩個(gè)是feign和服務(wù)降級(jí)用到的包,后兩個(gè)是用Apache Http替換原生的feign-http-client用來提供連接池等功能。
feign: httpclient: enabled: true hystrix: enabled: true hystrix: command: default: execution: isolation: thread: timeoutInMilliseconds: 3000 #降級(jí)超時(shí)時(shí)間,我設(shè)置為3秒。 feign.retry默認(rèn)超時(shí)時(shí)間是5s.
設(shè)置了個(gè)降級(jí)超時(shí)時(shí)間,還有啟動(dòng)了feign訪問外部httpClient配置和服務(wù)降級(jí)配置。
@EnableFeignClients
@EnableHystrix
代碼部分:
public interface HttpRequestFeign { @RequestLine("GET") String sendGetRequest(URI baseUri); @RequestLine("POST") String sendPostRequest(URI baseUri, Map map); }
調(diào)用部分,這里我在我的BaseController構(gòu)造注解,其他服務(wù)Controller繼承,提供調(diào)用能力:
@Autowired public BaseController(Decoder decoder, Encoder encoder) { httpRequestFeign = Feign.builder().encoder(encoder).decoder(decoder) .target(Target.EmptyTarget.create(HttpRequestFeign.class)); } protected String httpPostSend( String url, Map map) { String response = ""; try { response = httpRequestFeign.sendPostRequest(new URI(url), map); logger.info("調(diào)用外部服務(wù)返回的數(shù)據(jù)為->{}", response); // 這里改成重試的超時(shí)異常 } catch (RetryableException a) { logger.error("調(diào)用外部服超時(shí)錯(cuò)誤->{}", response); } catch (Exception e) { logger.error("調(diào)用外部服異常錯(cuò)誤->{}", response); } return response; }
這里只列舉了Post的,Get方式,就不用了攜帶map參數(shù)了。
然后在你的Controller層增加降級(jí)@HystrixCommand注解,并指定降級(jí)方法:
@HystrixCommand(fallbackMethod = "fallback") @PostMapping(value = "/1_0_0/{subServer}", produces = "application/json;charset=UTF-8") public Object send(@RequestBody Map<String, Object> map, @PathVariable String subServer) { ....................... .................... private Object fallback(Map<String, String> map, String subserver, Throwable e) { logger.error("xxx服務(wù)發(fā)生問題,入?yún)?{},地址:{}", map, subserver); return Result.fail(ResultCode.INTERNAL_SERVER_ERROR.getCode(), ERROR_MSG + e.toString()); }
在send方法里可以自行進(jìn)行拼接url,而Map就是傳遞給第三方服務(wù)的數(shù)據(jù)。
springboot 4.0.0
<dependencyManagement> <dependencies> <dependency> <groupId>org.springframework.cloud</groupId> <artifactId>spring-cloud-openfeign</artifactId> <version>2.0.2.BUILD-SNAPSHOT</version> <type>pom</type> <scope>import</scope> </dependency> </dependencies> </dependencyManagement> <dependencies> <!--外部http請(qǐng)求 FeignClient--> <dependency> <groupId>org.springframework.cloud</groupId> <artifactId>spring-cloud-starter-openfeign</artifactId> </dependency> </dependencies> <repositories> <!--外部http請(qǐng)求 FeignClient--> <repository> <id>spring-snapshots</id> <name>Spring Snapshots</name> <url>https://repo.spring.io/libs-snapshot</url> <snapshots> <enabled>true</enabled> </snapshots> </repository> </repositories>
@SpringBootApplication @MapperScan("com.sichuang.repository.dao")//將項(xiàng)目中對(duì)應(yīng)的mapper類的路徑加進(jìn)來就可以了 @ServletComponentScan @EnableFeignClients public class RepositoryApplication extends SpringBootServletInitializer{ public static void main(String[] args) { SpringApplication.run(RepositoryApplication.class, args); } @Override protected SpringApplicationBuilder configure(SpringApplicationBuilder builder) { // TODO Auto-generated method stub // return super.configure(builder); return builder.sources(RepositoryApplication.class); } }
@RequestParam 參數(shù)注解
produces = MediaType.APPLICATION_JSON_UTF8_VALUE 返回json參數(shù)
package com.sichuang.repository.api; import com.alibaba.fastjson.JSON; import com.alibaba.fastjson.JSONObject; import org.springframework.cloud.openfeign.FeignClient; import org.springframework.http.MediaType; import org.springframework.web.bind.annotation.GetMapping; import org.springframework.web.bind.annotation.RequestParam; import java.util.Map; /** * 對(duì)接接口 * * @author xs * @date 2018/10/8 9:08 */ @FeignClient(url = "${url}", name = "Ewaytec2001API") public interface Ewaytec2001API { /** */ @GetMapping(value = "${url}", produces = MediaType.APPLICATION_JSON_UTF8_VALUE) String getEmployeeInfo(@RequestParam("id") int id, @RequestParam("sign") String sign); }
關(guān)于“SpringCloud怎么利用Feign訪問外部http請(qǐng)求”這篇文章的內(nèi)容就介紹到這里,感謝各位的閱讀!相信大家對(duì)“SpringCloud怎么利用Feign訪問外部http請(qǐng)求”知識(shí)都有一定的了解,大家如果還想學(xué)習(xí)更多知識(shí),歡迎關(guān)注億速云行業(yè)資訊頻道。
免責(zé)聲明:本站發(fā)布的內(nèi)容(圖片、視頻和文字)以原創(chuàng)、轉(zhuǎn)載和分享為主,文章觀點(diǎn)不代表本網(wǎng)站立場(chǎng),如果涉及侵權(quán)請(qǐng)聯(lián)系站長(zhǎng)郵箱:is@yisu.com進(jìn)行舉報(bào),并提供相關(guān)證據(jù),一經(jīng)查實(shí),將立刻刪除涉嫌侵權(quán)內(nèi)容。