跳过正文
  1. 文章/

搭建Go版本Kubernetes微服务示例

·1665 字·4 分钟
编程框架
Weaxs
作者
Weaxs

前言
#

此项目示例主要是参考 Java版Kubernetes微服务示例,在业务需求相同的情况下,搭建一个Golang版本的Kubernetes项目

项目代码: Go微服务架构 Kubernetes

架构图
#

本项目和Java版本的示例类似架构,也是采用的DDD领域驱动设计,故架构图如下:

Untitled

模块
#

本项目分别采用了字节的kitex和hertz框架构建的微服务,具体的内容包括:

  • 框架方面,domain领域模块(account/payment/warehouse)采用的 Kitex框架;gateway网关采用的** Hertz框架**,网关目前只做了简单的转发验签
  • 配置方面,使用https://github.com/spf13/viper读取 toml 文件,同时兼容了environment环境变量
  • 通信和序列化协议方面,account领域提供了RPC+Thrift协议进行内部服务间调用;payment和warehouse模块提供了RPC+Protobuf协议进行内部服务间调用;gateway模块提供了RESTful接口供外部前端模块使用

Kitex框架中序列化的代码生成,具体参考 代码生成工具

技术组件
#

采用基于Kubernetes的微服务架构,其中的技术组件包括

  • 配置中心:采用的 Kubernetes 的 ConfigMap 来管理配置文件。在Kubernetes的 Deployment 中,将 ConfigMap 中的配置文件映射到Pod容器内,使用 viper 读取容器中配置文件并实现动态更新。
  • 服务发现:采用 Kubernetes 的Service 来管理,通过 Kubernetes 的 NameSpace 名称空间,使用 Service name 自动将 RPC 访问中的服务路由到对应容器。
  • 服务网关:仅用hertz框架搭建了一个简易的网关,只是进行简单的 restful 到 RPC 的请求转发,并使用Oauth中间键做权限校验。
  • 认证授权:采用 Google OAuth2

镜像构建
#

DockerFile 中的镜像生成,将镜像构建和镜像运行分为了两步:

  • 使用golang:1.20镜像作为builder,编译构建微服务,产出二进制文件
  • 使用alpine镜像运行 builder 中产生的二进制文件

以gateway模块为例,具体的操作如下:

FROM golang:1.20 as builder

RUN mkdir /app
WORKDIR /app

ENV GO111MODULE=on \
    GOPROXY=https://goproxy.cn,direct \
    PORT=8888

COPY *.go ./
COPY go.mod go.sum ./
RUN go mod tidy
RUN CGO_ENABLED=0 go build -o bookstore-platform-gateway *.go

###################################################################
## Run container
FROM alpine:latest

RUN apk --no-cache add ca-certificates

