client-go实战之六:时隔两年,刷新版本继续实战

client,go,实战,时隔,两年,刷新,版本,继续 · 浏览次数 : 32

小编点评

There are 7 pods in the cluster0. pod name : coredns-78fcd69978-gvzh8Found pod coredns-78fcd69978-gvzh8 in namespace kube-system1. pod name : coredns-78fcd69978-xfftzFound pod coredns-78fcd69978-xfftz in namespace kube-system2. pod name : etcd-izwz9h7q9tnbtp2qnzu8przFound pod etcd-izwz9h7q9tnbtp2qnzu8prz in namespace kube-system3. pod name : kube-apiserver-izwz9h7q9tnbtp2qnzu8przFound pod kube-apiserver-izwz9h7q9tnbtp2qnzu8prz in namespace kube-system4. pod name : kube-controller-manager-izwz9h7q9tnbtp2qnzu8przFound pod kube-controller-manager-izwz9h7q9tnbtp2qnzu8prz in namespace kube-system5. pod name : kube-proxy-cqsgpFound pod kube-proxy-cqsgp in namespace kube-system6. pod name : kube-scheduler-izwz9h7q9tnbtp2qnzu8przFound pod kube-scheduler-izwz9h7q9tnbtp2qnzu8prz in namespace kube-system至此, new versions of client-go and new environment already prepare just ready, next we'll explore client-go welcome attention blog园:programmer欣宸学习路上,你不孤单,欣宸原创一路相伴...

正文

欢迎访问我的GitHub

这里分类和汇总了欣宸的全部原创(含配套源码):https://github.com/zq2599/blog_demos

时隔两年,《client-go实战》被激活,更多内容将会继续更新

  • 时间过得真快,《client-go实战》系列已是两年前的作品,近期工作中再次用到client-go时,突然发现自己原创的内容远达不到工作要求(入门级,让您见笑了),于是打算继续更新此系列文章,重点是实用性和理解深度,既为自己补全短板,也为有同样需要的读者提供更多参考

本篇概览

  • 本篇的作用是为后续实战准备环境,主要有以下内容
  1. 安装kubernetes
  2. 本地安装辅助工具kubectl
  3. 确定client-go的版本
  4. 写个helloworld程序验证基本功能

版本信息

  • 这里列举出实战中各软件的版本情况,供您参考
  1. go:1.19.3
  2. kubernetes:1.22.8
  3. client-go:v0.22.8
  4. 开发环境:MacBook Pro 14寸(M1 Pro芯片),macOS Ventura 13.1

安装kubernetes

本地安装辅助工具kubectl

  • 如果想在本地远程操作kubernetes,除了ssh登录到kubernetes所在服务器,还可以在本地安装kubectl工具,这样就不用远程ssh登录服务器了
  • 针对M1芯片的MacBook,执行以下命令即可安装kubectl
curl -LO "https://dl.k8s.io/release/v1.22.8/bin/darwin/arm64/kubectl" \
&& chmod +x ./kubectl \
&& sudo mv ./kubectl /usr/local/bin/kubectl \
&& sudo chown root: /usr/local/bin/kubectl
  • 对于其他类型的电脑和其他版本的kubernetes,只需要修改下载路径中的参数即可,详细的参数请参考kubernetes官方文档
  • 执行kubectl version --client命令验证,如果安装成功则响应如下
➜  ~ kubectl version --client
Client Version: version.Info{Major:"1", Minor:"22", GitVersion:"v1.22.8", GitCommit:"7061dbbf75f9f82e8ab21f9be7e8ffcaae8e0d44", GitTreeState:"clean", BuildDate:"2022-03-16T14:10:06Z", GoVersion:"go1.16.15", Compiler:"gc", Platform:"darwin/arm64"}
  • 现在虽然kubectl安装成功,但还不能远程连接kubernetes,咱们需要把配置文件搞到手

  • 登录kubernetes所在服务器,在~/.kube/目录下有个config文件,将其下载下来,放在本机的~/.kube/目录下(没有目录就新建)

  • 另外还要注意:如果您的kubernetes环境部署在阿里云,那么服务器可能有多个IP,此时x509证书上如果没有外网IP,那么在本地是无法用kubectl连接这个kubernetes的,需要把外网IP添加到证书上去,具体方法就不在本篇展开了,可以参考这位大佬的文章:https://blog.csdn.net/lwlfox/article/details/122718568

  • 现在,在本机执行kubectl命令就能访问远程kubernetes环境了

