基于Kubernetes实现前后端应用的金丝雀发布(两种方案)
作者:福禄网络研发团队 发布时间:2023-01-07 02:32:27
公司的研发管理平台实现了Gitlab+Kubernetes的Devops,在ToB和ToC场景中,由于用户量大,且预发布环境和生产环境或多或少存在差异,使得生产环境发布版本的时候还是存在很多不确定性和很大的风险。于是需求方就提出了支持金丝雀发布的需求,金丝雀发布方案有很多,以下为两种常用的方案。
1、Deployment滚动更新策略实现金丝雀发布
利用Deployment的滚动更新策略maxSurge和maxUnavailable设置最大可超期望的节点数和最大不可用节点数可实现简单的金丝雀发布。rollingUpdate.maxSurge
最大可超期望的节点数,百分比 10% 或者绝对数值 5rollingUpdate.maxUnavailable
最大不可用节点数,百分比或者绝对数值
apiVersion: extensions/v1beta1
kind: Deployment
metadata:
name: demo-deployment
namespace: default
spec:
replicas: 10
selector:
matchLabels:
name: hello-deployment
strategy:
type: RollingUpdate
rollingUpdate:
maxSurge: 10%
maxUnavailable: 0
template:
metadata:
labels:
name: demo-deployment
spec:
containers:
- name: webserver
image: nginx:1.14
ports:
- containerPort:80
此方案只适合单个应用的金丝雀发布,如果是前后端应用就不合适了,会出现前端正常版本调用后端金丝雀版本,或者前端金丝雀版本调用后端正常版本的情况。于是乎,Pass掉此方案,另寻他路。
2、Ingress-Nginx配置Ingress Annotations实现金丝雀发布
Ingress-Nginx 支持配置 Ingress Annotations 来实现不同场景下的金丝雀发布。Nginx Annotations 支持以下 4 种 Canary 规则:
nginx.ingress.kubernetes.io/canary-by-header
:基于 Request Header 的流量切分,适用于灰度发布以及 A/B 测试。当 Request Header 设置为 always时,请求将会被一直发送到 Canary 版本;当 Request Header 设置为 never时,请求不会被发送到 Canary 入口;对于任何其他 Header 值,将忽略 Header,并通过优先级将请求与其他金丝雀规则进行优先级的比较。nginx.ingress.kubernetes.io/canary-by-header-value
:要匹配的 Request Header 的值,用于通知 Ingress 将请求路由到 Canary Ingress 中指定的服务。当 Request Header 设置为此值时,它将被路由到 Canary 入口。该规则允许用户自定义 Request Header 的值,必须与上一个 annotation (即:canary-by-header)一起使用。nginx.ingress.kubernetes.io/canary-weight
:基于服务权重的流量切分,适用于蓝绿部署,权重范围 0 - 100 按百分比将请求路由到 Canary Ingress 中指定的服务。权重为 0 意味着该金丝雀规则不会向 Canary 入口的服务发送任何请求。权重为 100 意味着所有请求都将被发送到 Canary 入口。nginx.ingress.kubernetes.io/canary-by-cookie
:基于 Cookie 的流量切分,适用于灰度发布与 A/B 测试。用于通知 Ingress 将请求路由到 Canary Ingress 中指定的服务的cookie。当 cookie 值设置为 always时,它将被路由到 Canary 入口;当 cookie 值设置为 never时,请求不会被发送到 Canary 入口;对于任何其他值,将忽略 cookie 并将请求与其他金丝雀规则进行优先级的比较。
注意
:金丝雀规则按优先顺序进行如下排序:canary-by-header
- > canary-by-cookie
- > canary-weight
很显然canary-weight
也是一种随机策略,也会导致前端正常版本调用后端金丝雀版本的情况,故Pass掉此策略。canary-by-cookie
和canary-by-header-value
适合后端金丝雀发布实现,canary-by-cookie
适合前端金丝雀发布实现。
apiVersion: extensions/v1beta1
kind: Ingress
metadata:
name: demo-canary
annotations:
kubernetes.io/ingress.class: nginx
nginx.ingress.kubernetes.io/canary: "true"
nginx.ingress.kubernetes.io/canary-by-header: "canary"
nginx.ingress.kubernetes.io/canary-by-cookie: "canary"
spec:
rules:
- host: demo-api.fulu.com
http:
paths:
- backend:
serviceName: demo-api-canary
servicePort: 80
前端根据用户标签或者手动在浏览器中设置cookie的值canary=always
,前端代码如果检测到此cookie,则传递canary=always
的请求头到后端,那么就可以实现前端正常版本访问后端正常版本,或者前端金丝雀版本访问后端金丝雀版本,不会出现版本混淆的情况。
2.1 流程
如果是第一次发布,必须是正常版本。
如果发布金丝雀版本,则先检测是否有
-canary
后缀的ingress、service、deployment,如果有则替换金丝雀版本的镜像,如果没有则创建-canary
后缀的ingress、service、deployment。如果发布正常版本,则先检测是否有
-canary
后缀的ingress、service、deployment,如果有则先删除它们,再替换正常版本的镜像。
2.2 代码
前端代码改造
以React为例,修改axios请求 * ,从cookie中获取当前是否访问金丝雀版本,如果是,传递金丝雀版本请求头给后端服务。
import cookie from 'react-cookies'
axios.interceptors.request.use(
(config) => {
// 金丝雀版本
const canaryCookie = cookie.load('canary')
if (canaryCookie !== undefined) {
config.headers.canary = canaryCookie
}
return config
},
(error) => {
return Promise.reject(error)
}
)
后端代码改造
以.Net为例,通过代理透传canary请求头到其他Api服务
public class CanaryHttpMessageHandler : DelegatingHandler
{
private readonly IHttpContextAccessor _httpContextAccessor;
private const string Canary = "canary";
public CanaryHttpMessageHandler(IHttpContextAccessor httpContextAccessor)
{
_httpContextAccessor = httpContextAccessor;
}
protected override async Task<HttpResponseMessage> SendAsync(HttpRequestMessage request,
CancellationToken cancellationToken)
{
var headers = _httpContextAccessor?.HttpContext?.Request?.Headers;
if (headers != null && headers.ContainsKey(Canary))
{
// 透传请求头canary
var canary = headers[Canary].ToString() ?? "";
if (!string.IsNullOrWhiteSpace(canary))
request.Headers.TryAddWithoutValidation(Canary, canary);
}
return await base.SendAsync(request, cancellationToken);
}
}
前端Chrome测试
使用Chrome浏览器访问前端网站F12,在Console中输入document.cookie='canary =
always'手动设置canary的cookie值。
在Cookies中可以看到设置,此时访问前端网站为灰度版本。
如果删除canary的cookie,此时访问前端网站为正常版本
后端Postman测试
使用Postman访问后端接口,在请求头中输入canary = always。此时访问后端服务为灰度版本。
如果删除canary的请求头,此时访问后端服务为正常版本
最后
总体来说Ingress Annotations实现了我们的需求,如果要进一步的实现用户标签来确定用户是否访问金丝雀版本,还需要继续迭代,难度不大。就实现金丝雀发布来说,istio也是支持的,它是属于基础设施层面的,对于代码入侵性小,后续大家可以考虑一下。另外,由于时间仓促,写得不太细致,但是核心的思想和代码都在上面,希望可以给大家带来帮助!
来源:https://www.cnblogs.com/fulu/p/15648351.html


