妙音

 

 

gin使用了微服务架构, 如何将自己的服务都监控起来?

 

 

 

1. grafana是什么, 能做什么?

 

grafana是一个监控平台，支持不同数据源的可视化。也就是说支持从prometheuse,influxdb等数据源, 并将他们的数据形式可视化的图表.

 

2. prometheus能做什么?

prometheuse是一个监控系统,通过定时http pull采集数据. 并且支持http push.

 

3. prometheus和grafana是什么关系?

prometheuse是监控系统, 界面展示比较粗糙, grafana主要是可视化, 并且支持多种类型数据源。

 

4. gin如何与prometheuse结合?

见后面

 

5. gin如何与grafana?

grafana不支持直接接入gin服务。需要gin先接入prometheuse，再将prometheus接入grafana。

 

6. gin服务的metrics数据格式如何解析?

暂时未找到

 

7. gin自定义监控项

略. 不是本文主题

 

 

 

grafana
https://github.com/grafana/grafana

prometheus
https://github.com/prometheus/prometheus

 

 

1. 修改gin服务代码

 

import (
    ...
"github.com/gin-gonic/gin"
"github.com/prometheus/client_golang/prometheus/promhttp"
    ...
)


//metrics, promhttp默认可以查看cpu,mem,线程等信息
router.GET("/metrics", gin.WrapH(promhttp.Handler()))

 

2.修改prometheuse配置(prometheuse.yml)

 

scrape_configs:
  - job_name: "prometheus-demo"
    static_configs:
      - targets: ["192.168.28.26:8011"]

 

3. 启动服务

 

a. 启动gin和prometheuse服务后, 访问localhost:9090

 

b. 在"Expression"输入框选择"go_goroutines", 点击"Execute"

 

c. 刚开始数据比较少,可以过一段时间后再刷新页面

 

佛說大乘無量壽莊嚴清淨平等覺經pdf

净土大经科注2014-doc

此生必看的科学实验-水知道答案

印光大师十念法（胡小林主讲第1集）

 

 

 

python版本的supervisrod, 在linux、windows系统中离线安装都不怎么方便.  是否有go版本的呢?

 

 

[https://github.com/ochinchina/supervisord/](https://github.com/ochinchina/supervisord/)

 

 

* 编译32版本, 有些报错, 需要修改源码

 

* 在ui界面快速点击start/stop, 进程可能会启动多个。需要加锁处理处理.

 

## 用法

 

* 配置文件查找顺序

 

$CWD/supervisord.conf
$CWD/etc/supervisord.conf
/etc/supervisord.conf
/etc/supervisor/supervisord.conf (since Supervisor 3.3.0)
../etc/supervisord.conf (Relative to the executable)
../supervisord.conf (Relative to the executable)

 

 

* 最简单配置supervisord.conf

 

[program:test]
command = /your/program args

 

 

* 常用配置

 

[inet_http_server]          ;http接口
port=:9002
;username=xxxx
;password=xxxx

[supervisorctl]             ;ui界面
serverurl=http://127.0.0.1:9002

[supervisord]               ;日志
logfile=%(here)s/../log/supervisord.log
logfileMaxbytes=50MB        ;文件大小
logfileBackups=10           ;10个文件
loglevel=info               ;日志级别

[program:middleware1]       ;进程
command = %(here)s/../middleware1.exe   ;here指的是supervisord.conf的路径，而不是supervisord.exe的路径
autorestart = true
numprocs=1                  ;进程数量

[program:programname1]
command = %(here)s/../programname1.exe
autorestart = true
numprocs=1
depends_on=middleware1      ;依赖进程


[program:programname2]
command = %(here)s/../programname2.exe
autorestart = true
numprocs=1
depends_on=middleware1

 

佛說大乘無量壽莊嚴清淨平等覺經pdf

净土大经科注2014-doc

此生必看的科学实验-水知道答案

印光大师十念法（胡小林主讲第1集）

 

 

    写了一个测试脚本，从数据读取一组数据，然后逐条publish到nats-server中, 确定每条都publish了

 

    有另外一个程序中subscribe订阅，在该程序发现最后一条一直没收到

 

 

 

* go: 1.16

 

* nats-server

 

 

* 发布

 

for _, record := range records{
    ...
    gNatsConn.Publish(Topic, record)
    time.Sleep(time.Second*0.1)    //间隔越小出现的概率越大. 间隔1秒好像就没有
}

 

* 订阅

 

natsConn.Subscribe(topic, func(m *nats.Msg){
    fmt.Println(m.Data)
    ....
}

 

 

    nats在发布消息时，有应该是用了缓存通道, 大小是1。最后一条数据有可能没被读走

 

    发布频率较高，最后需要flush一下

 

 

佛說大乘無量壽莊嚴清淨平等覺經pdf

净土大经科注2014-doc

此生必看的科学实验-水知道答案

印光大师十念法（胡小林主讲第1集）