client-go實戰之六:時隔兩年，刷新版本繼續實戰

来源:https://www.cnblogs.com/bolingcavalry/archive/2023/10/09/17724713.html
-Advertisement-
Play Games

歡迎訪問我的GitHub 這裡分類和彙總了欣宸的全部原創(含配套源碼)：https://github.com/zq2599/blog_demos 時隔兩年，《client-go實戰》被激活，更多內容將會繼續更新 時間過得真快，《client-go實戰》系列已是兩年前的作品，近期工作中再次用到clie ...


歡迎訪問我的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/[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

歡迎關註博客園：程式員欣宸

學習路上，你不孤單，欣宸原創一路相伴...


您的分享是我們最大的動力!

-Advertisement-
Play Games
更多相關文章
  • Java網路編程基礎
    Java網路編程基於TCP/UDP協議的基礎之上，TCP/IP協議是一個協議簇。裡面包括很多協議的，UDP只是其中的一個， 之所以命名為TCP/IP協議，因為TCP、IP協議是兩個很重要的協議，就用他兩命名了。那麼首先我們先介紹一下TCP和UDP的特點： 1.TCP（Transmission Con ...
  • C++系列十：日常學習-範圍庫Ranges
    目錄前言介紹舉例： 前言 不錯麼 內容參考 https://zh.cppreference.com/w/cpp/ranges Chatjpt 總結註意點: 確保你的C++編譯器支持C++20標準 包含 ranges 頭文件 views的操作是惰性的，它們不會立即執行，而是在需要時計算。這意味著你可以 ...
  • 使用playwright爬取魔筆小說網站並下載輕小說資源
    一、安裝python 官網 下載python3.9及以上版本 二、安裝playwright playwright是微軟公司2020年初發佈的新一代自動化測試工具，相較於目前最常用的Selenium，它僅用一個API即可自動執行Chromium、Firefox、WebKit等主流瀏覽器自動化操作。 （ ...
  • Oracle和達夢：連接多行查詢結果
    Oracle和達夢：LISTAGG連接查詢結果 LISTAGG介紹 使用LISTAGG函數，您可以將多行數據連接成一個字元串，並指定分隔符進行分隔。這在需要將多行數據合併為單個字元串的情況下非常有用，例如將多個值合併為逗號分隔的列表。 函數介紹 LISTAGG(column, delimiter) ...
  • 91基於java的藥品藥店藥房信息系統設計與實現（配套lun文，PPT，可參考做畢業設計）
    基於java藥品藥店藥房信息系統設計與實現，可適用於藥店管理系統，藥店系統，藥品管理系統，藥店出入庫管理系統，藥店買藥，線上購買藥品系統，線上藥店管理系統，線上藥店系統，藥品信息管理系統，藥品入庫管理、藥品出庫管理,醫療管理系統,醫療系統等等 ...
  • Oracle和達夢：相似度函數：UTL
    Oracle和達夢的：相似度函數：UTL 函數：UTL_MATCH.edit_distance_similarity UTL_MATCH.edit_distance_similarity是Oracle資料庫中的一個函數，用於計算兩個字元串之間的相似度。它基於編輯距離演算法，該演算法用於衡量兩個字元串之間 ...
  • SSM，Spring Boot和Redis學習中出錯的問題
    1. Spring 1.1 Spring事務 事務隔離級別是資料庫自帶的，與Spring無關 √ Spring自己實現了一套與資料庫無關的事務機制 × @Transactional註解主要是針對數據的增加、修改、刪除和查詢進行事務管理 × 1.2 Spring的Session會話 Session會話 ...
  • Go字元串實戰操作大全！
    在本篇文章中，我們深入探討了Go語言中字元串的魅力和深度。從基礎定義、操作、字元編碼到複雜的類型轉換，每個環節都帶有實例和代碼示例來深化理解。通過這些深入的解析，讀者不僅能夠掌握字元串在Go中的核心概念，還能洞察Go設計哲學背後的思考。 關註公眾號【TechLeadCloud】，分享互聯網架構、雲服 ...
一周排行
    -Advertisement-
    Play Games
  • 移動開發（一）：使用.NET MAUI開發第一個安卓APP
    移動開發（一）：使用.NET MAUI開發第一個安卓APP 對於工作多年的C#程式員來說，近來想嘗試開發一款安卓APP，考慮了很久最終選擇使用.NET MAUI這個微軟官方的框架來嘗試體驗開發安卓APP，畢竟是使用Visual Studio開發工具，使用起來也比較的順手，結合微軟官方的教程進行了安卓 ...
  • wpf ToggleButton選中效果和一個登錄界面
    前言 QuestPDF 是一個開源 .NET 庫，用於生成 PDF 文檔。使用了C# Fluent API方式可簡化開發、減少錯誤並提高工作效率。利用它可以輕鬆生成 PDF 報告、發票、導出文件等。 項目介紹 QuestPDF 是一個革命性的開源 .NET 庫，它徹底改變了我們生成 PDF 文檔的方 ...
  • 彈幕樹洞項目功能新增篇
    項目地址 項目後端地址： https://github.com/ZyPLJ/ZYTteeHole 項目前端頁面地址： ZyPLJ/TreeHoleVue (github.com) https://github.com/ZyPLJ/TreeHoleVue 目前項目測試訪問地址： http://tree ...
  • 第27篇 sqlserver2022詳細安裝步驟
    話不多說，直接開乾 一.下載 1.官方鏈接下載： https://www.microsoft.com/zh-cn/sql-server/sql-server-downloads 2.在下載目錄中找到下麵這個小的安裝包 SQL2022-SSEI-Dev.exe，運行開始下載SQL server； 二. ...
  • .NET 開源高性能 MQTT 類庫
    前言 隨著物聯網（IoT）技術的迅猛發展，MQTT（消息隊列遙測傳輸）協議憑藉其輕量級和高效性，已成為眾多物聯網應用的首選通信標準。 MQTTnet 作為一個高性能的 .NET 開源庫，為 .NET 平臺上的 MQTT 客戶端與伺服器開發提供了強大的支持。 本文將全面介紹 MQTTnet 的核心功能 ...
  • Serilog文檔翻譯系列（六） - 可用的接收器、增強器、格式化輸出
    Serilog支持多種接收器用於日誌存儲，增強器用於添加屬性，LogContext管理動態屬性，支持多種輸出格式包括純文本、JSON及ExpressionTemplate。還提供了自定義格式化選項，適用於不同需求。 ...
  • 警惕 Visual Studio 屬性求值副作用導致邏輯不符合預期
    目錄簡介獲取 HTML 文檔解析 HTML 文檔測試參考文章 簡介 動態內容網站使用 JavaScript 腳本動態檢索和渲染數據，爬取信息時需要模擬瀏覽器行為，否則獲取到的源碼基本是空的。 本文使用的爬取步驟如下： 使用 Selenium 獲取渲染後的 HTML 文檔 使用 HtmlAgility ...
  • [使用目前最新版]HybridCLR6.9.0+YooAsset2.2.4實現純C# Unity熱更新方案 (一)
    1.前言 什麼是熱更新 游戲或者軟體更新時，無需重新下載客戶端進行安裝，而是在應用程式啟動的情況下，在內部進行資源或者代碼更新 Unity目前常用熱更新解決方案 HybridCLR，Xlua，ILRuntime等 Unity目前常用資源管理解決方案 AssetBundles，Addressable， ...
  • 在 ASP.NET Core Web API 中使用操作篩選器統一處理通用操作
    本文章主要是在C# ASP.NET Core Web API框架實現向手機發送驗證碼簡訊功能。這裡我選擇是一個互億無線簡訊驗證碼平臺，其實像阿裡雲，騰訊雲上面也可以。 首先我們先去 互億無線 https://www.ihuyi.com/api/sms.html 去註冊一個賬號 註冊完成賬號後，它會送 ...
  • 第28篇 如何.net中實現高效可靠數據同步api
    通過以下方式可以高效，並保證數據同步的可靠性 1.API設計 使用RESTful設計，確保API端點明確，並使用適當的HTTP方法（如POST用於創建，PUT用於更新）。 設計清晰的請求和響應模型，以確保客戶端能夠理解預期格式。 2.數據驗證 在伺服器端進行嚴格的數據驗證，確保接收到的數據符合預期格 ...
所有分類