伪装注册-Spring Cloud-更改目标而不会覆盖色带

Question

简介

我希望能够有两个不同的弹簧轮廓，并根据轮廓将其更改为我们的假装建造者的硬编码地址。

当前具有以下内容：

return builder.target(cls, "http://" + serviceName);

但是我实际上想执行以下操作并改写地址：

return builder.target(cls, "http://our-server:8009/" + serviceName);

为什么

有时，我们不想在我们的开发环境中运行所有服务。此外，某些服务有时仅通过zuul网关可用。

因此，我们在不同的情况和条件下运行相同的代码。

技术细节

我们有以下代码可用于构建我们的Feign客户。

过去我们一直使用@FeignClient批注，但最近我们决定开始手动构建feignClients。

以下示例：

@FeignClient(name = "ab-document-store",  configuration = MultiPartSupportConfiguration.class, fallback = DocumentStoreFallback.class)

我们使用以下命令调用feignRegistrar类：

return registerFeignClient(DocumentStoreClient.class, true);



@RequiredArgsConstructor
//@Component
@Slf4j
public class FeignRegistrar {

    @Autowired
    private Decoder decoder;

    @Autowired
    private Encoder encoder;

    @Autowired
    private Client client;

    @Autowired
    private Contract feignContract;

    @Autowired
    private ObjectFactory<HttpMessageConverters> messageConverters;

    @Autowired
    private List<RequestInterceptor> interceptors;

    public <T> T register(Class<T> cls, String serviceName, boolean isDocumentStore) {

        if(isDocumentStore){
            encoder = new MultipartFormEncoder(new SpringEncoder(messageConverters));
        }

        //Client trustSSLSockets = new Client.Default(getSSLSocketFactory(), new NoopHostnameVerifier());

        Feign.Builder builder = Feign.builder()
            .client(client)
            .encoder(encoder)
            .decoder(decoder)
            .contract(feignContract)
            .logger(new Slf4Logger())
            .logLevel(Logger.Level.HEADERS);

        builder.requestInterceptor(new RequestInterceptor() {

            @Override
            public void apply(RequestTemplate template) {
                template.header("X-Service-Name", serviceName);
            }
        });

        for(RequestInterceptor interceptor : interceptors) { 

            builder.requestInterceptor(interceptor);
        }

        log.debug("Registering {} - as feign proxy ", serviceName);

        return builder.target(cls, "http://" + serviceName);
    }

    public static class Slf4Logger extends Logger {

        @Override
        protected void log(String configKey, String format, Object... args) {
            log.info("{} - {}", configKey, args);
        }
    }
}

Spring Cloud属性重写

我们也一直在使用诸如application-ENV.property之类的属性文件，其条目如下：

ab-document-store.ribbon.NIWSServerListClassName:com.netflix.loadbalancer.ConfigurationBasedServerList
ab-document-store.ribbon.listOfServers: localhost:8025

[不幸的是，listOfServers对我们来说还不够。我们也希望能够分配一个目录/路径。类似于：

ab-document-store.ribbon.listOfServers：localhost：8025 / ab-document-store

其他解决方法

我曾考虑过使用伪装拦截器将标头潜入所有请求，例如X-SERVICE-NAME。然后，我们可以将所有服务指向一个地址（例如localhost：9001），并将这些请求转发/代理到localhost：9001 / X-SERVICE-NAME。

但是，我希望使用更简单的解决方案，例如：

ab-document-store.ribbon.listOfServers: localhost:8025/ab-document-store

但这不起作用：（

Answer 1

简介

我找到了使用检测报头的代理的解决方案。因此，我在Java端有一个伪装拦截器，将标头x-service-name附加到每个伪装请求。

我还有一个NodeJS代理，可以分析请求，找到x-service-name，然后将请求重写为：x-service-name / originalRequestPath。

这使我可以将所有微服务都包含在zuul网关后面，而且还可以使用eureka-over-ride来访问它们。

Java-Feign-Interceptor

 Feign.Builder builder = Feign.builder()
            .client(client)
            .encoder(usedEncoder)
            .decoder(decoder)
            .contract(feignContract)
            .logger(new Slf4Logger())
            .logLevel(Logger.Level.HEADERS);

        builder.requestInterceptor(new RequestInterceptor() {

            @Override
            public void apply(RequestTemplate template) {
                template.header("X-Service-Name", serviceName);
            }
        });

NodeJS代理

在示例中，我的zuul网关（或其他代理）位于localhost：9001上。我正在听localhost:1200。

let enableProxyForJava = process.env.ENABLE_PROXY_FOR_JAVA;
if (enableProxyForJava != undefined &&  enableProxyForJava.toLowerCase() === 'true') {
    var httpProxyJava = require('http-proxy');
    var proxyJava = httpProxyJava.createProxy();

    gutil.log(  gutil.colors.green('Enabling Proxy for Java. Set your Eureka overrides to localhost:1200.') );

    require('http').createServer(function(req, res) {
        console.log("req.headers['x-service-name'] = " + req.headers['x-service-name']);
        console.log("Before req.url:"+ req.url);

        if( req.headers['x-service-name'] != undefined){
            let change =  req.headers['x-service-name'] +req.url;
            console.log("After req.url:"+ change);
            req.url = change;
        }

        proxyJava.web(req, res, {
            target: 'http://localhost:9001/'
        });

    }).listen(1200);
}

具有伪装客户端的Java应用程序内部的属性文件

mbak-microservice1.ribbon.NIWSServerListClassName:com.netflix.loadbalancer.ConfigurationBasedServerList
mbak-microservice1.ribbon.listOfServers: localhost:1200

mbak-microservice2.ribbon.NIWSServerListClassName:com.netflix.loadbalancer.ConfigurationBasedServerList
mbak-microservice2.ribbon.listOfServers: localhost:1200

mbak-document-store.ribbon.NIWSServerListClassName:com.netflix.loadbalancer.ConfigurationBasedServerList
mbak-document-store.ribbon.listOfServers: localhost:1200