➜  ~ kubectl get pod -A
NAMESPACE          NAME                                              READY   STATUS    RESTARTS   AGE
calico-apiserver   calico-apiserver-bf576f79d-ljtst                  1/1     Running   0          105m
calico-apiserver   calico-apiserver-bf576f79d-tmmxm                  1/1     Running   0          105m
calico-system      calico-kube-controllers-78687bb75f-86nm6          1/1     Running   0          106m
calico-system      calico-node-njxv4                                 1/1     Running   0          106m
calico-system      calico-typha-59df5f67b9-hmngq                     1/1     Running   0          106m
calico-system      csi-node-driver-5l6nk                             2/2     Running   0          106m
kube-system        coredns-78fcd69978-gvzh8                          1/1     Running   0          106m
kube-system        coredns-78fcd69978-xfftz                          1/1     Running   0          106m
kube-system        etcd-izwz9h7q9tnbtp2qnzu8prz                      1/1     Running   0          107m
kube-system        kube-apiserver-izwz9h7q9tnbtp2qnzu8prz            1/1     Running   0          107m
kube-system        kube-controller-manager-izwz9h7q9tnbtp2qnzu8prz   1/1     Running   0          107m
kube-system        kube-proxy-cqsgp                                  1/1     Running   0          106m
kube-system        kube-scheduler-izwz9h7q9tnbtp2qnzu8prz            1/1     Running   0          107m
tigera-operator    tigera-operator-6f669b6c4f-7tssg                  1/1     Running   0          106m

选择版本

  • 在确定了kubernetes版本后如何确定client-go的版本呢?来看client-go官方说明,如下图
    在这里插入图片描述
  • 简单解释一下如何确定版本
  1. client-go的版本一共有两类:旧版的kubernetes-1.x.y和新版v0.x.y
  2. 如果kubernetes版本大于或等于1.17.0,client-go版本请选择新版,举例:如果kubernetes版本是1.20.4,client-go版本就是v0.20.4
  3. 如果kubernetes版本小于1.17.0,client-go版本请选择旧版,举例:如果kubernetes版本是1.20.4,client-go版本就是kubernetes-1.16.3
  • 综上所述,《client-go实战》系列接下来的文章,都会使用:kubernetes:1.22.8和client-go:v0.22.8的组合

helloworld应用的运行和部署方式

  • 接下来新建一个helloworld应用,试试client-go的基本功能是否正常
  • 为了简单省事儿,这个helloworld应用就不要部署在kubernetes缓解了,直接在vscode上运行即可,远程访问kubernetes环境

开发helloworld应用

  • 新建名为basic的目录,进入此目录
  • 创建一个go项目,执行go mod init basic
  • 下载client-go依赖并指定版本
go get k8s.io/client-go@v0.22.8
go get k8s.io/client-go/rest@v0.22.8
go get k8s.io/client-go/tools/clientcmd@v0.22.8
go get k8s.io/client-go/discovery@v0.22.8
  • 新建main.go文件,内容如下
package main

import (
	"context"
	"flag"
	"fmt"
	"path/filepath"

	"k8s.io/apimachinery/pkg/api/errors"
	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"
)

func main() {
	var kubeconfig *string

	// 试图取到当前账号的家目录
	if home := homedir.HomeDir(); home != "" {
		// 如果能取到,就把家目录下的.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")
	}
	flag.Parse()

	// 加载配置文件
	config, err := clientcmd.BuildConfigFromFlags("", *kubeconfig)
	if err != nil {
		panic(err.Error())
	}

	// 用clientset类来执行后续的查询操作
	clientset, err := kubernetes.NewForConfig(config)
	if err != nil {
		panic(err.Error())
	}

	namespace := "kube-system"

	// 查询pod列表
	pods, err := clientset.CoreV1().Pods(namespace).List(context.TODO(), metav1.ListOptions{})
	if err != nil {
		panic(err.Error())
	}

	nums := len(pods.Items)

	fmt.Printf("There are %d pods in the cluster\n", nums)

	// 如果没有pod就返回了
	if nums < 1 {
		return
	}

	// 遍历列表中的每个pod
	for index, pod := range pods.Items {
		fmt.Printf("%v. pod name : %v\n", index, pod.Name)

		// 用pod name精确搜索单个pod
		podObj, err := clientset.CoreV1().Pods(namespace).Get(context.TODO(), pod.Name, metav1.GetOptions{})
		if errors.IsNotFound(err) {
			fmt.Printf("Pod %s in namespace %s not found\n", pod.Name, namespace)
		} else if statusError, isStatus := err.(*errors.StatusError); isStatus {
			fmt.Printf("Error getting pod %s in namespace %s: %v\n",
				pod.Name, namespace, statusError.ErrStatus.Message)
		} else if err != nil {
			panic(err.Error())
		} else {
			fmt.Printf("Found pod %s in namespace %s\n", podObj.Name, namespace)
		}
	}

}
  • 由于config文件之前已经存放在当前电脑的~/.kube/目录下,因此无需任何额外参数,直接在vscode上运行main方法即可,控制台输出如下,可见client-go可以正常访问kubernetes,接下来的实战也能顺利展开了
