Openfeign転送header全リンク階調パブリケーションを実現

Openfeign転送header全リンク階調パブリケーションを実現

引用

実現

サービスでPredicateを変更

Interceptorを1つ追加

ribbonルールを設定し、我々独自のルールを使用する

引用する
ゲートウェイ層はここを見る前にゲートウェイ層が階調パブリケーションを実現すると書いてあるが、これは一度にルーティングされるしかない.クライアント->ゲートウェイ->バージョン番号に基づいてアプリケーションにルーティングしてから他のサービスを呼び出す.呼び出しチェーンのルーティングは仕方がない.サービス呼び出しのopenfeignはデフォルトでヘッダ転送を持たないため、ルーティングされるだけだ.
インプリメンテーション
サービスにゲートウェイ層に書いてあるruleとpredicate、predicateを入れて直す必要がありますが、webの中 zuul RequestContext、使用に変更ServletRequestAttributes具体的なコードはゲートウェイ層の文章を見に行きますので、ここでは書き換えません.
サービスでのPredicateの変更

import com.google.common.base.Optional;
import com.netflix.loadbalancer.AbstractServerPredicate;
import com.netflix.loadbalancer.PredicateKey;
import com.netflix.loadbalancer.Server;
import com.netflix.niws.loadbalancer.DiscoveryEnabledServer;
import org.checkerframework.checker.nullness.compatqual.NullableDecl;
import org.springframework.util.StringUtils;
import org.springframework.web.context.request.RequestContextHolder;
import org.springframework.web.context.request.ServletRequestAttributes;

import java.util.List;

public class MyPredicate extends AbstractServerPredicate {

    @Override
    public boolean apply(@NullableDecl PredicateKey predicateKey) {
        Server server = predicateKey.getServer();
        //Object loadBalancerKey = predicateKey.getLoadBalancerKey();

        //         "version"   
        if (server instanceof DiscoveryEnabledServer){
            ServletRequestAttributes attributes = (ServletRequestAttributes) RequestContextHolder.getRequestAttributes();

            // http   version
            final String contextVersion = attributes.getRequest().getHeader("version");

            final String metaVersion = ((DiscoveryEnabledServer) server).getInstanceInfo().getMetadata().get("version");
            return StringUtils.isEmpty(contextVersion) || StringUtils.isEmpty(metaVersion) || metaVersion.equals(contextVersion);
        }

        return true;
    }

    @Override
    public Optional<Server> chooseRoundRobinAfterFiltering(List<Server> servers, Object loadBalancerKey) {
        return super.chooseRoundRobinAfterFiltering(servers, loadBalancerKey);
    }
}

Interceptorを追加
利用FeignのReqeustTemplateフルリンクヘッダ転送を実現するには、gatewayでもzulでもヘッダ転送は持参しているが、Feignではデフォルトでヘッダ転送はないので、サービスに1つ統合する必要があるInterceptor転送するheader.

import feign.RequestInterceptor;
import feign.RequestTemplate;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;

import javax.servlet.http.HttpServletRequest;
import java.util.Enumeration;

@Component
public class AddHeaderInterceptor implements RequestInterceptor {
    @Autowired
    HttpServletRequest request;

    @Override
    public void apply(RequestTemplate template) {
        Enumeration<String> headerNames = request.getHeaderNames();
        String hdrName = null;

        while(headerNames.hasMoreElements()){
            hdrName = headerNames.nextElement();
            template.header(hdrName,request.getHeader(hdrName));
        }
    }
}

ribbonルールを構成し、独自のルールを使用します.

指定されたサービスのみがグレースケール配信フルリンク転送

@RibbonClient(name="   ",configuration = MyPredicateRule.class)

グローバルを直接サポートするには、上記の方法を使わずに、直接グローバルにすればいいです.公式サイトの例では@RibbonClientのconfiuration必須@Configurationの配置クラスですが、@Configurationを持っていればSpringでスキャンされてグローバルBeanに登録されますので、私のテストを経て、配置クラスを書かずに直接configurationをRuleとすることができます.

グローバルサポート

import com.netflix.niws.loadbalancer.DiscoveryEnabledNIWSServerList;
import org.springframework.beans.factory.config.ConfigurableBeanFactory;
import org.springframework.boot.autoconfigure.AutoConfigureBefore;
import org.springframework.boot.autoconfigure.condition.ConditionalOnClass;
import org.springframework.boot.autoconfigure.condition.ConditionalOnMissingBean;
import org.springframework.boot.autoconfigure.condition.ConditionalOnProperty;
import org.springframework.cloud.netflix.ribbon.RibbonClientConfiguration;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.context.annotation.Scope;

@Configuration
@AutoConfigureBefore(RibbonClientConfiguration.class)
@ConditionalOnProperty(value = "ribbon.filter.metadata.enabled", matchIfMissing = true)
public class RuleConfiguration {
    @Bean
    @ConditionalOnMissingBean
    @ConditionalOnClass(DiscoveryEnabledNIWSServerList.class)
    @Scope(ConfigurableBeanFactory.SCOPE_SINGLETON)
    public MyPredicateRule metaDataAwareRule() {
        return new MyPredicateRule();
    }

}