Shawn

第一次,站长亲自招 Gopher 了>>>

原文https://juejin.im/post/6844903693423230989

引言

随着微服务的快速发展,越来越多的公司选择使用“金丝雀发布”的模式进行软件的发布。在本文中我将通过华为的开源微服务框架:go-chassis,向各位介绍如何通过对router的管理从而达到金丝雀发布的目的。

图一

Go-chassis实现金丝雀发布

金丝雀发布:又叫灰度发布,使程序可以在黑白之间进行新老版本平滑过度地发布,使应用可以更加平稳地升级。 如图一所示,需要将原100%访问 version 1.0的流量一半分流至新的版本version 2.0,此时我们通过以下简单的配置,我们就可以实现图一所示的效果。

routeRule:
 RESTServer: 
 - precedence: 1 # 优先级,数字越大优先级越高
 route: #路由规则列表
 - tags:
 version: 1.0 #对接service center的话,如果不填就自动为0.1
 weight: 50 #全重 50%到这里
 - tags:
 version: 2.0 
 weight: 50 #全重 50%到这里复制代码

通过流量的分流,在老版本依旧正常服务的情况下,通过引流部分流量访问新的版本,进行新版本的发布。如果新版本一切正常,以及用户对新功能也满意,我们就可以逐步将原本分流至version 1.0的流量全部分流至version 2.0。等全部请求version 2.0后,我们就可以将version 1.0 服务逐步下线。但是如果version 2.0在运行过程中出现严重的问题,也可以迅速将请求全部访问version 1.0,然后将新本版全部下线。

此时也许会有人问,我们不仅仅是为了将所有的请求进行分流,我们仅仅需要某些功能进行分流,如图二

图二

图二中,我们只是需要将header含有chassis:v2进行分流,将80%的请求访问新斑斑,其余的请求将继续访问老版本。此时我们可以使用如下配置已达到图二中特定的效果

routeRule:
 RESTServer: #这里就是请求里的host,也是sc里的service name
 - precedence: 1 # 优先级,数字越大优先级越高
 route: #路由规则列表
 - tags:
 version: 1.0 #对接service center的话,如果不填就自动为0.1
 weight: 100 #全重 100%到这里
 - precedence: 2
 match:
 headers:
 Chassis: # 请求header中有V2
 regex: V2
 route: #路由规则列表
 - tags:
 version: 2.0
 weight: 80 #权重80%到这里
 - tags:
 version: 1.0
 weight: 20 #权重100%到这里复制代码

1 Go-chassis介绍

源码仓库 : go-chassis

go-chassis文档

go-chassis 是华为的一个开源微服务框架,该框架集成了许多功能,为求为广大使用者这提供一站式的服务。

2 Go-chassis的路由管理介绍

go-chassis的路由管理可根据版本设置流量权重,header匹配,模板匹配等规则进行设置,让你轻松通过路由管理实现金丝雀发布。

2.1 路由管理配置说明

配置项

说明

precedence

优先级配置,数字越大则优先级越高

match

匹配特定请求,未定义则匹配任何请求

headers

header规则设置,支持正则, 等于, 小于, 大, 于不等于等匹配方式

router

配置路由规则列表

tags

tags属性的配置,用于路由分发规则的version和appID

weight

router下的tag规则设置,设置请求权重,值为0-100之间

version

router下的tag规则设置,设置请求的version,与weight搭配使用

refer

指定需要引用的模板,使用定义的模板名称

sourceTemplate

定义请求模板

• header说明

如果headers下同时配置多个匹配条件,则需要同时满足所有配置条件,才会执行该header下的router规则

exact : 精确匹配, 必须等于该配置值

regex:按正则匹配header内容

noEqu:不等于。Header不等于配置值

noLess:大于等于。header不小于配置值

noGreater:小于等于。header不大于配置值

greater:大于。header大于配置值

less:小于。header小于配置值

在文中,将会通过展示demo使用的router配置进行详细的介绍,以及实现的功能进行说明

3快速入门---router

例子中使用的go-chassis的rest协议

运行前,请前往一下地址下载server center,并启动server center