RUN mkdir /app
WORKDIR /app
COPY conf/*.toml conf/
COPY --from=builder /app/bookstore-platform-gateway .

EXPOSE $PORT

## Run
CMD [ "./bookstore-platform-gateway" ]

运行程序
#

相比于《凤凰架构》中的原工程,这里仅支持 Skaffold 的方式运行。

Skaffold 是根据skaffold.yml中的配置来进行的,开发时 skaffold 通过dev指令来执行这些配置。

拓展
#

Kitex Protobuf 中使用 google.timestamp 的序列化问题
#

kitex 框架中 fastpb 部分对于 google.timestamp 的序列化暂无支持,具体 issue 可以追溯到 https://github.com/cloudwego/kitex/issues/835,这里通过 string 类型兼容了这一处理,具体操作如下:

import "google/protobuf/timestamp.proto";

message Payment {
  google.protobuf.Timestamp createTime = 1;
  string payId = 2;
  double totalPrice = 3;
  int64 expires = 4;
  string paymentLink = 5;
}
type Payment struct {
	state         protoimpl.MessageState
	sizeCache     protoimpl.SizeCache
	unknownFields protoimpl.UnknownFields

	CreateTime  *timestamppb.Timestamp `protobuf:"bytes,1,opt,name=createTime,proto3" json:"createTime,omitempty"`
	PayId       string                 `protobuf:"bytes,2,opt,name=payId,proto3" json:"payId,omitempty"`
	TotalPrice  float64                `protobuf:"fixed64,3,opt,name=totalPrice,proto3" json:"totalPrice,omitempty"`
	Expires     int64                  `protobuf:"varint,4,opt,name=expires,proto3" json:"expires,omitempty"`
	PaymentLink string                 `protobuf:"bytes,5,opt,name=paymentLink,proto3" json:"paymentLink,omitempty"`
}

func (x *Payment) fastReadField1(buf []byte, _type int8) (offset int, err error) {
	value, offset, err := fastpb.ReadString(buf, _type)
	if err != nil {
		return offset, err
	}
	timestamp, _ := time.Parse(time.RFC3339Nano, value)
	x.CreateTime = &timestamppb.Timestamp{Seconds: timestamp.Unix(), Nanos: int32(timestamp.Nanosecond())}
	return offset, nil
}

func (x *Payment) fastWriteField1(buf []byte) (offset int) {
	if x.CreateTime == nil {
		return offset
	}
	timestamp := x.GetCreateTime().AsTime()
	offset += fastpb.WriteString(buf[offset:], 1, timestamp.Format(time.RFC3339Nano))
	return offset
}

func (x *Payment) sizeField1() (n int) {
	if x.CreateTime == nil {
		return n
	}
	timestamp := x.GetCreateTime().AsTime()
	n += fastpb.SizeString(1, timestamp.Format(time.RFC3339Nano))
	return n
}

Viper 读取 ConfigMap 配置
#

采用 Kubernetes ConfigMap 定义config.toml 配置文件,在使用 Kubernetes Deployment 构建过程中,将 ConfigMap 映射到 volumes ,并在 volumes 映射到 container 对应的配置文件目录。具体的操作示例如下:

## ConfigMap 定义配置配置文件config.toml
kind: ConfigMap
apiVersion: v1
metadata:
  name: gateway
  namespace: bookstore-microservices
data:
  config.toml: |-
    [account.client]
    connnum = 1
    hostport = ["account:8810"]

    [payment.client]
    connnum = 1
    hostport = ["payment:8812"]

    [warehouse.client]
    connnum = 1
    hostport = ["warehouse:8811"]    

---
kind: Deployment
apiVersion: apps/v1
metadata:
  name: bookstore-platform-gateway
  namespace: bookstore-microservices
  labels:
    app: gateway
spec:
  replicas: 1
  selector:
    matchLabels:
      app: gateway
  template:
    metadata:
      labels:
        app: gateway
    spec:
      serviceAccountName: book-admin
      containers:
        - name: gateway
          image: icyfenix/bookstore-platform-gateway
          ports:
            - name: http-server
              containerPort: 8888
          env:
            - name: CONFIG_PATH
              value: /app/conf/config.toml
          ## volumes 映射到 container 中的配置文件目录
          volumeMounts:
            - name: config-volume
              mountPath: /app/conf
      ## 映射 configmap 到 volumes
      volumes:
        - name: config-volume
          configMap:
            name: gateway

微服务层面,使用 viper 读取对应的配置文件,具体操作如下:

func NewConfig() (v *viper.Viper) {
	v = viper.New()
	v.SetDefault(configPathKey, defaultConfigPath)
	defaultClientConfig(v)
	v.AutomaticEnv()
	// 通过ENV获取
	v.SetEnvKeyReplacer(strings.NewReplacer(".", "_"))
	v.SetTypeByDefaultValue(true)
	v.SetConfigFile(v.GetString(configPathKey))
	err := v.ReadInConfig()
	if err != nil {
		klog.CtxErrorf(context.Background(), err.Error())
	}
	v.WatchConfig()
	v.OnConfigChange(func(in fsnotify.Event) {
		klog.CtxErrorf(context.Background(), "Config file changed: %s", in.Name)
	})
	return
}

框架
#

cloudwego/kitex

Go RPC framework with high-performance and strong-extensibility for building micro-services.

Go
6654
772
cloudwego/hertz

Go HTTP framework with high-performance and strong-extensibility for building micro-services.

Go
4674
450
spf13/viper

Go configuration with fangs

Go
25736
1983
golang/oauth2

Go OAuth2

Go
5125
970

参考
#

项目
#

fenixsoft/microservice_arch_kubernetes

基于Kubernetes实现的微服务架构示例工程。《凤凰架构》的配套组件。

Java
208
133
EwanValentine/shippy

Code for the tutorial series on creating Microservices with Golang

Go
768
233
cloudwego/kitex-examples

Examples for Kitex.

Go
339
218
cloudwego/hertz-examples

Examples for Hertz.

Go
190
109

文档
#

《凤凰架构》——基于Kubernetes的微服务架构

kitex 文档

hertz 文档

viper 读取 ConfigMap 配置

Kubernetes Deployment 添加 ConfigMap 和 Secret 配置映射

相关文章

为什么Spring可以“自己注入自己”
·2032 字·5 分钟
编程框架
看一下Spring源码和PR记录,解答从哪个版本哪个提交那段代码后,Spring支持了Self-Injection
Go语言指针性能
·2205 字·5 分钟
编程框架
Go值对象和指针对象在存储、性能和使用上的区别
Netty 源码分析及内存溢出思路
·4372 字·9 分钟
编程框架
主要介绍了Java NIO、Netty和Spring Reactor中Buffer的使用和继承关系。