如何基于Golang实现Kubernetes边车模式_Golang

本文介绍了如何基于 go 语言实现 kubernetes sidecar 模式，并通过实际示例演示创建 golang 实现的微服务服务、docker 容器化以及在 kubernetes 上的部署和管理。原文: sidecar pattern with kubernetes and go

在这篇文章中，我们会介绍 sidecar 模式，并创建两个基于 go 的容器化微服务，然后部署到 kubernetes 上。

什么是 sidecar 模式？

sidecar 模式是一种软件架构设计模式，尤其适用于构建和部署微服务。其主要表现为在主应用容器旁部署附加服务，称为"边车（sidecar）"，在不改变主应用程序功能的情况下增强其功能，这种模式常用于容器化应用程序。

服务

sidecar 认证服务（go）
主服务（go）

主服务

主服务非常简单，只有一个 api 端点，该端点以 http 响应的形式返回 json 消息。

package main
import (
    "fmt"
    "github.com/gin-gonic/gin"
)
func main() {
    fmt.println("api go!")
    r := gin.default()
    r.get("/ping", ping)
    r.run(":8080")
}
func ping(c *gin.context) {
    c.json(200, gin.h{
       "message": "pong",
    })
}

dockefile

from golang:1.22-alpine as builder
workdir /go/app
copy . .
run go build -v -o app cmd/api/main.go
from alpine
copy --from=builder /go/app/ .
expose 8080
cmd ["/app"]

运行以下命令编译 docker 镜像。

docker build -t mertcakmak2/go-container .

sidecar 服务

sidecar 服务会将传入的 http 请求转发给主服务。

package main
import (
 "fmt"
 "github.com/gin-gonic/gin"
 "net/http"
 "net/http/httputil"
 "net/url"
)
func main() {
 fmt.println("sidecar go!")
 r := gin.default()
 // reverse proxy
 r.any("/*proxypath", authproxy)
 r.run(":8081")
}
// simulate auth
func authproxy(c *gin.context) {
 // bearer token check...
 // main container url
 remote, err := url.parse("http://localhost:8080")
 if err != nil {
  panic(err)
 }
 proxy := httputil.newsinglehostreverseproxy(remote)
 proxy.director = func(req *http.request) {
  req.header = c.request.header
  req.host = remote.host
  req.url.scheme = remote.scheme
  req.url.host = remote.host
  req.url.path = c.param("proxypath")
 }
 proxy.servehttp(c.writer, c.request)
}

dockerfile

from golang:1.22-alpine as builder
workdir /go/app
copy . .
run go build -v -o app cmd/sidecar/main.go
from alpine
copy --from=builder /go/app/ .
expose 8081
cmd ["/app"]

运行以下命令编译 docker 镜像。

docker build -f dockerfile.sidecar -t mertcakmak2/go-sidecar .

kubernetes 部署

kubernetes 部署文件

apiversion: v1
kind: service
metadata:
  name: go-container-sidecar
spec:
  selector:
    app: go-container-sidecar
  ports:
    - protocol: "tcp"
      name: main-container-port
      port: 8080
      targetport: 8080
    - protocol: "tcp"
      name: sidecar-container-port
      port: 8081
      targetport: 8081
  type: clusterip
---
apiversion: apps/v1
kind: deployment
metadata:
  name: go-container-sidecar
spec:
  selector:
    matchlabels:
      app: go-container-sidecar
  replicas: 1
  template:
    metadata:
      labels:
        app: go-container-sidecar
    spec:
      containers:
        - name: go-container
          image: mertcakmak2/go-container:latest
          imagepullpolicy: always
          ports:
            - containerport: 8080
        - name: go-sidecar
          image: mertcakmak2/go-sidecar:latest
          imagepullpolicy: always
          ports:
            - containerport: 8081

创建部署文件，在不同端口上公开两个服务。

主服务 => 8080 sidecar 服务 => 8081

运行以下命令进行部署。

kubectl apply -f k8s-deployment.yaml

kubernetes 控制面板

包含两个容器的 pod。

发送 http 请求

访问 minikube 服务

minikube service go-container-sidecar --url

生成了两个 url，第一个 url 是主服务，第二个 url 是 sidecar 服务。

主服务 => http://127.0.0.1:57496 sidecar 服务 => http://127.0.0.1:57497

用 curl 命令发送请求。

api 返回了 json 消息，我们看一下容器日志。

sidecar 服务将这些传入的 http 请求转发给主服务。

参考资料

kubernetes sidecar container - best practices and examples^[2]

sidecar container: what is it and how to use it (examples)^[3]

你好，我是俞凡，在motorola做过研发，现在在mavenir做技术工作，对通信、网络、后端架构、云原生、devops、cicd、区块链、ai等技术始终保持着浓厚的兴趣，平时喜欢阅读、思考，相信持续学习、终身成长，欢迎一起交流学习。为了方便大家以后能第一时间看到文章，请朋友们关注公众号"deepnomind"，并设个星标吧，如果能一键三连(转发、点赞、在看)，则能给我带来更多的支持和动力，激励我持续写下去，和大家共同成长进步！