k8s 上 go 服务实战: 扩容 发版更新 回滚 平滑重启

简介: 我是 dayday, 读书写作敲代码, 永远在路上感谢 [网管叨bi叨 - #Kubernetes学习笔记](https://mp.weixin.qq.com/mp/appmsgalbum?__biz=MzUzNTY5MzU2MA==&action=getalbum&album_id=1394839706508148737&scene=173#wechat_redirect "网管叨bi叨 - #Kubernetes学习笔记")

实践为主, 部分 内容/细节 略去, 详情请查看最后的资料


写在前面:


- go 稳坐 **云原生第一编程语言**

- 对概念的理解很重要, 这篇主要涉及 k8s 发布涉及到的 `deployment replicaSet pod` 3个概念

- 动手对学习真的很重要, 不仅要 `BB那么多, show me the code`, 还要 `show and run the code`

- 不要把时间浪费在 **没完没了** 的折腾工具上, 比如 本地安装 k8s, alibaba cloud toolkit 一键部署到 k8s, 用它, 是因为 **用起来爽呀**


## 环境装备


本地开发机使用的 mac, win 平台同理


mac 安装 k8s:


- [docker desktop 安装 - 使用阿里云加速](https://cr.console.aliyun.com/undefined/instances/mirrors "docker desktop 安装")

- [docker desktop 开启 k8s](https://github.com/AliyunContainerService/k8s-for-docker-desktop "docker desktop 开启 k8s")


![mac 安装 k8s]](https://upload-images.jianshu.io/upload_images/567399-cd053d01be8d0687.png?imageMogr2/auto-orient/strip%7CimageView2/2/w/1240)


更多 k8s 开发环境准备:


[minikube](https://minikube.sigs.k8s.io/docs/ "minikube")

[kind](https://kind.sigs.k8s.io/ "kind")


继续之前, 请确保自己已经了解 k8s 的基础知识


推荐教程:


- 云原生技术公开课(https://developer.aliyun.com/learning/roadmap/cloudnative "aliyun x cloudnative")


## go 服务代码准备


go http server 入门代码, 开启 3000 端口, 并包含 `/` `/health_check` 2 个请求地址


```go

package main


import (

"fmt"

"net/http"

)


func index(w http.ResponseWriter, r *http.Request) {

fmt.Fprintf(w, "<h1>Hello World</h1>")

}


func check(w http.ResponseWriter, r *http.Request) {

fmt.Fprintf(w, "<h1>Health check</h1>")

}


func main() {

http.HandleFunc("/", index)

http.HandleFunc("/health_check", check)

fmt.Println("Server starting...")

http.ListenAndServe(":3000", nil)

}

```


## go 镜像准备


号称 **云原生第一语言** 的实力开始显露出来了: 2 阶段构建, 一个镜像用来便来编译, 一个镜像只包含可执行文件


```dockerfile

FROM golang:alpine AS build-env

WORKDIR /app

ADD . /app

RUN cd /app && go build -o goapp


FROM alpine

WORKDIR /app

COPY --from=build-env /app/goapp /app/

EXPOSE 3000

ENTRYPOINT ./goapp

```


本地进行测试:


```sh

# 镜像构建

docker build -t test . # -t name:tag, 这里简单测试

# 容器运行

docker run -d --rm -p 3000:3000


# 测试

curl http://localhost:3000/

curl http://localhost:3000/health_check

```


## k8s deployment 准备


简单理一理 k8s 中 deployment 的概念:


- deployment: 管理应用的所有发布, 可使用 `kubectl get deploy` 查看

- ReplicaSet: 每次发布的都是应用的 `副本`, 不同版本会生成不同 `副本`, 副本可以进行水平伸缩, 使用 `kubectl get replicasets` 查看

- pod: 应用, 由应用需要的一组 container(容器) 组成, 本文示例比较简单, 只有一个包含简单 `go http server` 的容器


使用 [官方提供的 deployment 示例](https://k8s.io/examples/application/deployment.yaml "官方提供的 deployment 示例") 稍微改一改就行:


```yaml

apiVersion: apps/v1

kind: Deployment

metadata:

 name: go-app

spec:

 replicas: 1

 selector:

   matchLabels:

     app: go-app

 template:

   metadata:

     labels:

       app: go-app

   spec:

     containers:

       - name: go-app-container

         image: test # 上一步生成的镜像

         resources:

           limits:

             memory: "128Mi"

             cpu: "500m"

         ports:

           - containerPort: 3000

```


运行:


```sh

kubectl apply -f deployment.yaml

➜ kubectl get pod

NAME                                        READY   STATUS         RESTARTS   AGE

go-app-5757fcdcc5-pcw8l                     0/1     ErrImagePull   0          19s

```


嘛, 报错了, [胜败乃兵家常事](玩过仙剑的请举手 "胜败乃兵家常事"), 错误信息 `ErrImagePull`, 需要将镜像放到 docker hub 上


我们现在缺少的步骤:


- 镜像构建 `docker build`: `name:tag` 要想好

- 上传到 `docker hub`, 或者其他 docker 镜像管理平台, 获取可供使用的镜像地址

- 修改 `deployment.yaml`, 重新 `kubectl apply`


这一步, 敢不敢简单点? 敢!


## 使用 alibaba cloud toolkit 一键部署


[文档在此](https://help.aliyun.com/document_detail/162966.html "alibaba cloud toolkit")


![action > `deploy to kube` 快速打开](https://upload-images.jianshu.io/upload_images/567399-233d9ea7349da8ee.png?imageMogr2/auto-orient/strip%7CimageView2/2/w/1240)


[图片上传失败...(image-809730-1600257903272)]


[图片上传失败...(image-c93393-1600257903272)]


```sh

# 检查发布状态

➜ kubectl get deploy

NAME                        READY   UP-TO-DATE   AVAILABLE   AGE

go-app                      1/1     1            1           6h47m

➜ kubectl get replicasets

NAME                                  DESIRED   CURRENT   READY   AGE

go-app-6fd4487dd                      1         1         1       6h32m

➜  kubectl get pod

NAME                                        READY   STATUS             RESTARTS   AGE

go-app-6fd4487dd-d4rgv                      1/1     Running            0          6h31


# 暴露服务快速验证

kubectl expose deployment go-app --type=NodePort --name=go-app-svc --target-port=3000

➜ kubectl get svc

NAME                 TYPE        CLUSTER-IP      EXTERNAL-IP   PORT(S)          AGE

go-app-svc           NodePort    10.97.88.209    <none>        3000:32016/TCP   6h29m

```


PS: 仔细看一下 pod 的名字 `go-app-6fd4487dd-d4rgv`, 是不是理解了 `deployment replicaSet pod` 之间的联系?


## let's party with k8s


- 水平扩展/收缩


```sh

➜ kubectl get replicasets

NAME                DESIRED   CURRENT   READY   AGE

go-app-84f9f889c6   1         1         1       6s

➜ kubectl scale --replicas=3 deploy go-app --record

deployment.apps/go-app scaled

➜ kubectl get deploy

NAME     READY   UP-TO-DATE   AVAILABLE   AGE

go-app   3/3     3            3           31s

➜ kubectl get replicasets

NAME                DESIRED   CURRENT   READY   AGE

go-app-84f9f889c6   3         3         3       36s

➜ kubectl get pod

NAME                      READY   STATUS    RESTARTS   AGE

go-app-84f9f889c6-bx5cx   1/1     Running   0          40s

go-app-84f9f889c6-nlc4r   1/1     Running   0          13s

go-app-84f9f889c6-wd7k8   1/1     Running   0          13s

```


伸缩后, pod 新增了 2 个, replicaSet 名字没有变(水平伸缩还是使用当前 `版本`), deployment 名字也没有变


- 滚动更新


简单修改下代码, 使用 alibaba cloud toolkit 更新下


```go

func test(w http.ResponseWriter, r *http.Request) {

fmt.Fprintf(w, "<h1>test</h1>")

}

```


再次查看: deployment 没有变, replicaSet 新增, pod 更新为新的 3 个


```sh

➜ kubectl get deploy

NAME     READY   UP-TO-DATE   AVAILABLE   AGE

go-app   3/3     3            3           6m39s

➜ kubectl get replicasets

NAME                DESIRED   CURRENT   READY   AGE

go-app-5dd75d6f55   3         3         3       28s

go-app-84f9f889c6   0         0         0       6m46s

➜ kubectl get pod

NAME                      READY   STATUS    RESTARTS   AGE

go-app-5dd75d6f55-gkbp4   1/1     Running   0          31s

go-app-5dd75d6f55-m9w8d   1/1     Running   0          32s

go-app-5dd75d6f55-zl8g2   1/1     Running   0          33s

```


到这里, 也可以猜到, 如果回滚, 就是回到上一个 replicaSet


- 回滚: `kubectl rollout undo  deployment my-go-app --to-revision=1`


- 平滑重启


Deployment 会保证服务的连续性,确保滚动一定有 pod 可用, 从而保证服务可用, 这样就保证了服务能平滑更新


同时, 可以通过 deployment spec 来设置滚动更新策略:


```yaml

apiVersion: apps/v1

kind: Deployment

metadata:

 name: go-app

spec:

 replicas: 3

 strategy:

   type: RollingUpdate

   rollingUpdate:

     maxSurge: 1

     maxUnavailable: 1

```


## 写在最后


我是 dayday, 读书写作敲代码, 永远在路上


感谢 [网管叨bi叨 - #Kubernetes学习笔记](https://mp.weixin.qq.com/mp/appmsgalbum?__biz=MzUzNTY5MzU2MA==&action=getalbum&album_id=1394839706508148737&scene=173#wechat_redirect "网管叨bi叨 - #Kubernetes学习笔记")

相关实践学习
深入解析Docker容器化技术
Docker是一个开源的应用容器引擎,让开发者可以打包他们的应用以及依赖包到一个可移植的容器中,然后发布到任何流行的Linux机器上,也可以实现虚拟化,容器是完全使用沙箱机制,相互之间不会有任何接口。Docker是世界领先的软件容器平台。开发人员利用Docker可以消除协作编码时“在我的机器上可正常工作”的问题。运维人员利用Docker可以在隔离容器中并行运行和管理应用,获得更好的计算密度。企业利用Docker可以构建敏捷的软件交付管道,以更快的速度、更高的安全性和可靠的信誉为Linux和Windows Server应用发布新功能。 在本套课程中,我们将全面的讲解Docker技术栈,从环境安装到容器、镜像操作以及生产环境如何部署开发的微服务应用。本课程由黑马程序员提供。 &nbsp; &nbsp; 相关的阿里云产品:容器服务 ACK 容器服务 Kubernetes 版(简称 ACK)提供高性能可伸缩的容器应用管理能力,支持企业级容器化应用的全生命周期管理。整合阿里云虚拟化、存储、网络和安全能力,打造云端最佳容器化应用运行环境。 了解产品详情: https://www.aliyun.com/product/kubernetes
目录
相关文章
|
8月前
|
Linux Go iOS开发
Go语言100个实战案例-进阶与部署篇:使用Go打包生成可执行文件
本文详解Go语言打包与跨平台编译技巧,涵盖`go build`命令、多平台构建、二进制优化及资源嵌入(embed),助你将项目编译为无依赖的独立可执行文件,轻松实现高效分发与部署。
1332 162
|
8月前
|
存储 前端开发 JavaScript
Go语言实战案例-项目实战篇:编写一个轻量级在线聊天室
本文介绍如何用Go语言从零实现一个轻量级在线聊天室,基于WebSocket实现实时通信,支持多人消息广播。涵盖前后端开发、技术选型与功能扩展,助你掌握Go高并发与实时通信核心技术。
888 158
|
9月前
|
数据采集 数据挖掘 测试技术
Go与Python爬虫实战对比:从开发效率到性能瓶颈的深度解析
本文对比了Python与Go在爬虫开发中的特点。Python凭借Scrapy等框架在开发效率和易用性上占优,适合快速开发与中小型项目;而Go凭借高并发和高性能优势,适用于大规模、长期运行的爬虫服务。文章通过代码示例和性能测试,分析了两者在并发能力、错误处理、部署维护等方面的差异,并探讨了未来融合发展的趋势。
936 0
|
9月前
|
存储 人工智能 Go
Go-Zero全流程实战即时通讯
Go-Zero 是一个功能丰富的微服务框架,适用于开发高性能的即时通讯应用。它具备中间件、工具库和代码生成器,简化开发流程。本文介绍其环境搭建、项目初始化及即时通讯功能实现,涵盖用户认证、消息收发和实时推送,帮助开发者快速上手。
515 0
|
9月前
|
数据采集 Go API
Go语言实战案例:使用context控制协程取消
本文详解 Go 语言中 `context` 包的使用,通过实际案例演示如何利用 `context` 控制协程的生命周期,实现任务取消、超时控制及优雅退出,提升并发程序的稳定性与资源管理能力。
489 152
|
9月前
|
负载均衡 监控 Java
微服务稳定性三板斧:熔断、限流与负载均衡全面解析(附 Hystrix-Go 实战代码)
在微服务架构中,高可用与稳定性至关重要。本文详解熔断、限流与负载均衡三大关键技术,结合API网关与Hystrix-Go实战,帮助构建健壮、弹性的微服务系统。
879 1
微服务稳定性三板斧:熔断、限流与负载均衡全面解析(附 Hystrix-Go 实战代码)
|
9月前
|
安全 Go 开发者
Go语言实战案例:使用sync.Mutex实现资源加锁
在Go语言并发编程中,数据共享可能导致竞态条件,使用 `sync.Mutex` 可以有效避免这一问题。本文详细介绍了互斥锁的基本概念、加锁原理及实战应用,通过构建并发安全的计数器演示了加锁与未加锁的区别,并封装了一个线程安全的计数器结构。同时对比了Go中常见的同步机制,帮助开发者理解何时应使用 `Mutex` 及其注意事项。掌握 `Mutex` 是实现高效、安全并发编程的重要基础。
|
9月前
|
数据采集 Go API
Go语言实战案例:多协程并发下载网页内容
本文是《Go语言100个实战案例 · 网络与并发篇》第6篇,讲解如何使用 Goroutine 和 Channel 实现多协程并发抓取网页内容,提升网络请求效率。通过实战掌握高并发编程技巧,构建爬虫、内容聚合器等工具,涵盖 WaitGroup、超时控制、错误处理等核心知识点。
|
9月前
|
Go 开发者
Go语言实战案例:使用select监听多个channel
本文为《Go语言100个实战案例 · 网络与并发篇》第5篇,详解Go并发核心工具`select`的使用。通过实际案例讲解如何监听多个Channel、实现多任务处理、超时控制和非阻塞通信,帮助开发者掌握Go并发编程中的多路异步事件处理技巧。
|
9月前
|
数据采集 编解码 监控
Go语言实战案例:使用channel实现生产者消费者模型
本文是「Go语言100个实战案例 · 网络与并发篇」第4篇,通过实战案例详解使用 Channel 实现生产者-消费者模型,涵盖并发控制、任务调度及Go语言并发哲学,助你掌握优雅的并发编程技巧。

推荐镜像

更多