Kubernetes Operator开发模式与控制器运行时深度实践：从client-go到Kubebuilder/Operator SDK的声明式编排

Kubebuilder：一站式的Operator开发框架

Kubebuilder是SIG-Apimachinery主导的Operator开发脚手架，基于controller-runtime库，自动生成CRD定义、控制器代码模板、Webhook骨架和RBAC权限：

# 初始化Kubebuilder项目
kubebuilder init --domain mycompany.com --repo github.com/myorg/myapp-operator

# 创建API（CRD+Controller）
kubebuilder create api --group apps --version v1alpha1 --kind MyApp
# 生成：api/v1alpha1/myapp_types.go (Go结构体，即CRD的Schema)
#       controllers/myapp_controller.go (协调逻辑骨架)

# 实现核心：编辑api/v1alpha1/myapp_types.go定义Spec/Status
type MyAppSpec struct {
    Replicas int32  json:"replicas"
    Image    string json:"image"
    // ...
}
type MyAppStatus struct {
    ReadyReplicas int32 json:"readyReplicas"
    Conditions    []metav1.Condition json:"conditions"
}

// 实现controllers/myapp_controller.go的Reconcile方法
func (r *MyAppReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error) {
    // 读取MyApp资源
    myApp := &appsv1alpha1.MyApp{}
    if err := r.Get(ctx, req.NamespacedName, myApp); err != nil {
        return ctrl.Result{}, client.IgnoreNotFound(err)
    }
    
    // 协调子资源（Deployment、Service、PVC等）
    // 每种子资源使用CreateOrUpdate保证幂等
    deploy := constructDeployment(myApp)
    if err := ctrl.SetControllerReference(myApp, deploy, r.Scheme); err != nil { ... }
    existing := &appsv1.Deployment{}
    err := r.Get(ctx, types.NamespacedName{Name: deploy.Name, Namespace: deploy.Namespace}, existing)
    if errors.IsNotFound(err) {
        err = r.Create(ctx, deploy)
    } else {
        existing.Spec = deploy.Spec
        err = r.Update(ctx, existing)
    } 
    
    // 更新状态子资源（/status子资源endpoint单独更新）
    myApp.Status.ReadyReplicas = readyCount
    r.Status().Update(ctx, myApp)
    return ctrl.Result{}, nil
}

// 在Reconcile开始时添加Finalizer
const myFinalizer = "myapp.mycompany.com/finalizer"

func (r *MyAppReconciler) Reconcile(...) {
    if !containsString(myApp.Finalizers, myFinalizer) {
        myApp.Finalizers = append(myApp.Finalizers, myFinalizer)
        r.Update(ctx, myApp)
        return ctrl.Result{}, nil
    }
    
    // 检查是否正在被删除
    if !myApp.DeletionTimestamp.IsZero() {
        // 执行外部资源清理（如删除云数据库实例）
        if err := deleteExternalResources(myApp); err != nil {
            return ctrl.Result{RequeueAfter: time.Second * 10}, err
        }
        // 移除Finalizer，允许Kubernetes完成删除
        removeString(myApp.Finalizers, myFinalizer)
        r.Update(ctx, myApp)
        return ctrl.Result{}, nil
    }
    // ...正常协调逻辑
}

# Operator版本升级 - Channel语义
# stable-v1.0 → stable-v1.1 → stable-v2.0
apiVersion: operators.coreos.com/v1alpha1
kind: ClusterServiceVersion
metadata:
  name: myapp-operator.v1.1.0
spec:
  replaces: myapp-operator.v1.0.  # 指定上一版本，实现无缝升级
  skips:                         # 允许跳过的重要版本升级
  - myapp-operator.v1.0.5