类名

描述

BambooClientHttpRequestIntercptor

用于@LoadBalance 标记的 RestTemplate，主要作用是用来获取request的相关信息，为后面的路由提供数据基础。

RestTemplate衔接：

ClientHttpRequestInterceptor是RestTemplate的拦截器接口，可以通过这个接口添加bamboo的逻辑，从而将RestTemplate和bamboo衔接起来。

BambooClientHttpRequestIntercptor是ClientHttpRequestInterceptor接口的实现类，它加入了bamboo的逻辑。

BambooPreZuulFilter

主要作用是用来获取request的相关信息，为后面的路由提供数据基础。

Zuul衔接：

实现两个ZuulFilter接口，分别是pre和post类型，将bamboo的逻辑加入其中。

Pre类型的ZuulFilter获取请求信息，并执行LoadBalanceRequestTrigger#before方法。

BambooPostZuulFilter

做一些善后工作。比如删除BambooRequestContext在ThreadLocal中的信息。

Zuul衔接

实现两个ZuulFilter接口，分别是pre和post类型，将bamboo的逻辑加入其中。

Post类型的ZuulFilter执行LoadBalanceRequestTrigger#after方法，并清除存在ThreadLocal中的相关信息。

BambooFeignClient

主要作用是用来获取request的相关信息，为后面的路由提供数据基础。

Feign衔接：

BambooFeignClient类实现了feign.Client接口，该类是一个代理类，主要的Feign的调用逻辑依然由被代理的类去执行，在该类中添加了bamboo的逻辑，从而将Feign和bamboo衔接起来。

public class BambooClientHttpRequestIntercptor implements ClientHttpRequestInterceptor{

    @Override

    public ClientHttpResponse intercept(HttpRequest request, byte[] body, ClientHttpRequestExecution execution) throws IOException {

        URI uri = request.getURI();

        BambooRequest bambooRequest = BambooRequest.builder()

                .serviceId(uri.getHost())

                .uri(uri.getPath())

                .ip(RequestIpKeeper.getRequestIp())

                .addMultiHeaders(request.getHeaders())

                .addMultiParams(WebUtils.getQueryParams(uri.getQuery()))

                .build();

        ConnectPointContext connectPointContext = ConnectPointContext.builder().bambooRequest(bambooRequest).build();

        try {     BambooAppContext.getBambooRibbonConnectionPoint().executeConnectPoint(connectPointContext);

            return execution.execute(request, body);

        }finally {

BambooAppContext.getBambooRibbonConnectionPoint().shutdownconnectPoint();

        }

    }

}

public class BambooPreZuulFilter extends ZuulFilter{

    @Override

    public String filterType() {

        return FilterConstants.PRE_TYPE;

    }

    @Override

    public int filterOrder() {

        return 10000;

    }

    @Override

    public boolean shouldFilter() {

        return true;

    }

    @Override

    public Object run() {

        RequestContext context = RequestContext.getCurrentContext();

        BambooRequest.Builder builder = BambooRequest.builder()

                .serviceId((String)context.get(FilterConstants.SERVICE_ID_KEY))

                .uri((String)context.get(FilterConstants.REQUEST_URI_KEY))

                .ip(context.getZuulRequestHeaders().get(FilterConstants.X_FORWARDED_FOR_HEADER.toLowerCase()))

                .addMultiParams(context.getRequestQueryParams())

                .addHeaders(context.getZuulRequestHeaders())

                .addHeaders(context.getOriginResponseHeaders().stream().collect(Collectors.toMap(Pair::first, Pair::second)));

        context.getOriginResponseHeaders().forEach(pair-> builder.addHeader(pair.first(), pair.second()));

        ConnectPointContext connectPointContext = ConnectPointContext.builder().bambooRequest(builder.build()).build();

        BambooAppContext.getBambooRibbonConnectionPoint().executeConnectPoint(connectPointContext);

        return null;

    }

}

public class BambooPostZuulFilter extends ZuulFilter {

    @Override

    public String filterType() {

        return FilterConstants.POST_TYPE;

    }

    @Override

    public int filterOrder() {

        return 0;

    }

    @Override

    public boolean shouldFilter() {

        return true;

    }

    @Override

