使用Golang通过client-go与Kubernetes交互，实现Deployment和服务的创建。首先配置环境并引入client-go依赖，接着加载kubeconfig认证信息并构建客户端连接。然后调用AppsV1 API创建含两个副本的Deployment，定义Pod模板及容器镜像。随后创建LoadBalancer类型的Service，将应用暴露到外部网络。最后在主函数中依次执行客户端初始化、资源创建操作，完成自动化部署。该方法适用于CI/CD集成与自研平台开发，需注意权限控制与错误处理。
使用Golang集成Kubernetes进行服务部署，核心是通过Kubernetes官方提供的Go客户端库——client-go，与集群API交互，实现创建、更新、删除Deployment、Service等资源。整个过程包括配置认证、编写代码调用API、处理响应等步骤。
1. 准备环境和依赖
确保本地或运行环境中具备以下条件：
- Kubernetes集群正在运行（如Minikube、Kind、云厂商托管集群）
-
kubectl已配置并能正常访问集群 - Go开发环境已安装（建议1.18+）
初始化Go模块并引入 client-go：
go mod init k8s-deployergo get k8s.io/client-go/kubernetes
go get k8s.io/client-go/tools/clientcmd
2. 配置Kubernetes客户端
程序需要获取访问集群的凭证。通常从~/.kube/config读取，生产环境可使用ServiceAccount挂载的Token。
立即学习“go语言免费学习笔记（深入）”；
示例代码加载配置并创建客户端：
3. 创建Deployment部署服务
通过调用AppsV1 API创建Deployment，定义Pod模板、副本数、容器镜像等。
import "k8s.io/api/apps/v1" import metav1 "k8s.io/apimachinery/pkg/apis/meta/v1" func createDeployment(clientset *kubernetes.Clientset) error { deployment := &v1.Deployment{ ObjectMeta: metav1.ObjectMeta{ Name: "demo-app", Labels: map[string]string{ "app": "demo", }, }, Spec: v1.DeploymentSpec{ Replicas: int32Ptr(2), Selector: &metav1.LabelSelector{ MatchLabels: map[string]string{"app": "demo"}, }, Template: corev1.PodTemplateSpec{ ObjectMeta: metav1.ObjectMeta{ Labels: map[string]string{"app": "demo"}, }, Spec: corev1.PodSpec{ Containers: []corev1.Container{ { Name: "web", Image: "nginx:latest", Ports: []corev1.ContainerPort{ {ContainerPort: 80}, }, }, }, }, }, }, } _, err := clientset.AppsV1().Deployments("default").Create( context.TODO(), deployment, metav1.CreateOptions{}, ) return err } func int32Ptr(i int32) *int32 { return &i }4. 暴露服务（Service）
创建Service将Deployment暴露为网络端点，支持ClusterIP、NodePort或LoadBalancer类型。
import corev1 "k8s.io/api/core/v1" func createService(clientset *kubernetes.Clientset) error { service := &corev1.Service{ ObjectMeta: metav1.ObjectMeta{ Name: "demo-service", }, Spec: corev1.ServiceSpec{ Selector: map[string]string{"app": "demo"}, Ports: []corev1.ServicePort{ { Protocol: corev1.ProtocolTCP, Port: 80, TargetPort: intstr.IntOrString{IntVal: 80}, }, }, Type: corev1.ServiceTypeLoadBalancer, }, } _, err := clientset.CoreV1().Services("default").Create( context.TODO(), service, metav1.CreateOptions{}, ) return err }主函数中依次调用：
func main() { clientset, err := getClientset() if err != nil { panic(err) } if err := createDeployment(clientset); err != nil { panic(err) } if err := createService(clientset); err != nil { panic(err) } fmt.Println("Deployment and Service created.") }运行后，执行kubectl get pods,svc 可看到新部署的服务。
基本上就这些。通过Golang调用client-go，你可以把Kubernetes部署流程嵌入CI/CD工具、自研平台或自动化脚本中，实现灵活控制。注意权限管理（RBAC）、错误重试和日志记录在实际项目中必不可少。
