Redmi Pad評測：紅米充滿野心的一次嘗試
從Note系列到K系列，從藍牙耳機到筆記本電腦，紅米不知不覺之間也已經形成了自己頗有競爭力的產品體系，在中端和次旗艦市場上甚至要比小米新機的表現來得更好，正所謂“大丈夫生居
在分布式系統中，應用服務常常會通過多個節點（或實例）的方式來保證高可用。然而在某些場景下，有些數據或者任務無法被并行操作，此時就需要由一個特定的節點來執行這些特殊的任務（或者進行協調及決策），這個特定的節點也就是領導者（Leader），而在多個節點中選擇領導者的機制也就是分布式選主（Leader Election）。
如今諸多知名項目也都使用了分布式選主，例如：
常用算法包括：
在 Kubernetes 中，諸如 kube-scheduler 和 kube-controller-manager 等核心組件也需要使用分布式選主，因為其需要確保任一時刻只有一個調度器在做出調度決策，同一時間只有一個控制管理器在處理資源對象。
然而，除了核心組件，用戶的應用服務很可能也有類似分布式選主的需求，為了滿足這種通用需求，kubernetes 提供了 Lease（翻譯為“租約”）這樣一個特殊的資源對象。
如上圖所示，在 k8s 中選主是通過爭搶一個分布式鎖（Lease）來實現的，搶到鎖的實例成為 leader，為了確認自己持續存活，leader 需要不斷的續簽這個鎖（Lease），一旦 leader 掛掉，則鎖被釋放，其他候選人便可以競爭成為新的 leader。
Lease 的結構也很簡單：
apiVersion: coordination.k8s.io/v1kind: Leasemetadata: # objectspec: acquireTime: # 當前租約被獲取的時間 holderIdentity: # 當前租約持有者的身份信息 leaseDurationSeconds: # 租約候選者需要等待才能強制獲取它的持續時間 leaseTransitions: # 租約換了多少次持有者 renewTime: # 當前租約持有者最后一次更新租約的時間Lease 本質上與其它資源并無區別，除了 Lease，其實也可以用 configmap 或者 endpoint 作為分布式鎖，因為在底層都是 k8s 通過資源對象的 resourceVersion 字段進行 compare-and-swap，也就是通過這個字段實現的樂觀鎖。當然在實際使用中，建議還是用 Lease。
使用 Lease 進行分布式選主的示例如下：
import ( "context" "time" "k8s.io/client-go/kubernetes" "k8s.io/client-go/rest" "k8s.io/client-go/tools/leaderelection" "k8s.io/client-go/tools/leaderelection/resourcelock")func main() { config, err := rest.InClusterConfig() if err != nil { panic(err.Error()) } clientset, err := kubernetes.NewForConfig(config) if err != nil { panic(err.Error()) } // 配置 Lease 參數 leaseLock := &resourcelock.LeaseLock{ LeaseMeta: metav1.ObjectMeta{ Name: "my-lease", Namespace: "default", }, Client: clientset.CoordinationV1(), LockConfig: resourcelock.ResourceLockConfig{ Identity: "my-identity", }, } // 配置 Leader Election leaderElectionConfig := leaderelection.LeaderElectionConfig{ Lock: leaseLock, LeaseDuration: 15 * time.Second, RenewDeadline: 10 * time.Second, RetryPeriod: 2 * time.Second, Callbacks: leaderelection.LeaderCallbacks{ OnStartedLeading: func(ctx context.Context) { // 當前實例成為 Leader // 在這里執行 Leader 專屬的邏輯 }, OnStoppedLeading: func() { // 當前實例失去 Leader 地位 // 可以在這里執行清理工作 }, OnNewLeader: func(identity string) { // 有新的 Leader 產生 } }, } leaderElector, err := leaderelection.NewLeaderElector(leaderElectionConfig) if err != nil { panic(err.Error()) } // 開始 Leader Election ctx := context.Background() leaderElector.Run(ctx)}參考資料：
本文鏈接：http://www.www897cc.com/showinfo-26-55040-0.htmlKubernetes Lease 及分布式選主
聲明：本網頁內容旨在傳播知識，若有侵權等問題請及時與本網聯系，我們將在第一時間刪除處理。郵件：2376512515@qq.com
Copyright ? 2016-2023 天津谷騏科技有限公司 版權所有 sitemap.xml
違法及侵權請聯系：2376512515@qq.com 津ICP備18001702號
津公網安備 12010102000574號