zuul灰度发布功能实现
灰度发布、蓝绿发布、金丝雀发布各是什么意思，可以看这篇http://www.appadhoc.com/blog/product-release-strategy/。
基于eureka、ribbon实现灰度发布，是这一篇要讲的知识。
我们要发布版本了，在不确定正确性的情况下，我们选择先部分节点升级，然后让一些特定的流量进入到这些新节点，完成测试后再全量发布。
我们知道，在eureka中注册各个服务后，如果一个服务有多个实例，那么默认会走ribbon的软负载均衡来进行分发请求。
我们要完成灰度发布，要做的就是修改ribbon的负载策略（rule），通过一些特定的标识，譬如我们可以选择header里带有foo=1的全部路由到金丝雀服务上，其他的还走原来的老版本。或者可以设置个比重，虽然roll个小于4的正数，将等于1的路由到金丝雀，这样就会有1/4的请求到达金丝雀。诸如此类，我们可以定制各种规则来进行灰度测试。
在SpringCloud体系中，完成这件事，模式比较固定，就是根据eureka的metadata进行自定义元数据，然后修改ribbon的Rule规则。
使用很简单，我们直接上例子，注意我这里只发出来目标服务和zuul的代码，eureka的就不放了。eureka很简单，就是一个eureka server项目，什么也没有。
我们的目标服务是User，在User的application.yml里，由于我要启动2个，所以使用不同的端口
application.yml
server:
port: 8888
eureka:
instance:
prefer-ip-address: true
metadata-map:
lancher: 2
client:
service-url:
defaultZone: http://localhost:10000/eureka/application-dev.yml
server:
port: 8889
eureka:
instance:
metadata-map:
lancher: 1就是那个metadata-map元数据，这是一个map，里面就自定义一些key-value键值对。将来匹配时就用这个键值对。
然后分别启动这两个实例，启动后就有两个user注册到了eureka。
zuul配置:
在zuul项目里添加依赖，https://github.com/jmnarloch/ribbon-discovery-filter-spring-cloud-starter
<dependency>
<groupId>io.jmnarloch</groupId>
<artifactId>ribbon-discovery-filter-spring-cloud-starter</artifactId>
<version>2.1.0</version>
</dependency>这个就是做ribbon的Rule的。
package com.example.zuul_route;
import com.netflix.zuul.ZuulFilter;
import com.netflix.zuul.context.RequestContext;
import io.jmnarloch.spring.cloud.ribbon.support.RibbonFilterContextHolder;
import org.springframework.context.annotation.Configuration;
import javax.servlet.http.HttpServletRequest;
import static org.springframework.cloud.netflix.zuul.filters.support.FilterConstants.*;
/**
* @author wuweifeng wrote on 2018/1/17.
*/
@Configuration
public class PreFilter extends ZuulFilter {
@Override
public int filterOrder() {
return PRE_DECORATION_FILTER_ORDER - 1;
}
@Override
public String filterType() {
return PRE_TYPE;
}
@Override
public boolean shouldFilter() {
RequestContext ctx = RequestContext.getCurrentContext();
// a filter has already forwarded
// a filter has already determined serviceId
return !ctx.containsKey(FORWARD_TO_KEY)
&& !ctx.containsKey(SERVICE_ID_KEY);
}
@Override
public Object run() {
RequestContext ctx = RequestContext.getCurrentContext();
HttpServletRequest request = ctx.getRequest();
if (request.getParameter("foo") != null) {
// put the serviceId in `RequestContext`
RibbonFilterContextHolder.getCurrentContext()
.add("lancher", "1");
} else {
RibbonFilterContextHolder.getCurrentContext()
.add("lancher", "2");
}
return null;
}
}这个是zuul的filter，别的无所谓，注意看run方法，RibbonFilterContextHolder.getCurrentContext() .add("lancher", "1");这句话就代表将请求路由到metadata-map里lancher为1的那个服务。
so，很简单，我们就可以在这里定制各种规则了，把符合什么条件的请求，只发送到某个实例。