Kubernetes Controller选举机制简介
Kubernetes Controller选举机制是一种确保高可用性的关键技术，允许在多个运行实例中选出一个领导者（Leader），以确保同一时间只有一个实例执行任务。这在运行多个实例以实现高可用性的场景中尤为重要。
选举机制的实现原理
选举机制通常基于Kubernetes的API Server实现，通过特定的资源对象（如Endpoints或Leases）来协调。选举过程中，所有候选人（Candidate）会尝试获取或更新这些资源对象，成功者成为领导者。
代码示例
以下是使用client-go库在Kubernetes中实现Controller选举的简化代码示例：
go<button class="MuiButtonBase-root MuiButton-root MuiButton-text MuiButton-textPrimary MuiButton-sizeSmall MuiButton-textSizeSmall MuiButton-colorPrimary MuiButton-root MuiButton-text MuiButton-textPrimary MuiButton-sizeSmall MuiButton-textSizeSmall MuiButton-colorPrimary copyBtn___l3xJQ css-xox1ca" tabindex="0" type="button"></button>
package main
import (
"context"
"flag"
"fmt"
"time"
"github.com/go-logr/logr"
"github.com/go-logr/zapr"
"k8s.io/client-go/kubernetes"
"k8s.io/client-go/tools/leaderelection"
"github.com/kubernetes-sigs/controller-runtime/pkg/client/config"
"sigs.k8s.io/controller-runtime/pkg/manager"
)
func main() {
// 设置日志
log := zapr.NewLogger(zap.L())
// 获取Kubernetes配置
cfg, err := config.GetConfig()
if err != nil {
log.Error(err, "unable to get Kubernetes config")
return
}
// 创建Kubernetes客户端
client, err := kubernetes.NewForConfig(cfg)
if err != nil {
log.Error(err, "unable to create Kubernetes client")
return
}
// 设置选举参数
electionID := "my-controller-election"
leaseDuration, renewDeadline, retryPeriod := 10*time.Second, 5*time.Second, 2*time.Second
// 创建Manager
mgr, err := manager.New(cfg, manager.Options{
// 其他配置...
})
if err != nil {
log.Error(err, "unable to create manager")
return
}
// 启动选举
ctx, cancel := context.WithCancel(context.Background())
leaderElector, err := leaderelection.NewLeaderElector(leaderelection.LeaderElectionConfig{
Lock: &resourcelock.LeaseLock{
LeaseMeta: metav1.ObjectMeta{
Name: electionID,
Namespace: "default",
},
Client: client.CoordinationV1(),
LockConfig: resourcelock.ResourceLockConfig{
Identity: electionID,
},
},
LeaseDuration: leaseDuration,
RenewDeadline: renewDeadline,
RetryPeriod: retryPeriod,
Callbacks: leaderelection.LeaderCallbacks{
OnStartedLeading: func(ctx context.Context) {
fmt.Println("Start leading!")
// 在这里执行Controller的Run逻辑
},
OnStoppedLeading: func() {
fmt.Println("Stop leading!")
// 清理资源
cancel()
},
OnNewLeader: func(identity string) {
fmt.Printf("New leader elected: %s", identity)
},
},
})
if err != nil {
log.Error(err, "unable to create leader elector")
return
}
// 运行选举
go leaderElector.Run(ctx)
// 等待选举结束
<-ctx.Done()
}在上述代码中，我们首先设置了选举所需的参数，包括选举ID、租约持续时间、续约截止时间和重试周期。然后，我们创建了一个manager实例，并使用leaderelection.NewLeaderElector方法创建了一个选举器。在选举回调中，我们定义了当开始领导时和停止领导时的逻辑。
