Go语言微服务框架 - 13.监控组件Prometheus的引入

--- micro_web_service            项目目录
 |-- gen                            从idl文件夹中生成的文件，不可手动修改
    |-- idl                             对应idl文件夹
       |-- demo                             对应idl/demo服务，包括基础结构、HTTP接口、gRPC接口
      |-- order                            对应idl/order服务，同上
     |-- swagger.json                    openapiv2的接口文档
 |-- idl                            原始的idl定义
    |-- demo                            业务package定义，protobuffer的原始定义
    |-- order                           业务order定义，同时干
 |-- internal                       项目的内部代码，不对外暴露
    |-- config                          配置相关的文件夹，viper的相关加载逻辑
    |-- dao                             Data Access Object层，是model层的实现
    |-- gormer                          从pkg/gormer中生成的相关代码，不允许更改
    |-- metrics                         新增：自定义监控指标
    |-- model                           model层基本定义由gormer自动生成
    |-- mysql                           MySQL连接，支持日志打印
    |-- server                          服务器的实现，对idl中定义服务的具体实现
    |-- service                         service层，作为领域实现的核心部分
     |-- zlog                            封装zap日志的代码实现
  |-- pkg                            开放给第三方的工具库
     |-- gormer                          gormer二进制工具，用于生成Gorm相关Dao层代码
 |-- buf.gen.yaml                   buf生成代码的定义，新增参数校验逻辑
 |-- buf.yaml                       buf工具安装所需的工具，从v1beta升到v1
 |-- format.sh                      新增：格式化代码的脚本
 |-- gen.sh                         生成代码的脚本：buf+gormer
 |-- go.mod                         Go Module文件
 |-- gormer.yaml                    将gormer中的参数移动到这里
 |-- main.go                        项目启动的main函数
 |-- swagger.sh                     生成openapiv2的相关脚本

go func() {
  mux := http.NewServeMux()
  mux.Handle("/metrics", promhttp.Handler())
  http.ListenAndServe(fmt.Sprintf(":%d", config.Viper.GetInt("server.prometheus.port")), mux)
}()

# 示例的metrics起在8083端口
curl --request GET 'http://127.0.0.1:8083/metrics'

package metrics

import "github.com/prometheus/client_golang/prometheus"

func init() {
 prometheus.MustRegister(OrderList)
}

var OrderList = prometheus.NewCounterVec(
 prometheus.CounterOpts{
  Name: "order_list_counter",
  Help: "List Order Count",
 },
 []string{"service"},
)

func (s *Server) ListOrders(ctx context.Context, req *order.ListOrdersRequest) (*order.ListOrdersResponse, error) {
 metrics.OrderList.With(map[string]string{"service": "example"}).Inc()
  // ...
}

# HELP order_list_counter List Order Count
# TYPE order_list_counter counter
order_list_counter{service="example"} 2