当前位置：首页 > 文章列表 > Golang > Go教程 > Golang实现K8sStatefulSet管理实践

Golang实现K8sStatefulSet管理实践

2026-01-04 21:56:45 0浏览收藏

学习Golang要努力，但是不要急！今天的这篇文章《Golang在K8s中管理StatefulSet实践》将会介绍到等等知识点，如果你想深入学习Golang，可以关注我！我会持续更新相关文章的，希望对大家都能有所帮助！

使用Golang通过client-go可高效管理Kubernetes StatefulSet，1. 利用client-go列出、创建、更新StatefulSet；2. 使用Informer监听增删改事件以实时响应；3. 借助controller-runtime构建Operator实现自动化控制，适用于数据库等有状态应用的精细化管理。

Golang如何在Kubernetes中管理StatefulSet_Golang Kubernetes StatefulSet管理实践

在 Kubernetes 中管理 StatefulSet 是处理有状态应用的关键方式，而使用 Golang 编写控制器或操作逻辑可以实现对 StatefulSet 的精细化控制。Golang 作为 Kubernetes 原生开发语言，具备丰富的客户端库和良好的生态支持，非常适合用于构建自定义的 StatefulSet 管理工具或 Operator。

使用 client-go 操作 StatefulSet

要通过 Golang 管理 StatefulSet，最常用的方式是使用 client-go 库，它是 Kubernetes 官方提供的 Go 客户端库。

安装依赖：

go get k8s.io/client-go/kubernetes go get k8s.io/client-go/rest

基本代码示例：列出集群中所有 StatefulSet

package main import ( "context" "fmt" "log" "k8s.io/client-go/kubernetes" "k8s.io/client-go/rest" appsv1 "k8s.io/api/apps/v1" ) func main() { config, err := rest.InClusterConfig() if err != nil { log.Fatal(err) } clientset, err := kubernetes.NewForConfig(config) if err != nil { log.Fatal(err) } statefulSets, err := clientset.AppsV1().StatefulSets("").List(context.TODO(), metav1.ListOptions{}) if err != nil { log.Fatal(err) } for _, sts := range statefulSets.Items { fmt.Printf("Namespace: %s, Name: %s, Replicas: %d\n", sts.Namespace, sts.Name, *sts.Spec.Replicas) } }

创建和更新 StatefulSet

你可以通过 Golang 构造 StatefulSet 对象并提交到集群。

示例：创建一个简单的 StatefulSet

import ( "context" "k8s.io/api/apps/v1" corev1 "k8s.io/api/core/v1" metav1 "k8s.io/apimachinery/pkg/apis/meta/v1" ) statefulSet := &v1.StatefulSet{ ObjectMeta: metav1.ObjectMeta{ Name: "web", Namespace: "default", }, Spec: v1.StatefulSetSpec{ ServiceName: "nginx", Replicas: int32Ptr(3), Selector: &metav1.LabelSelector{ MatchLabels: map[string]string{"app": "nginx"}, }, Template: corev1.PodTemplateSpec{ ObjectMeta: metav1.ObjectMeta{ Labels: map[string]string{"app": "nginx"}, }, Spec: corev1.PodSpec{ Containers: []corev1.Container{ { Name: "nginx", Image: "nginx:latest", Ports: []corev1.ContainerPort{ {ContainerPort: 80}, }, }, }, }, }, }, } _, err := clientset.AppsV1().StatefulSets("default").Create( context.TODO(), statefulSet, metav1.CreateOptions{}) if err != nil { log.Fatal(err) }

注意：int32Ptr 是一个辅助函数，用于将 int32 值转为指针。

func int32Ptr(i int32) *int32 { return &i }

监听 StatefulSet 状态变化（Informer）

对于需要实时响应 StatefulSet 变化的场景，可以使用 Informer 机制减少轮询开销。

示例：监听 StatefulSet 的添加、更新、删除事件

informers := informers.NewSharedInformerFactory(clientset, time.Minute*30) stsInformer := informers.Apps().V1().StatefulSets().Informer() stsInformer.AddEventHandler(&cache.ResourceEventHandlerFuncs{ AddFunc: func(obj interface{}) { sts := obj.(*v1.StatefulSet) fmt.Printf("StatefulSet 添加: %s/%s\n", sts.Namespace, sts.Name) }, UpdateFunc: func(old, new interface{}) { newSts := new.(*v1.StatefulSet) fmt.Printf("StatefulSet 更新: %s/%s\n", newSts.Namespace, newSts.Name) }, DeleteFunc: func(obj interface{}) { sts := obj.(*v1.StatefulSet) fmt.Printf("StatefulSet 删除: %s/%s\n", sts.Namespace, sts.Name) }, }) // 启动 Informer stopCh := make(chan struct{}) defer close(stopCh) informers.Start(stopCh) informers.WaitForCacheSync(stopCh)