• 安装

go get -u github.com/go-chassis/go-chassis复制代码

server-v1

在conf文件下新增或修改你的配置文件

配置microservice.yaml

---
#Private property of microservices
service_description:
 name: RESTServer
 version: 1.0复制代码

name:配置你的服务名

version:配置服务版本号

配置chassis.yaml

---
cse:
 service:
 registry:
 address: http://127.0.0.1:30100 # 
 scope: full #set full to be able to discover other app's service
 protocols:
 rest:
 listenAddress: 127.0.0.1:9091复制代码

• address:为注册服务中心的地址,下载后为进行任何修改,默认为127.0.0.1:30100,如你已经进行修改,请使用自己修改后的值
• rest: 所选用的通讯协议,如为grpc,则填写grpc
• listenAddress:为服务监听的IP和端口

代码演示

在这里使用的rest协议,需要声明所需要的struct,以及实现URLPatterns,该方法主要用于路由的设置。

HelloServer

// HelloServer
type HelloServer struct {
}复制代码

URLPatterns

// URLPatterns
func (*HelloServer) URLPatterns() []restful.Route {
 return []restful.Route{
 {Method: http.MethodGet, Path: "/hello/{name}", ResourceFuncName: "Hello"},
 }
}复制代码

完整代码如下

package main
import (
 "net/http"
 "github.com/go-chassis/go-chassis"
 "github.com/go-chassis/go-chassis/core/lager"
 "github.com/go-chassis/go-chassis/core/server"
 "github.com/go-chassis/go-chassis/server/restful"
)
func main() {
 chassis.RegisterSchema("rest", &ServerStruct{}, server.WithSchemaID("Hello"))
 if err := chassis.Init(); err != nil {
 lager.Logger.Error("Init failed." + err.Error())
 return
 }
 chassis.Run()
}
// HelloServer
type HelloServer struct {
}
// Hello
func (*HelloServer) Hello(ctx *restful.Context) {
 name := ctx.ReadPathParameter("name")
 ctx.Write([]byte("Chassis V1.0 hello : " + name))
}
// URLPatterns
func (*ServerStruct) URLPatterns() []restful.Route {
 return []restful.Route{
 {Method: http.MethodGet, Path: "/hello/{name}", ResourceFuncName:"Hello"},
 }
}复制代码

启动server V1

go build main.go
./main复制代码

如果你直接启动,需要设置环境变量:CHASSIS_HOME,如果未设置该环境变量,启动时将找不到你的配置文件

CHASSIS_HOME=/{path}/{to}/serverV1/复制代码

也就是你的conf所在的目录

server-v2

与server-v1类似,只要修改一下几个地方即可

在 microservice.yaml 中将version修改为2.0,此处没强制性要求,只要修改和不一致即可。修改Hello 方法,为了方便区分服务之间的不同

// Hello
func (*HelloServer) Hello(ctx *restful.Context) {
 name := ctx.ReadPathParameter("name")
 ctx.Write([]byte("Chassis V2.0 hello : " + name))
}复制代码

修改chassis.yaml中的监听端口

完成以上修改了,就可以启动server-v2了

Client

前面介绍到的路由管理,也是在client端进行配置,下面展示在例子中使用到router.yaml配置

routeRule:
 RESTServer: # server设置的name,也是sc里的service name
 - precedence: 1 # 优先级,数字越大优先级越高
 route: #路由规则列表
 - tags:
 version: 1.0 #对接service center的话,如果不填就自动为0.1
 weight: 50 #全重 50%到这里
 - tags:
 version: 2.0 #对接service center的话,如果不填就自动为0.1
 weight: 50 #全重 50%到这里
 - precedence: 2
 match:
 headers:
 Chassis: # 请求header中有v1 
 regex: v1
 route: #路由规则列表
 - tags:
 version: 1.0
 weight: 80 #权重 80%到这里
 - tags:
 version: 2.0
 weight: 20 #权重 20%到这里
 - precedence: 2
 match:
 headers:
 Chassis: # 请求header中有v2 
 regex: v2
 route: #路由规则列表
 - tags:
 version: 2.0
 weight: 80#权重 80%到这里
 - tags:
 version: 1.0
 weight: 20 #权重 20%到这里复制代码