There are 7 pods in the cluster
0. pod name : coredns-78fcd69978-gvzh8
Found pod coredns-78fcd69978-gvzh8 in namespace kube-system
1. pod name : coredns-78fcd69978-xfftz
Found pod coredns-78fcd69978-xfftz in namespace kube-system
2. pod name : etcd-izwz9h7q9tnbtp2qnzu8prz
Found pod etcd-izwz9h7q9tnbtp2qnzu8prz in namespace kube-system
3. pod name : kube-apiserver-izwz9h7q9tnbtp2qnzu8prz
Found pod kube-apiserver-izwz9h7q9tnbtp2qnzu8prz in namespace kube-system
4. pod name : kube-controller-manager-izwz9h7q9tnbtp2qnzu8prz
Found pod kube-controller-manager-izwz9h7q9tnbtp2qnzu8prz in namespace kube-system
5. pod name : kube-proxy-cqsgp
Found pod kube-proxy-cqsgp in namespace kube-system
6. pod name : kube-scheduler-izwz9h7q9tnbtp2qnzu8prz
Found pod kube-scheduler-izwz9h7q9tnbtp2qnzu8prz in namespace kube-system
  • 至此,新版本的client-go和新环境都已经准备就绪,接下来咱们一起深入探索client-go

欢迎关注博客园:程序员欣宸

学习路上,你不孤单,欣宸原创一路相伴...

与client-go实战之六:时隔两年,刷新版本继续实战相似的内容:

client-go实战之六:时隔两年,刷新版本继续实战

欢迎访问我的GitHub 这里分类和汇总了欣宸的全部原创(含配套源码):https://github.com/zq2599/blog_demos 时隔两年,《client-go实战》被激活,更多内容将会继续更新 时间过得真快,《client-go实战》系列已是两年前的作品,近期工作中再次用到clie

containerd 源码分析:创建 container(三)

文接 containerd 源码分析:创建 container(二) 1.2.2.2 启动 task 上节介绍了创建 task,task 创建之后将返回 response 给 ctr。接着,ctr 调用 task.Start 启动容器。 // containerd/client/task.go fu

go使用 github.com/influxdata/influxdb/client/v2 写数据到 influxdb

转载请注明出处: 接入示例 使用 github.com/influxdata/influxdb/client/v2 依赖包向 InfluxDB 写入数据的示例代码: package main import ( "fmt" "log" "time" "github.com/influxdata/inf

【Azure Developer】Go语言调用Azure SDK如何登录到中国区Azure环境

问题描述 在 “使用 Azure SDK for Go 进行 Azure 身份验证” 文章中的 Go 示例代码进行登录Azure时,默认指向的是Globa Azure。当只修改AAD AZURE_CLIENT_ID , AZURE_TENANT_ID 和 AZURE_CLIENT_SECRET参数值

[转帖]Docker方式安装ZabbixServer/Agent及Grafana

https://www.jianshu.com/p/055a3cf63233 安装环境 [root@master0 ~]# docker version Client: Version: 17.12.0-ce API version: 1.35 Go version: go1.9.2 Git com

oidc-client.js踩坑吐槽贴

前言 前面选用了IdentityServer4做为认证授权的基础框架,感兴趣的可以看上篇<微服务下认证授权框架的探讨>,已经初步完成了authorization-code与implicit的简易demo(html+js 在IIS部署的站点),并实现了SSO,本想着将Demo迁移到vue工程是轻而易举

[转帖]MinIO Client(mc)完全指南

https://www.cnblogs.com/lvzhenjiang/p/14944821.html 目录 一、获取MinIO Client(mc) 1.1 docker版 1.2 Homebrew (macOS) 1.3 下载二进制文件(GNU/Linux) 1.4 下载二进制文件(Micros

[转帖]MinIO Client(mc)完全指南

https://www.cnblogs.com/lvzhenjiang/p/14944821.html 目录 一、获取MinIO Client(mc) 1.1 docker版 1.2 Homebrew (macOS) 1.3 下载二进制文件(GNU/Linux) 1.4 下载二进制文件(Micros

从 Pulsar Client 的原理到它的监控面板

![image.png](https://s2.loli.net/2023/08/02/GipDPSlbycQxqFd.png) # 背景 前段时间业务团队偶尔会碰到一些 Pulsar 使用的问题,比如消息阻塞不消费了、生产者消息发送缓慢等各种问题。 虽然我们有个监控页面可以根据 topic 维度查

[转帖]为什么redis的SDS的最大长度限制为512mb?

当客户端操作 client 时,一般不会直接使用 sds ,而是通过对象的方式来使用。比如创建的字符串其实是一个对象,间接使用到了 sds 结构。限制 512M 的逻辑在 t_string.c 的 checkStringLength 方法。 在redis3.2.13、redis4.0.14、redi