快捷導(dǎo)航

Java skill動(dòng)態(tài)指定feign的訪問(wèn)地址方式

更新時(shí)間：2026年01月09日 16:43:17 作者：她又在叢中笑

在使用Feign調(diào)用內(nèi)部服務(wù)時(shí),通過(guò)Redis查詢ELB地址并進(jìn)行調(diào)用,遇到的問(wèn)題包括：指定的地址在Nacos服務(wù)名中不存在時(shí),URL參數(shù)需要賦初始值；使用ThreadLocal獲取當(dāng)前線程信息時(shí)易出問(wèn)題,建議使用MDC跨線程傳遞參數(shù),并注意請(qǐng)求結(jié)束后的清理

場(chǎng)景

在有下沉節(jié)點(diǎn)項(xiàng)目的前提下，使用feign調(diào)用內(nèi)部服務(wù)的時(shí)候，在redis查詢需要調(diào)用的內(nèi)部服務(wù)的elb地址并調(diào)用

編碼

新增feign傳參類

@Data
public class TestDto {
    private String id;
}

新增調(diào)用內(nèi)部服務(wù)的feign接口

@FeignClient(name = "test", url = "http://localhost:1234", configuration = FeignConfig.class)
public interface TestClient {
    @PostMapping(value = "/v1/test/get_name")
    Object getNameById(@RequestParam("id") String id, @RequestBody TestDto body);
}

feign配置類邏輯修改

@Configuration
public class FeignConfig {

    @Bean
    public RequestInterceptor headerInterceptor() {
        return new RequestInterceptor() {
            @Override
            public void apply(RequestTemplate requestTemplate) {
            	// 只有請(qǐng)求url的前綴是【/v1/test/】才需要指定地址
                if(requestTemplate.url().startsWith("/v1/test/")){
                	// 初始化地址信息
                	String url = "";
                	// 獲取@RequestBody 中的參數(shù)
                    Object parse = JSONObject.parse(new String(requestTemplate.body()));
                    Map<String,String> info = (Map<String, String>) parse;
                    String id= info.get("id");
                    if(StringUtils.isBlank(id)){
                        // 如果body中沒(méi)有id，去@RequestParam 查詢
                        Map<String, Collection<String>> queries = requestTemplate.queries();
                        //================ 業(yè)務(wù)邏輯 begin
                                             .
                                             .
                                             .
                                             .
                        //================ 業(yè)務(wù)邏輯 end
                        // 拿到要訪問(wèn)的地址之后，配置RequestTemplate.target，這樣就可以實(shí)現(xiàn)feign指定地址調(diào)用了
                        requestTemplate.target(url);
                    }
                }

            }
        };
    }
}

大坑

1、如果feign接口中@FeignClient注解的name值是nacos注冊(cè)的服務(wù)名，那要實(shí)現(xiàn)動(dòng)態(tài)指定訪問(wèn)地址的話，分以下兩種情況：

指定的地址在nacos的服務(wù)名中不存在，url參數(shù)一定要賦初始值，否則，就會(huì)發(fā)現(xiàn)requestTemplate.target 就失效了，實(shí)質(zhì)是在debug日志級(jí)別會(huì)打印負(fù)載均衡失敗的日志。
指定的地址在nacos的服務(wù)名中存在，url參數(shù)沒(méi)有硬性要求。
還是建議大家，動(dòng)態(tài)指定feign的訪問(wèn)地址，url參數(shù)最好賦一個(gè)初始值

2、requestTemplate.target(url)中的參數(shù)url內(nèi)容一定是完整的地址(如：http://127.0.0.1:8080)

3、不要在這個(gè)apply()方法中使用ThreadLocal這種獲取當(dāng)前線程中的相關(guān)信息的類，因?yàn)閒eign是線程池管理的，主線程進(jìn)入到feign之后，就進(jìn)入到了一個(gè)子線程，在feign中的所有操作都是在一個(gè)子線程中的操作，所以使用ThreadLocal這種類時(shí)會(huì)出問(wèn)題。

如果必須要在feign中獲取到此次請(qǐng)求中的一個(gè)全局參數(shù)的話，可以考慮一下使用MDC（log4j和logback等日志框架提供的一種機(jī)制），ThreadLocal是面向單個(gè)線程的，MDC是面向單個(gè)請(qǐng)求的（跨線程），使用MDC就不用考慮多個(gè)線程的問(wèn)題了，但一定要注意 請(qǐng)求結(jié)束之后要清除。