    public Object run() {

//        BambooRequestContext.shutdownRequestContext();

        BambooAppContext.getBambooRibbonConnectionPoint().shutdownconnectPoint();

        return null;

    }

}

public class BambooFeignClient implements Client {

    private Client delegate;

    public BambooFeignClient(Client delegate) {

        this.delegate = delegate;

    }

    @Override

    public Response execute(Request request, Request.Options options) throws IOException {

        URI uri = URI.create(request.url());

        BambooRequest.Builder builder = BambooRequest.builder()

                .serviceId(uri.getHost())

                .uri(uri.getPath())

                .ip(RequestIpKeeper.getRequestIp())

                .addMultiParams(WebUtils.getQueryParams(uri.getQuery()));

        request.headers().entrySet().forEach(entry ->{

            for (String v : entry.getValue()) {

                builder.addHeader(entry.getKey(), v);

            }

        });

        ConnectPointContext connectPointContext = ConnectPointContext.builder().bambooRequest(builder.build()).build();

        try {

            BambooAppContext.getBambooRibbonConnectionPoint().executeConnectPoint(connectPointContext);

            return delegate.execute(request, options);

        }finally {

            BambooAppContext.getBambooRibbonConnectionPoint().shutdownconnectPoint();

        }

    }

}

接口名称

功能

BambooRibbonConnectionPoint

这个接口是负责将bamboo跟ribbon连接起来的，将请求的信息， 以及根据业务需要添加的一些路由信息，和获取请求接口的目标版本，还有触发执行LoadBanceRequestTrigger等，都是由该接口的实现类DefaultRibbonConnectionPoint负责实现。

RequestVersionExtractor

这个接口负责获取请求需要访问的目标接口的版本。比如有些接口版本是放在路径上，如:/v1/api/test/get。也有放在uri参数中:/api/test/get?v=1。也有可能放到header中，所以在bamboo抽象出来一个接口， 具体的实现由开发者根据业务去实现。

LoadBalanceRequestTrigger

Ribbon请求的触发器，在ribbon请求发起时， 会被执行。这个接口有三个方法，分别是判断是否需要执行的方法(shouldExecute)，以及请求之前执行(before)和请求完成之后执行(after)，如果出现异常，after方法依然会被执行。

BambooRequestContext

Hystrix衔接：

Hystrix实现降级、断路器等功能，但是在使用线程池隔离时，

ThreadLocal存储的信息如何传递下去呢?使用HystrixRequestVariableDefault可以解决这个问题。

可以查看com.netflix.hystrix.strategy.concurrency包下的

HystrixContexSchedulerAction、HystrixContextCallable、HystrixContextRunnable，

它们都有一段相同功能的代码

parentThreadState也是一个HystrixRequestContext对象，它是在hystrix创建线程之前的，

也就是处理http请求的线程的HystrixRequestContext对象，我们一般也是维护这个对象。

在使用线程池隔离时，hystrix会将parentThreadState中的信息复到到新线程中，实现跨线程的数据传递，

从而在后面的逻辑中可以获取到parentThreadState中维护的信息，

包括ribbon的路由信息。在bamboo中，将一步骤的逻辑放到

BambooRequestContext中，将BambooRequestContext实例本身传递下去。

类名称

描述

BambooRequestContext

parentThreadState也是一个HystrixRequestContext对象，它是在hystrix创建线程之前的，也就是处理http请求的线程的HystrixRequestContext对象，我们一般也是维护这个对象。在使用线程池隔离时，hystrix会将parentThreadState中的信息复到到新线程中，实现跨线程的数据传递，从而在后面的逻辑中可以获取到parentThreadState中维护的信息，包括ribbon的路由信息。在bamboo中，将一步骤的逻辑放到BambooRequestContext中，将BambooRequestContext实例本身传递下去。

BambooZoneAvoidanceRule和BambooApiVersionPredicate

Bamboo中的BambooZoneAvoidanceRule继承了ZoneAvoidanceRule,所以它会有ZvoidanceRule的一切特性，在此基础上，还加入了版本过滤的逻辑，这个逻辑主要是由BambooApiVersionPredicate实现。从BambooRequestContext中获取请求的接口的版本，如果有该没有获取到版本，就返回true;如果有获取到版本，就获取服务实例的metadata中的version信息，并进行匹配校验，返回结果。