说明:

以上配置中当没有在请求的header中设置任何值的情况下,所有的请求将平均分配到两个sever,但是当在header中设置 v1,此时请求将有80%分流到版本为1.0的服务中,20%分流到版本为2.0的服务中,而如果在header中设置了v2,则和设置v1时刚好相反。在配置文件中使用到的RESTServer为你开发的服务名称,如果你服务名为 RESTxxx,则此处的RESTServer就改为RESTxxx即可。同时在设置header匹配条件是的chassis:v1也是任意的键值对,只要在请求时的header设置与配置一致事,router策略的配置即可生效。

client修改microservice.yaml和chassis.yaml文件,与服务端类似,name我们修改为:RESTClient,监听地址配置为:8080

client代码演示

package main
import (
 "context"
 "fmt"
 "net/http"
 "strconv"
 "github.com/go-chassis/go-chassis/core"
 "github.com/go-chassis/go-chassis"
 "github.com/go-chassis/go-chassis/client/rest"
 "github.com/go-chassis/go-chassis/core/lager"
 "github.com/go-chassis/go-chassis/core/server"
 "github.com/go-chassis/go-chassis/server/restful" "github.com/go-chassis/go-chassis/pkg/util/httputil"
)
func main() {
 chassis.RegisterSchema("rest", &ClientStruct{}, server.WithSchemaID("Hello"))
 if err := chassis.Init(); err != nil {
 lager.Logger.Error("Init failed." + err.Error())
 return
 }
 chassis.Run()
}
type ClientStruct struct {
}type result struct {
 Reply string
 Error string
}
func (*ClientStruct) Hello(ctx *restful.Context) {
 url := ctx.ReadRequest().URL
 times := ctx.ReadQueryParameter("times")
 sefverName := ctx.ReadQueryParameter("server")
 timeNum, _ := strconv.Atoi(times)
 results := []result{}
 for i := 0; i < timeNum; i++ {
 result := invoker(url.Path, sefverName)
 results = append(results, result)
 }
 ctx.WriteJSON(results, "application/json")
}
func invoker(url, serverName string) result {
 callUrl := fmt.Sprintf("cse://%s/%s", serverName, url)
 req, err := rest.NewRequest(http.MethodGet, callUrl,nil)
 if err != nil {
 return result{Error: err.Error()}
 }
 // req.Header.Set("Chassis", "v1") resp, err :=core.NewRestInvoker().ContextDo(context.TODO(), req)
 if err != nil {
 return result{Error: err.Error()}
 }
 if resp.StatusCode >= 200 || resp.StatusCode <=304 {
 return result{Reply: string(httputil.ReadBody(resp))}
 }
 return result{Reply: string(httputil.ReadBody(resp))}
}
// URLPatterns
func (*ClientStruct) URLPatterns() []restful.Route
{
 return []restful.Route{
 {Method: http.MethodGet, Path: "/hello/{name}", ResourceFuncName: "Hello"},
 }
}复制代码

演示代码中使用到的times主要为了实现一次请求,我们可以多次向sever发起请求,简化测试。为了简化,在client所提供的route和server是一致的,直接将请求在拼接“cse://”后就可以转发至server,查询参数中server获取值为启动的服务名称,一般client和server对外提供一般是不一致的,这里只是为了demo演示方便。

client代码编写完并且启动后,使用如下命令进行访问

curl http://127.0.0.1:8080/hello/chassis?times=10&server=RESTServer复制代码

最后推荐关于go-chassis的文章,以下的文章可以让你更加深入的对go-chassis的进行了解

作者:lizihuai
链接:https://juejin.im/post/6844903693423230989
来源:掘金
著作权归作者所有。商业转载请联系作者获得授权,非商业转载请注明出处。

---

2016 次点击

上一篇:Go之断言类型(assert type)

下一篇:Go make 和 new 的区别

代码 github 金丝雀 context

• 编辑
• 预览