首先集成Prometheus采集gRPC请求量、延迟、错误率等指标，通过grpc-prometheus库自动收集并暴露/metrics接口；接着在Prometheus中配置告警规则，例如当非OK响应率持续2分钟超过10%时触发告警；然后将告警推送至Alertmanager，由其通过webhook转发通知，可对接钉钉、企业微信等；最后在服务中启用gRPC健康检查接口，实现主动探活。核心是指标采集、规则判断与通知链路的完整闭环。
在golang中实现RPC服务的监控告警，核心是将指标采集、健康检测与通知机制集成到服务中。通常使用gRPC作为RPC框架时，结合Prometheus进行指标收集，再通过告警规则触发通知，是一种成熟方案。
集成Prometheus指标采集
要在gRPC服务中暴露监控数据，需使用prometheus/client_golang和grpc-prometheus库自动收集请求量、延迟、错误率等关键指标。
示例代码：
import ( "github.com/grpc-ecosystem/go-grpc-prometheus" "google.golang.org/grpc" ) <p>// 创建gRPC服务器并启用Prometheus拦截器 server := grpc.NewServer( grpc.UnaryInterceptor(grpc_prometheus.UnaryServerInterceptor), grpc.StreamInterceptor(grpc_prometheus.StreamServerInterceptor), )</p><p>// 注册Prometheus metrics handler http.Handle("/metrics", promhttp.Handler()) go http.ListenAndServe(":8080", nil)启动后，访问http://localhost:8080/metrics即可看到gRPC调用相关的指标，如grpc_server_handled_total、grpc_server_handling_seconds等。
立即学习“go语言免费学习笔记（深入）”；
配置告警规则（使用Prometheus）
Prometheus可定时拉取/metrics接口，并根据预设规则判断是否触发告警。例如，在rules.yml中定义：
groups: - name: rpc_service_alerts rules: - alert: HighErrorRate expr: rate(grpc_server_handled_total{code!="OK"}[5m]) / rate(grpc_server_handled_total[5m]) > 0.1 for: 2m labels: severity: warning annotations: summary: "高错误率" description: "gRPC服务在过去5分钟内错误率超过10%"该规则表示：当非OK响应占比持续高于10%达2分钟，触发告警。
对接告警通知（Alertmanager）
Prometheus不直接发通知，而是将告警推送给Alertmanager，由其负责去重、分组和发送。
配置alertmanager.yml示例：
route: receiver: 'webhook-notifier' <p>receivers:</p><ul><li>name: 'webhook-notifier' webhook_configs:<ul><li>url: '<a href="https://phps.yycxw.com/link/6f1ee9cf8ecb6f8f9e26b778f92a9cdd">https://phps.yycxw.com/link/6f1ee9cf8ecb6f8f9e26b778f92a9cdd</a>'你可以搭建一个简单的Go服务接收webhook，再转发到钉钉、企业微信或邮件：
http.HandleFunc("/notify", func(w http.ResponseWriter, r *http.Request) { body, _ := io.ReadAll(r.Body) log.Println("收到告警:", string(body)) // 发送到钉钉机器人 sendDingTalkAlert(string(body)) })补充：服务自身健康检查
除了外部监控，建议在gRPC服务中实现健康检查接口，便于探活。
使用gRPC内置的health包：
import "google.golang.org/grpc/health/grpc_health_v1" <p>healthServer := health.NewServer() grpc_health_v1.RegisterHealthServer(server, healthServer)</p><p>// 标记服务状态 healthServer.SetServingStatus("", grpc_health_v1.HealthCheckResponse_SERVING)客户端可通过调用Health.Check方法判断服务可用性。
基本上就这些。通过Prometheus抓取指标，配置合理告警规则，再经Alertmanager推送通知，就能实现完整的gRPC服务监控告警体系。不复杂但容易忽略的是指标标签划分和服务上下文关联，建议按method或service维度做聚合分析。
git go github golang 微信 企业微信 stream 钉钉 google cos talk igs golang 接口 http rpc prometheus