SpringBoot動(dòng)態(tài)Feign服務(wù)調(diào)用詳解

更新時(shí)間：2022年12月21日 10:11:02 作者：xp_xpxp

Feign是Netflix公司開(kāi)發(fā)的一個(gè)聲明式的REST調(diào)用客戶端; Ribbon負(fù)載均衡、 Hystrⅸ服務(wù)熔斷是我們Spring Cloud中進(jìn)行微服務(wù)開(kāi)發(fā)非?；A(chǔ)的組件,在使用的過(guò)程中我們也發(fā)現(xiàn)它們一般都是同時(shí)出現(xiàn)的,而且配置也都非常相似

1.Feign傳統(tǒng)方式的不足

①.在微服務(wù)架構(gòu)中,當(dāng)我們使用Feign傳統(tǒng)方式進(jìn)行服務(wù)調(diào)用的時(shí)候,需要在每個(gè)服務(wù)消費(fèi)者中添加FeignClient接口,編寫(xiě)對(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ì)象,然后通過(guò)一個(gè)通用的方法,指定Handler的URL以及參數(shù)就可以調(diào)用到指定的方法呢?

當(dāng)然可以!

2.動(dòng)態(tài)Feign

2.1.服務(wù)生產(chǎn)者

由于微服務(wù)項(xiàng)目創(chuàng)建過(guò)程并不是重點(diǎn),所以后續(xù)只展示關(guān)鍵的代碼.

Handler方法

@RestController
public class OrderController {
    // 模擬數(shù)據(jù)庫(kù)存儲(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ú)抽取出來(lái)作為一個(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: 通過(guò)FeignClient工廠獲取到的FeignClient對(duì)象通過(guò)指定的請(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)者來(lái)說(shuō)也不會(huì)產(chǎn)生任何影響(有點(diǎn)類似于設(shè)計(jì)模式里面的"開(kāi)閉原則");

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) {
        //通過(guò)動(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 //開(kāi)啟Feign功能(不寫(xiě)也可以!)
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)用可以讓開(kāi)發(fā)者少寫(xiě)很多代碼,使其可以專注于業(yè)務(wù)本身!

到此這篇關(guān)于SpringBoot動(dòng)態(tài)Feign服務(wù)調(diào)用詳解的文章就介紹到這了,更多相關(guān)SpringBoot Feign內(nèi)容請(qǐng)搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家！

您可能感興趣的文章: