Golang RPC服务状态监控与健康检查示例-Golang-PHP中文网

Golang RPC服务状态监控与健康检查示例

P粉602998670

发布： 2025-10-08 19:45:02

原创

357人浏览过

答案：文章介绍了在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服务状态监控与健康检查示例

在使用 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 等系统。

以上就是Golang RPC服务状态监控与健康检查示例的详细内容，更多请关注php中文网其它相关文章！