定义rpc健康检查方法如HealthCheck，返回服务状态；可结合http端点/healthz供监控系统检测，注意区分轻量存活检查与深度就绪检查，控制超时并妥善处理依赖探测。

go语言中处理RPC服务健康检查，核心是让客户端或监控系统能确认服务是否正常运行。常见做法是定义一个简单的健康检查方法，通过RPC接口暴露，返回服务状态。下面介绍具体实现方式和注意事项。

定义健康检查的RPC方法

在RPC服务接口中添加一个专门用于健康检查的方法，比如Health或Ping。这个方法不带参数，返回一个表示状态的结构体。

以gRPC为例：

1. 在proto文件中定义服务：

立即学习“go语言免费学习笔记（深入）”；

service HealthService { rpc HealthCheck(HealthRequest) returns (HealthResponse); } message HealthRequest {} message HealthResponse { String status = 1; int64 timestamp = 2; }

2. 在Go中实现该方法：

type HealthServer Struct{} func (s *HealthServer) HealthCheck(ctx context.Context, req *pb.HealthRequest) (*pb.HealthResponse, Error) { return &pb.HealthResponse{ Status: “OK”, Timestamp: time.Now().unix(), }, nil }

这个方法快速返回，不依赖外部资源，确保即使数据库或缓存异常，也能区分是服务进程问题还是依赖问题。

集成更全面的健康状态

如果需要检查数据库、缓存等依赖项，可以在健康检查中加入探测逻辑，但要控制超时，避免阻塞。

如知AI笔记

如知笔记——支持markdown的在线笔记，支持ai智能写作、AI搜索，支持DeepseekR1满血大模型

27

查看详情

示例：

func (s *HealthServer) HealthCheck(ctx context.Context, req *pb.HealthRequest) (*pb.HealthResponse, error) { ctx, cancel := context.WithTimeout(ctx, 2*time.Second) defer cancel() // 检查数据库连接 if err := s.db.PingContext(ctx); err != nil { return &pb.HealthResponse{ Status: “DB_ERROR”, Timestamp: time.Now().Unix(), }, nil } return &pb.HealthResponse{ Status: “OK”, Timestamp: time.Now().Unix(), }, nil }

注意：这类检查适合用在“就绪检查”（readiness），而“存活检查”（liveness）应尽量轻量，只判断进程是否运行。

配合HTTP健康端点（可选）

虽然RPC本身可以做健康检查，但很多运维工具（如kubernetes）习惯通过HTTP探测。可以在同一服务中启动一个HTTP服务器，提供/healthz端点。

代码示例：

go func() { http.HandleFunc(“/healthz”, func(w http.ResponseWriter, r *http.Request) { w.WriteHeader(http.StatusOK) w.Write([]byte(“OK”)) }) log.Fatal(http.ListenAndServe(“:8080”, nil)) }()

这样Kubernetes的livenessProbe和readinessProbe可以直接使用HTTP GET请求检测服务状态。

基本上就这些。关键是根据使用场景选择轻量检查还是深度依赖检查，并合理暴露接口。RPC健康检查不复杂，但容易忽略超时和错误处理，保持简单可靠最重要。