SpringBoot動(dòng)態(tài)Feign服務(wù)調(diào)用詳解
1.Feign傳統(tǒng)方式的不足
①.在微服務(wù)架構(gòu)中,當(dāng)我們使用Feign傳統(tǒng)方式進(jìn)行服務(wù)調(diào)用的時(shí)候,需要在每個(gè)服務(wù)消費(fèi)者中添加FeignClient接口,編寫對(duì)應(yīng)的方法,而且當(dāng)服務(wù)生產(chǎn)者Handler新增方法之后,服務(wù)消費(fèi)者也要在FeignClient接口中添加方法,這樣的話,會(huì)有些累贅.
那么能不能在調(diào)用服務(wù)提供者方法的時(shí)候,傳入生產(chǎn)者服務(wù)名稱的動(dòng)態(tài)生成FeignClient對(duì)象,然后通過一個(gè)通用的方法,指定Handler的URL以及參數(shù)就可以調(diào)用到指定的方法呢?
當(dāng)然可以!
2.動(dòng)態(tài)Feign
2.1.服務(wù)生產(chǎn)者
由于微服務(wù)項(xiàng)目創(chuàng)建過程并不是重點(diǎn),所以后續(xù)只展示關(guān)鍵的代碼.
Handler方法
@RestController public class OrderController { // 模擬數(shù)據(jù)庫存儲(chǔ)數(shù)據(jù) private static Map<String, Object> maps = new HashMap<>(10); static { maps.put("1", "筆記本"); } @GetMapping(value = "/getOrderById/{oId}") public Object getOrderById(@PathVariable(name = "oId") String oid) { return maps.get(oid); } @PostMapping(value = "/addOrder") public boolean addOrder(@RequestBody Map<String, String> orderMap) { try { maps.putAll(orderMap); return true; } catch (Exception e) { e.printStackTrace(); return false; } } }
2.2.動(dòng)態(tài)Feign
為了方便在多個(gè)服務(wù)消費(fèi)者模塊中使用動(dòng)態(tài)Feign的功能,可以將動(dòng)態(tài)Feign相關(guān)的功能單獨(dú)抽取出來作為一個(gè)公共的模塊,之后在服務(wù)消費(fèi)者模塊中直接依賴該公共模塊即可.
①.pom.xml
<dependencies> <dependency> <groupId>org.springframework.cloud</groupId> <artifactId>spring-cloud-starter-openfeign</artifactId> </dependency> </dependencies>
②.通用方法
/** * Description: 通用接口,里面定義通用方法 * 注意: 由于服務(wù)生產(chǎn)者所有的接口的返回值都是json格式的字符串, * 所以這里的通用接口的返回值最好使用String類型!!! */ public interface DynamicService { /** * post方法對(duì)應(yīng)的方法 * @param url 服務(wù)生產(chǎn)者Handler方法請(qǐng)求映射地址 * @param params 服務(wù)生產(chǎn)者Handler方法參數(shù) * @return */ @PostMapping(value = "{url}") String executePostRequest(@PathVariable("url") String url, @RequestBody Object params); @GetMapping(value = "{url}") String executeGetRequest(@PathVariable("url") String url, @SpringQueryMap Object params); @PutMapping(value = "{url}") String executePutRequest(@PathVariable("url") String url, @RequestBody Object params); @DeleteMapping(value = "{url}") String executeDeleteRequest(@PathVariable("url") String url, @RequestBody Object params); }
②.Feign工廠類
/** * Description: FeignClient工廠類,根據(jù)服務(wù)名稱創(chuàng)建FeignClient對(duì)象(代理對(duì)象) */ @Component public class DynamicFeignClientFactory <T>{ private FeignClientBuilder feignClientBuilder; public DynamicFeignClientFactory(ApplicationContext applicationContext){ this.feignClientBuilder = new FeignClientBuilder(applicationContext); } //動(dòng)態(tài)生成feignClient對(duì)象(代理對(duì)象) public T getFeignClient(final Class<T> type,String ServiceID){ return this.feignClientBuilder.forType(type,ServiceID).build(); } }
③.動(dòng)態(tài)FeignClient類
/** * Description: 通過FeignClient工廠獲取到的FeignClient對(duì)象通過指定的請(qǐng)求去調(diào)用生產(chǎn)者方法! */ @Component public class DynamicClient { @Autowired private DynamicFeignClientFactory<DynamicService> dynamicDynamicFeignClientFactory; public Object executePostApi(String feignName,String url,Object params){ DynamicService dynamicService = dynamicDynamicFeignClientFactory.getFeignClient(DynamicService.class,feignName); return dynamicService.executePostRequest(url,params); } public Object executeGetApi(String feignName,String url,Object params){ DynamicService dynamicService = dynamicDynamicFeignClientFactory.getFeignClient(DynamicService.class,feignName); return dynamicService.executeGetRequest(url, params); } //省略了兩個(gè)方法... }
動(dòng)態(tài)Feign一旦定義好之后,不管后續(xù)服務(wù)生產(chǎn)者中添加加多少Handler方法,這里的代碼基本上不需要修改,對(duì)于服務(wù)消費(fèi)者來說也不會(huì)產(chǎn)生任何影響(有點(diǎn)類似于設(shè)計(jì)模式里面的"開閉原則");
2.3.服務(wù)消費(fèi)者
①.引入動(dòng)態(tài)Feign模塊
<dependency> <groupId>com.xp</groupId> <artifactId>dynamic-feign</artifactId> <version>1.0-SNAPSHOT</version> </dependency>
②.Handler接口
@RestController public class UserController { //注入動(dòng)態(tài)FeignClient對(duì)象 @Autowired private DynamicClient dynamicClient; @GetMapping(value = "/getorder/{oid}") public Object getOrderById(@PathVariable(value = "oid") String oid) { //通過動(dòng)態(tài)FeignClient,指定服務(wù)名稱,Handler方法URL,參數(shù)等信息即可調(diào)用生產(chǎn)者對(duì)應(yīng)的方法 return this.dynamicClient.executeGetApi("cloud-order", "/getOrderById/".concat(oid),new HashMap<>()); } @PostMapping(value = "/addOrder") public Object addOrder(@RequestBody Map<String,Object> map){ return this.dynamicClient.executePostApi("cloud-order", "/addOrder", map); } }
③.啟動(dòng)類
@SpringBootApplication @EnableDiscoveryClient //服務(wù)治理 @EnableFeignClients //開啟Feign功能(不寫也可以!) public class UserApplication { public static void main(String[] args) { SpringApplication.run(UserApplication.class,args); } }
代碼完成之后,啟動(dòng)相關(guān)的服務(wù),就可以進(jìn)行測(cè)試
3.總結(jié)
使用動(dòng)態(tài)Feign方式進(jìn)行服務(wù)調(diào)用可以讓開發(fā)者少寫很多代碼,使其可以專注于業(yè)務(wù)本身!
到此這篇關(guān)于SpringBoot動(dòng)態(tài)Feign服務(wù)調(diào)用詳解的文章就介紹到這了,更多相關(guān)SpringBoot Feign內(nèi)容請(qǐng)搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家!
- SpringBoot使用quartz,注入feignClient,client為null問題
- SpringBoot使用Feign進(jìn)行服務(wù)間通信的實(shí)現(xiàn)示例代碼
- springboot+feign+Hystrix整合(親測(cè)有效)
- SpringBoot之使用Feign實(shí)現(xiàn)微服務(wù)間的交互
- SpringBoot Feign使用教程超全面講解
- SpringBoot + openFeign實(shí)現(xiàn)遠(yuǎn)程接口調(diào)用的過程
- springboot單獨(dú)使用feign簡(jiǎn)化接口調(diào)用方式
- springboot集成Feign的實(shí)現(xiàn)示例
相關(guān)文章
java操作mongodb實(shí)現(xiàn)CURD功能實(shí)例
mongodb支持多種語言,并且提供了多種語言的驅(qū)動(dòng),本文使用java操作mongodb實(shí)現(xiàn)CURD功能,大家參考使用吧2013-12-12springboot通用分支處理超級(jí)管理員權(quán)限邏輯
這篇文章主要為大家介紹了springboot通用分支處理超級(jí)管理員的權(quán)限邏輯,有需要的朋友可以借鑒參考下,希望能夠有所幫助,祝大家多多進(jìn)步,早日升職加薪2022-07-07SpringBoot使用maven實(shí)現(xiàn)多環(huán)境運(yùn)行和打包的操作步驟
在開發(fā)過程中,需要不斷進(jìn)行環(huán)境的切換和打包部署,maven提供了多環(huán)境配置,可以方便實(shí)現(xiàn)不同環(huán)境的配置切換和打包,本文通過代碼示例給大家介紹的非常詳細(xì),需要的朋友可以參考下2024-04-04java微信開發(fā)API第二步 獲取和回復(fù)消息
這篇文章主要為大家詳細(xì)介紹了java微信開發(fā)API第二步,獲取消息和回復(fù)消息,感興趣的小伙伴們可以參考一下2016-06-06關(guān)于kafka-consumer-offset位移問題
這篇文章主要介紹了關(guān)于kafka-consumer-offset位移問題,具有很好的參考價(jià)值,希望對(duì)大家有所幫助。如有錯(cuò)誤或未考慮完全的地方,望不吝賜教2023-03-03