java

关注公众号 jb51net

关闭
首页 > 软件编程 > java > Java skill动态指定feign的访问地址

Java skill动态指定feign的访问地址方式

作者:她又在丛中笑

在使用Feign调用内部服务时,通过Redis查询ELB地址并进行调用,遇到的问题包括:指定的地址在Nacos服务名中不存在时,URL参数需要赋初始值;使用ThreadLocal获取当前线程信息时易出问题,建议使用MDC跨线程传递参数,并注意请求结束后的清理

场景

在有下沉节点项目的前提下,使用feign调用内部服务的时候,在redis查询需要调用的内部服务的elb地址并调用

编码

新增feign传参类

@Data
public class TestDto {
    private String id;
}

新增调用内部服务的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) {
            	// 只有请求url的前缀是【/v1/test/】才需要指定地址
                if(requestTemplate.url().startsWith("/v1/test/")){
                	// 初始化地址信息
                	String url = "";
                	// 获取@RequestBody 中的参数
                    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中没有id,去@RequestParam 查询
                        Map<String, Collection<String>> queries = requestTemplate.queries();
                        //================ 业务逻辑 begin
                                             .
                                             .
                                             .
                                             .
                        //================ 业务逻辑 end
                        // 拿到要访问的地址之后,配置RequestTemplate.target,这样就可以实现feign指定地址调用了
                        requestTemplate.target(url);
                    }
                }

            }
        };
    }
}

大坑

1、如果feign接口中@FeignClient注解的name值是nacos注册的服务名,那要实现动态指定访问地址的话,分以下两种情况:

2、requestTemplate.target(url)中的参数url内容一定是完整的地址(如:http://127.0.0.1:8080)

3、不要在这个apply()方法中使用ThreadLocal这种获取当前线程中的相关信息的类,因为feign是线程池管理的,主线程进入到feign之后,就进入到了一个子线程,在feign中的所有操作都是在一个子线程中的操作,所以使用ThreadLocal这种类时会出问题。

如果必须要在feign中获取到此次请求中的一个全局参数的话,可以考虑一下使用MDC(log4j和logback等日志框架提供的一种机制),ThreadLocal是面向单个线程的,MDC是面向单个请求的(跨线程),使用MDC就不用考虑多个线程的问题了,但一定要注意 请求结束之后要清除

总结

以上为个人经验,希望能给大家一个参考,也希望大家多多支持脚本之家。

您可能感兴趣的文章:
阅读全文