Golang如何在Kubernetes中管理Deployment与ReplicaSet_Golang Kubernetes Deployment管理实践-Golang-PHP中文网

Golang如何在Kubernetes中管理Deployment与ReplicaSet_Golang Kubernetes Deployment管理实践

P粉602998670

发布： 2025-12-02 13:58:02

原创

412人浏览过

首先通过client-go配置集群访问凭证，使用kubeconfig或ServiceAccount获取config并创建clientset；接着定义Deployment对象，设置副本数、选择器和Pod模板，并调用Create方法提交至API Server；更新时修改Spec并调用Update触发滚动升级；通过List方法结合LabelSelector获取关联的ReplicaSet，查看其副本状态以判断缩容情况；利用Informer监听Deployment的Add和Update事件，实现对状态变化的实时响应；最终基于控制器模式构建自动化运维工具。

golang如何在kubernetes中管理deployment与replicaset_golang kubernetes deployment管理实践

在 Kubernetes 中，Deployment 和 ReplicaSet 是管理应用副本和滚动更新的核心控制器。使用 Golang 编写程序来管理这些资源，能实现自动化部署、状态监控与故障恢复。本文介绍如何通过 client-go 与 Kubernetes API 交互，完成对 Deployment 和其底层 ReplicaSet 的操作。

连接 Kubernetes 集群

使用 client-go 前需配置集群访问凭证。开发环境通常使用 kubeconfig 文件，生产环境推荐使用 Pod 内置 ServiceAccount。

clientset, err := kubernetes.NewForConfig(config) if err != nil { log.Fatal(err) }

config 可通过 rest.InClusterConfig()（Pod 内运行）或 clientcmd.BuildConfigFromFlags()（本地调试）获取。

创建与更新 Deployment

定义 Deployment 对象并提交至 API Server，可声明期望的 Pod 模板与副本数。

立即学习“go语言免费学习笔记（深入）”；

deployment := &appsv1.Deployment{ ObjectMeta: metav1.ObjectMeta{ Name: "my-app", Namespace: "default", }, Spec: appsv1.DeploymentSpec{ Replicas: int32Ptr(3), Selector: &metav1.LabelSelector{ MatchLabels: map[string]string{"app": "my-app"}, }, Template: v1.PodTemplateSpec{ ObjectMeta: metav1.ObjectMeta{ Labels: map[string]string{"app": "my-app"}, }, Spec: v1.PodSpec{ Containers: []v1.Container{{ Name: "web", Image: "nginx:latest", }}, }, }, }, } _, err := clientset.AppsV1().Deployments("default").Create( context.TODO(), deployment, metav1.CreateOptions{}) if err != nil { log.Fatal(err) }

更新 Deployment 时，修改其 Spec 并调用 Update 方法。Kubernetes 会自动触发滚动升级。

Otter.ai

一个自动的会议记录和笔记工具，会议内容生成和实时转录

查看详情

查看与管理 ReplicaSet

Deployment 控制器会自动生成 ReplicaSet 来管理 Pod 副本。可通过以下方式列出某 Deployment 关联的 ReplicaSet：

rsList, err := clientset.AppsV1().ReplicaSets("default").List( context.TODO(), metav1.ListOptions{ LabelSelector: "app=my-app", }) if err != nil { log.Fatal(err) } for _, rs := range rsList.Items { fmt.Printf("ReplicaSet: %s, Pods: %d\n", rs.Name, *rs.Spec.Replicas) }

旧的 ReplicaSet 保留用于回滚，可通过观察其 status.replicas 判断是否已缩容为 0。

监听 Deployment 状态变化

使用 Informer 监听 Deployment 事件，实现实时响应。

informerFactory := informers.NewSharedInformerFactory(clientset, 0) deploymentInformer := informerFactory.Apps().V1().Deployments().Informer() deploymentInformer.AddEventHandler(&cache.ResourceEventHandlerFuncs{ AddFunc: func(obj interface{}) { d := obj.(*appsv1.Deployment) log.Printf("Deployment added: %s", d.Name) }, UpdateFunc: func(old, new interface{}) { newD := new.(*appsv1.Deployment) log.Printf("Deployment updated: %s", newD.Name) }, }) informerFactory.Start(wait.NeverStop) informerFactory.WaitForCacheSync(wait.NeverStop)

Informer 减少轮询开销，适合长期运行的控制器或监控服务。

基本上就这些。掌握 client-go 的基本用法后，可以构建更复杂的 Operator 或 CI/CD 集成工具。关键在于理解控制器模式与资源生命周期。

以上就是Golang如何在Kubernetes中管理Deployment与ReplicaSet_Golang Kubernetes Deployment管理实践的详细内容，更多请关注php中文网其它相关文章！