k8s中 如何实现controller的健康检查接口 请给出具体代码

在 Kubernetes 中，可以使用 readinessProbe 和 livenessProbe 两种探针来实现 Controller 的健康检查接口。

readinessProbe 用于检查 Pod 是否已经就绪，如果返回成功，则表示该 Pod 已经可以接收流量；如果返回失败，则表示该 Pod 还未就绪，不能接收流量。

livenessProbe 用于检查 Pod 是否存活，如果返回成功，则表示该 Pod 正常运行；如果返回失败，则表示该 Pod 已经出现故障，需要重启或者替换掉。

下面是一个简单的 Controller 的样例代码，其中包含了 readinessProbe 和 livenessProbe 的配置：

package main

import (
	"context"
	"fmt"
	"net/http"
	"os"
	"os/signal"
	"syscall"
	"time"

	"github.com/gorilla/mux"
)

func main() {
	// 创建一个路由器
	r := mux.NewRouter()

	// 注册一个处理器函数
	r.HandleFunc("/", func(w http.ResponseWriter, r *http.Request) {
		fmt.Fprintln(w, "Hello World!")
	})

	// 创建一个 HTTP 服务器
	srv := &http.Server{
		Addr:    ":8080",
		Handler: r,
	}

	// 启动 HTTP 服务器
	go func() {
		if err := srv.ListenAndServe(); err != nil {
			fmt.Println(err)
		}
	}()

	// 定义 readinessProbe 探针
	readinessProbe := &http.Server{
		Addr:    ":8081",
		Handler: http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) {
			w.WriteHeader(http.StatusOK)
		}),
	}

	// 定义 livenessProbe 探针
	livenessProbe := &http.Server{
		Addr:    ":8082",
		Handler: http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) {
			w.WriteHeader(http.StatusOK)
		}),
	}

	// 启动 readinessProbe 探针
	go func() {
		if err := readinessProbe.ListenAndServe(); err != nil {
			fmt.Println(err)
		}
	}()

	// 启动 livenessProbe 探针
	go func() {
		if err := livenessProbe.ListenAndServe(); err != nil {
			fmt.Println(err)
		}
	}()

	// 等待信号中断
	sig := make(chan os.Signal, 1)
	signal.Notify(sig, syscall.SIGINT, syscall.SIGTERM)
	<-sig

	// 关闭 HTTP 服务器
	ctx, cancel := context.WithTimeout(context.Background(), 5*time.Second)
	defer cancel()
	if err := srv.Shutdown(ctx); err != nil {
		fmt.Println(err)
	}
}

在上面的代码中，我们通过创建两个 HTTP 服务器来实现 readinessProbe 和 livenessProbe 探针。其中，readinessProbe 探针监听在 8081 端口，livenessProbe 探针监听在 8082 端口。当探针返回成功时，HTTP 响应码为 200，表示探针测试通过。最后，我们通过等待信号来关闭 HTTP 服务器。