答案：文章介绍了在Golang中使用net/rpc构建RPC服务并添加HTTP健康检查的方法。1. 实现了基于Arith结构体的加法RPC服务，通过8081端口提供TCP通信；2. 使用net/http包启动独立健康检查服务，监听8080端口，/healthz返回200和OK表示存活；3. 主函数并发启动RPC和健康检查服务；4. 扩展支持/metrics接口，利用原子操作统计请求量，供Prometheus采集。该设计分离关注点，便于集成Kubernetes等系统。
在使用 Golang 构建 RPC 服务时，加入状态监控与健康检查机制是保障服务稳定性和可观测性的关键。一个简单的健康检查接口可以帮助负载均衡器、运维系统或 Kubernetes 判断服务是否正常运行。下面是一个基于 net/rpc 包的完整示例，包含基础 RPC 服务和 HTTP 健康检查端点。
1. 实现基本的 RPC 服务
我们先构建一个简单的 RPC 服务，提供加法功能：
package main
import (
"log"
"net"
"net/rpc"
)
// Args 定义加法参数
type Args struct {
A, B int
}
// Arith 提供 RPC 方法
type Arith int
func (t *Arith) Add(args *Args, reply *int) error {
*reply = args.A + args.B
return nil
}
func startRPCServer() {
arith := new(Arith)
rpc.Register(arith)
listener, err := net.Listen("tcp", ":8081")
if err != nil {
log.Fatal("RPC Listen error:", err)
}
log.Println("RPC server running on :8081")
for {
conn, err := listener.Accept()
if err != nil {
log.Print("Accept error:", err)
continue
}
go rpc.ServeConn(conn)
}
}
2. 添加 HTTP 健康检查端点
虽然 RPC 使用 TCP，但我们可以通过启用一个独立的 HTTP 服务来提供健康检查接口，便于 Prometheus 抓取或负载均衡探测。
func startHealthCheckServer() {
http.HandleFunc("/healthz", func(w http.ResponseWriter, r *http.Request) {
// 可在此处添加数据库连接、依赖服务等检查
w.WriteHeader(http.StatusOK)
w.Write([]byte("OK"))
})
log.Println("Health check server running on :8080")
log.Fatal(http.ListenAndServe(":8080", nil))
}
访问 http://localhost:8080/healthz 将返回 "OK" 和 200 状态码，表示服务健康。
立即学习“go语言免费学习笔记（深入）”；
3. 综合启动主函数
将两个服务合并启动：
func main() {
go startRPCServer()
startHealthCheckServer() // 主协程运行健康检查服务
}
这样，RPC 功能通过 8081 端口提供，健康检查通过 8080 的 HTTP 接口暴露。
4. 扩展：增加服务状态指标
可进一步增强健康检查，例如记录请求数、错误数等：
var requestCount int64
func (t *Arith) Add(args *Args, reply *int) error {
atomic.AddInt64(&requestCount, 1)
*reply = args.A + args.B
return nil
}
// 在 healthz 中加入状态输出
http.HandleFunc("/metrics", func(w http.ResponseWriter, r *http.Request) {
w.Header().Set("Content-Type", "text/plain")
w.Write([]byte(fmt.Sprintf("rpc_requests_total %d\n", atomic.LoadInt64(&requestCount))))
})
这样 Prometheus 可从 /metrics 获取简单指标。
基本上就这些。通过分离 RPC 和 HTTP 健康检查，既能保持协议清晰，又能满足监控需求，适合集成进 Kubernetes 或 Consul 等系统。
