如何实现k8s中自定义controller的健康检查 请给出具体实现代码

在k8s中自定义controller的健康检查可以通过在controller的Pod中运行一个HTTP服务，然后在Pod的定义中添加livenessProbe和readinessProbe来实现。

下面是一个简单的示例，假设我们要实现一个名为"my-controller"的controller，并且它的Pod中运行一个HTTP服务，监听端口为8080。

apiVersion: v1
kind: Pod
metadata:
  name: my-controller
spec:
  containers:
  - name: my-controller
    image: my-controller-image
    ports:
    - name: http
      containerPort: 8080
    livenessProbe: # livenessProbe用于检查Pod是否健康
      httpGet:
        path: /healthz
        port: http
      initialDelaySeconds: 10 # 初始等待10秒再检查
      periodSeconds: 5 # 每5秒检查一次
    readinessProbe: # readinessProbe用于检查Pod是否准备好接收流量
      httpGet:
        path: /ready
        port: http
      initialDelaySeconds: 5 # 初始等待5秒再检查
      periodSeconds: 3 # 每3秒检查一次

上述示例中，我们在Pod的定义中添加了livenessProbe和readinessProbe。它们都使用了httpGet作为检查方式，并且分别检查了/healthz和/ready这两个路径。这两个路径需要在my-controller的HTTP服务中实现，例如：

http.HandleFunc("/healthz", func(w http.ResponseWriter, r *http.Request) {
  w.WriteHeader(http.StatusOK)
})

http.HandleFunc("/ready", func(w http.ResponseWriter, r *http.Request) {
  if isReady {
    w.WriteHeader(http.StatusOK)
  } else {
    w.WriteHeader(http.StatusServiceUnavailable)
  }
})

上述示例中，/healthz路径返回200 OK，表示Pod健康；/ready路径则根据isReady变量的值返回200 OK或503 Service Unavailable，表示Pod是否准备好接收流量。

当Pod的livenessProbe或readinessProbe检测到失败时，k8s会自动重启Pod或停止将流量转发到该Pod。这样就可以保证controller的健康和稳定运行了。