client-go實戰之六:時隔兩年，重新整理版本繼續實戰
2023-10-09 21:01:47
歡迎存取我的GitHub
這裡分類和彙總了欣宸的全部原創(含配套原始碼)：https://github.com/zq2599/blog_demos
時隔兩年，《client-go實戰》被啟用，更多內容將會繼續更新
- 時間過得真快，《client-go實戰》系列已是兩年前的作品，近期工作中再次用到client-go時，突然發現自己原創的內容遠達不到工作要求（入門級，讓您見笑了），於是打算繼續更新此係列文章，重點是實用性和理解深度，既為自己補全短板，也為有同樣需要的讀者提供更多參考
本篇概覽
- 本篇的作用是為後續實戰準備環境，主要有以下內容
- 安裝kubernetes
- 本地安裝輔助工具kubectl
- 確定client-go的版本
- 寫個helloworld程式驗證基本功能
版本資訊
- 這裡列舉出實戰中各軟體的版本情況，供您參考
- go：1.19.3
- kubernetes：1.22.8
- client-go：v0.22.8
- 開發環境：MacBook Pro 14寸(M1 Pro晶片)，macOS Ventura 13.1
安裝kubernetes
- 接下來的實戰中，我安裝的kubernetes版本是v1.22.8，選此版本的原因很簡單：之前寫過《快速搭建雲原生開發環境（k8s+pv+prometheus+grafana）》，按照這篇文章操作，幾分鐘就能成功部署v1.22.8的kubernetes
- 本次實戰中，我的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官方說明，如下圖
- 簡單解釋一下如何確定版本
- client-go的版本一共有兩類：舊版的kubernetes-1.x.y和新版v0.x.y
- 如果kubernetes版本大於或等於1.17.0，client-go版本請選擇新版，舉例：如果kubernetes版本是1.20.4，client-go版本就是v0.20.4
- 如果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/[email protected]
go get k8s.io/client-go/[email protected]
go get k8s.io/client-go/tools/[email protected]
go get k8s.io/client-go/[email protected]
- 新建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