本篇实战中的源码可在GitHub下载到，地址和链接信息如下表所示(https://github.com/zq2599/blog_demos)：
名称 链接 备注项目主页 https://github.com/zq2599/blog_demos 该项目在GitHub上的主页
git仓库地址(https) https://github.com/zq2599/blog_demos.git 该项目源码的仓库地址，https协议
git仓库地址(ssh) git@github.com:zq2599/blog_demos.git 该项目源码的仓库地址，ssh协议
这个git项目中有多个文件夹，client-go相关的应用在client-go-tutorials文件夹下，如下图红框所示：
client-go-tutorials文件夹下有多个子文件夹，本篇对应的源码在clientsetdemo目录下，如下图红框所示：
新建文件夹restclientdemo，在里面执行以下命令，新建module：
go mod init clientsetdemo添加k8s.io/api和k8s.io/client-go这两个依赖，注意版本要匹配kubernetes环境：
go get k8s.io/api@v0.20.0 go get k8s.io/client-go@v0.20.0新建main.go，内容如下，已经都添加了详细的注释，就不赘述了：
package main import ( "context" "flag" "fmt" appsv1 "k8s.io/api/apps/v1" apiv1 "k8s.io/api/core/v1" metav1 "k8s.io/apimachinery/pkg/apis/meta/v1" "k8s.io/client-go/kubernetes" "k8s.io/client-go/tools/clientcmd" "k8s.io/client-go/util/homedir" "k8s.io/utils/pointer" "path/filepath" ) const ( NAMESPACE = "test-clientset" DEPLOYMENT_NAME = "client-test-deployment" SERVICE_NAME = "client-test-service" ) func main() { var kubeconfig *string // home是家目录，如果能取得家目录的值，就可以用来做默认值 if home:=homedir.HomeDir(); home != "" { // 如果输入了kubeconfig参数，该参数的值就是kubeconfig文件的绝对路径， // 如果没有输入kubeconfig参数，就用默认路径~/.kube/config kubeconfig = flag.String("kubeconfig", filepath.Join(home, ".kube", "config"), "(optional) absolute path to the kubeconfig file") } else { // 如果取不到当前用户的家目录，就没办法设置kubeconfig的默认目录了，只能从入参中取 kubeconfig = flag.String("kubeconfig", "", "absolute path to the kubeconfig file") } // 获取用户输入的操作类型，默认是create，还可以输入clean，用于清理所有资源 operate := flag.String("operate", "create", "operate type : create or clean") flag.Parse() // 从本机加载kubeconfig配置文件，因此第一个参数为空字符串 config, err := clientcmd.BuildConfigFromFlags("", *kubeconfig) // kubeconfig加载失败就直接退出了 if err != nil { panic(err.Error()) } // 实例化clientset对象 clientset, err := kubernetes.NewForConfig(config) if err!= nil { panic(err.Error()) } fmt.Printf("operation is %v\n", *operate) // 如果要执行清理操作 if "clean"==*operate { clean(clientset) } else { // 创建namespace createNamespace(clientset) // 创建deployment createDeployment(clientset) // 创建service createService(clientset) } } // 清理本次实战创建的所有资源 func clean(clientset *kubernetes.Clientset) { emptyDeleteOptions := metav1.DeleteOptions{} // 删除service if err := clientset.CoreV1().Services(NAMESPACE).Delete(context.TODO(), SERVICE_NAME, emptyDeleteOptions) ; err != nil { panic(err.Error()) } // 删除deployment if err := clientset.AppsV1().Deployments(NAMESPACE).Delete(context.TODO(), DEPLOYMENT_NAME, emptyDeleteOptions) ; err != nil { panic(err.Error()) } // 删除namespace if err := clientset.CoreV1().Namespaces().Delete(context.TODO(), NAMESPACE, emptyDeleteOptions) ; err != nil { panic(err.Error()) } } // 新建namespace func createNamespace(clientset *kubernetes.Clientset) { namespaceClient := clientset.CoreV1().Namespaces() namespace := &apiv1.Namespace{ ObjectMeta: metav1.ObjectMeta{ Name: NAMESPACE, }, } result, err := namespaceClient.Create(context.TODO(), namespace, metav1.CreateOptions{}) if err!=nil { panic(err.Error()) } fmt.Printf("Create namespace %s \n", result.GetName()) } // 新建service func createService(clientset *kubernetes.Clientset) { // 得到service的客户端 serviceClient := clientset.CoreV1().Services(NAMESPACE) // 实例化一个数据结构 service := &apiv1.Service{ ObjectMeta: metav1.ObjectMeta{ Name: SERVICE_NAME, }, Spec: apiv1.ServiceSpec{ Ports: []apiv1.ServicePort{{ Name: "http", Port: 8080, NodePort: 30080, }, }, Selector: map[string]string{ "app" : "tomcat", }, Type: apiv1.ServiceTypeNodePort, }, } result, err := serviceClient.Create(context.TODO(), service, metav1.CreateOptions{}) if err!=nil { panic(err.Error()) } fmt.Printf("Create service %s \n", result.GetName()) } // 新建deployment func createDeployment(clientset *kubernetes.Clientset) { // 得到deployment的客户端 deploymentClient := clientset. AppsV1(). Deployments(NAMESPACE) // 实例化一个数据结构 deployment := &appsv1.Deployment{ ObjectMeta: metav1.ObjectMeta{ Name: DEPLOYMENT_NAME, }, Spec: appsv1.DeploymentSpec{ Replicas: pointer.Int32Ptr(2), Selector: &metav1.LabelSelector{ MatchLabels: map[string]string{ "app" : "tomcat", }, }, Template: apiv1.PodTemplateSpec{ ObjectMeta:metav1.ObjectMeta{ Labels: map[string]string{ "app" : "tomcat", }, }, Spec: apiv1.PodSpec{ Containers: []apiv1.Container{ { Name: "tomcat", Image: "tomcat:8.0.18-jre8", ImagePullPolicy: "IfNotPresent", Ports: []apiv1.ContainerPort{ { Name: "http", Protocol: apiv1.ProtocolSCTP, ContainerPort: 8080, }, }, }, }, }, }, }, } result, err := deploymentClient.Create(context.TODO(), deployment, metav1.CreateOptions{}) if err!=nil { panic(err.Error()) } fmt.Printf("Create deployment %s \n", result.GetName()) } 数据结构初始化的烦恼