怎么写一个 crd 和 controller-Go服务器开发

要写一个CRD和Controller，需要经过以下步骤：

定义CRD的规范：首先需要定义Custom Resource Definition（CRD）的规范。可以在Kubernetes中定义自己的API资源类型，例如Pod、Service等。但是，如果你想定义一种新的资源类型，则需要使用CRD来描述它们的属性和行为。
编写 CRD Controller 的代码：编写CRD Controller代码以实现对所创建的CRD资源对象进行管理。比如监听到某个事件后，就可以执行一些自定义逻辑。
部署 CRD 和 Controller：将所编写的CRD和Controller部署到Kubernetes集群中，并确保它们正确地运行。

下面是一个基本示例:

首先，在Kubernetes YAML文件中定义你要创建的自定义资源

apiVersion: apiextensions.k8s.io/v1beta1
kind: CustomResourceDefinition
metadata:
  name: myresource.example.com
spec:
  group: example.com
  version: v1alpha1
  scope: Namespaced
  names:
    plural: myresources
    singular: myresource
    kind: MyResource

然后, 我们需要编写一个Controller以响应这个自定义资源:

package main

import (
	"context"
	"fmt"

	"github.com/operator-framework/operator-sdk/pkg/k8sutil"
	"k8s.io/apimachinery/pkg/runtime"
	"sigs.k8s.io/controller-runtime/pkg/client/config"

	myresv1alpha1 "example.com/my-resource-operator/api/v1alpha1" // 这里需要引入自定义资源类型的包

	ctrl "sigs.k8s.io/controller-runtime"
)

func main() {
	namespace, err := k8sutil.GetWatchNamespace()
	if err != nil {
		fmt.Printf("Failed to get watch namespace: %v", err)
	}
	cfg, err := config.GetConfig()
	if err != nil {
		fmt.Printf("Failed to get Kubernetes config: %v", err)
	}

	mgr, err := ctrl.NewManager(cfg, ctrl.Options{
		Scheme:             runtime.NewScheme(),
		Namespace:          namespace,
		MetricsBindAddress: "0",
	})
	if err != nil {
		fmt.Printf("Failed to create manager: %v", err)
	}

	err = (&MyResourceReconciler{
		Client: mgr.GetClient(),
        // 这里可以添加一些其他的依赖注入
    }).SetupWithManager(mgr)
	if err != nil {
		fmt.Printf("Failed to setup reconciler: %v", err)
    }
    
    // 启动Controller
    if err = mgr.Start(ctrl.SetupSignalHandler()); err != nil {
        fmt.Printf("Failed to start controller manager: %v", err)
    }
}

type MyResourceReconciler struct {
	client.Client
	Scheme *runtime.Scheme
}

// Reconcile is called for each resource created or updated on the cluster.
func (r *MyResourceReconciler) Reconcile(req ctrl.Request) (ctrl.Result, error) {

	ctx := context.Background()

	var myres myresv1alpha1.MyResource

	err := r.Get(ctx, req.NamespacedName, &myres)

	if err != nil {
	    return ctrl.Result{}, client.IgnoreNotFound(err)
    }

    // Add your custom logic here...

	return ctrl.Result{}, nil
}

func (r *MyResourceReconciler) SetupWithManager(mgr ctrl.Manager) error {
    return ctrl.NewControllerManagedBy(mgr).
        For(&myresv1alpha1.MyResource{}).
        Complete(r)
}

最后，你需要使用operator-sdk生成代码和构建docker镜像，并将其部署到Kubernetes集群中。