猜你喜欢
- 本文实例讲述了C#实现向函数传递不定参数的方法。分享给大家供大家参考。具体实现方法如下:using System;class Min{ pu
- 报错:Caused by: org.gradle.api.internal.artifacts.ivyservice.DefaultLeni
- Mybatis Criteria条件查询CriterionCriterion是最基本,最底层的Where条件,用于字段级的筛选。Criter
- 1.application.yml中添加两个datasourceserver: port: 8080spring: application:
- 动态创建函数大多数同学,都或多或少的使用过。回顾下c#中动态创建函数的进化:C# 1.0中:public delegate string D
- 1.下载idea的 《.ignore》 插件,重启idea生效2.添加自己想要忽略的文件夹及文件,一般选这个就够了3.如果想要忽略提交的文件
- 关联篇:HandlerThread 使用及其源码完全解析关联篇:Handler内存泄漏详解及其解决方案一说到Android的消息机制,自然就
- 实现常驻通知栏时遇到的问题:无论如何就是不显示通知,查看日志发现貌似报错了:2020-06-28 14:11:34.923 6387-638
- class文件中的特殊字符串首先说明一下, 所谓的特殊字符串出现在class文件中的常量池中,本着循序渐进和减少跨度的原则, 首先把clas
- 本文实例讲述了android编程实现sd卡读取数据库的方法。分享给大家供大家参考,具体如下:先在 Manifest 里添加权限:<us
- 本文实例为大家分享了android自定义滚动上下回弹scollView的具体代码,供大家参考,具体内容如下这是一个自定义view,在xml布
- 第一步:后端简单建个SpringBoot项目,提供一个 helloWorld接口;版本选用 2.2.6.RELEASEpackage com
- BigDecimal的舍入模式(RoundingMode)BigDecimal.divide方法中必须设置roundingMode,不然会报
- 编译常见问题在开发过程中,有碰到过一些由于编译优化导致的代码修改并不符合我们预期的情况。这也就是之前为什么我经常说编译产物其实是不太可以被信
- 实现了一个自定义的密码输入框和自定义数字键盘,用作用户支付密码设置界面。先上效果图如下,方格样式,以及点击空白处隐藏软键盘。 控件实现清单:
- 因为项目不同,有些公用库而且还是c++的,还有一些带资源的,简单的复制遇到库升级又是一轮配置,编译成aar则解决这些麻烦。但是默认andri
- 一、导入JAR包二、配置applicationContext.xml的spring核心配置三、 public static void mai
- 在Java世界中,AES、DES加密解密需要使用Cipher对象构建加密解密系统,Hutool中对这一对象做再包装,简化了加密解密过程。介绍
- 一、前言目前大部分手机都是 60Hz 的刷新率,也就是 16.6ms 刷新一次,系统为了配合屏幕的刷新频率,将 Vsync 的周期也设置为
- mybatis的SqlSession一定要关闭今天在使用mybatis查询数据时,出现了一个很奇怪的问题。同一条sql语句,查询时快时慢,并