spring - 在没有 Spring Cloud 的情况下使用 RibbonClient 和 Consul 发现进行 Feign

Question

我试图设置 Feign 来与 RibbonClient 一起使用，例如 MyService api = Feign.builder().client(RibbonClient.create()).target(MyService.class, "https://myAppProd"); ，其中 myAppProd 是我可以在 Consul 中看到的应用程序。现在，如果我对 Feign 客户端使用 Spring 注解( @FeignClient("myAppProd") 、 @RequestMapping )，一切都会像 Spring Cloud 模块一样处理一切。

如果我想使用Feign.builder()和@RequestLine ，我收到错误: com.netflix.client.ClientException: Load balancer does not have available server for client: myAppProd .

我最初的想法是 Feign 是为了与 Eureka 配合使用而构建的，只有 Spring Cloud 才能与 Consul 集成，但我对此并不确定。

那么，有没有办法让Feign在没有Spring Cloud的情况下与Consul一起工作？

提前致谢。

Answer 1

在我看来，这不是假装与领事一起工作，而是假装 -> 功能区 -> 领事。

RibbonClient 需要从其 LoadBalancer 中找到 myAppProd 的 serverList。 如果没有 ServerList，则会出现错误:“没有可供客户端使用的服务器”。

这项工作已经由 SpringCloudConsul 和 SpringCloudRibbon 项目完成，当然你可以编写另一个适配器，这只是一些粘合代码。恕我直言，您可以将此 spring 依赖项导入到您的项目中，但以非 spring 方式使用它。演示代码:

只需编写一个新的feign.ribbon.LBClientFactory，它使用ConsulServerList(Spring的类)生成LBClient。

public class ConsulLBFactory implements LBClientFactory {

    private ConsulClient client;
    private ConsulDiscoveryProperties properties;

    public ConsulLBFactory(ConsulClient client, ConsulDiscoveryProperties consulDiscoveryProperties) {
        this.client = client;
        this.properties = consulDiscoveryProperties;
    }

    @Override
    public LBClient create(String clientName) {
        IClientConfig config =
            ClientFactory.getNamedConfig(clientName, DisableAutoRetriesByDefaultClientConfig.class);

        ConsulServerList consulServerList = new ConsulServerList(this.client, properties);
        consulServerList.initWithNiwsConfig(config);

        ZoneAwareLoadBalancer<ConsulServer> lb = new ZoneAwareLoadBalancer<>(config);

        lb.setServersList(consulServerList.getInitialListOfServers());
        lb.setServerListImpl(consulServerList);
        return LBClient.create(lb, config);
    }
}

然后在 feign 中使用它:

public class Demo {
    public static void main(String[] args) {
        ConsulLBFactory consulLBFactory = new ConsulLBFactory(
            new ConsulClient(),
            new ConsulDiscoveryProperties(new InetUtils(new InetUtilsProperties()))
        );

        RibbonClient ribbonClient = RibbonClient.builder()
            .lbClientFactory(consulLBFactory)
            .build();

        GitHub github = Feign.builder()
            .client(ribbonClient)
            .decoder(new GsonDecoder())
            .target(GitHub.class, "https://api.github.com");

        List<Contributor> contributors = github.contributors("OpenFeign", "feign");
        for (Contributor contributor : contributors) {
            System.out.println(contributor.login + " (" + contributor.contributions + ")");
        }
    }

    interface GitHub {
        @RequestLine("GET /repos/{owner}/{repo}/contributors")
        List<Contributor> contributors(@Param("owner") String owner, @Param("repo") String repo);
    }

    public static class Contributor {
        String login;
        int contributions;
    }
}

你可以找到这个demo code here ，在运行此演示之前将 api.github.com 添加到您的本地 consul。