个人中心
gpt4 book ai didi

详解Go操作supervisor xml rpc接口及注意事项

转载 作者：qq735679552 更新时间：2022-09-27 22:32:09 26 4
gpt4 key购买 nike

CFSDN坚持开源创造价值，我们致力于搭建一个资源共享平台，让每一个IT人在这里找到属于你的精彩世界.

这篇CFSDN的博客文章详解Go操作supervisor xml rpc接口及注意事项由作者收集整理，如果你对这篇文章有兴趣，记得点赞哟.

1. 前言

之前提到过目前我们的进程都是通过supervisor（http://supervisord.org/）这样一个进程管理软件进行管理的，也专门做过专题翻译过supervisor的一些内容：https://blog.csdn.net/weixin_39510813/category_11128455.html 。

我们会发现3.0以上的版本会有xml-rpc接口（http://supervisord.org/xmlrpc.html）可以通过对应接口控制supervisor管理的进程，包括获取对应的日志、运行状态等功能，这在实际开发过程中获取这些信息在web上进行控制、查询也是非常有帮助的，所以这里对go如何进行supervisor管理进程的信息的处理做简单的总结.

2. 管理web

一般在配置文件中添加:

[inet_http_server] port=9001 。

即可通过9001端口访问一个web页面:

详解Go操作supervisor xml rpc接口及注意事项

而通过xml-rpc可以获取状态，对这些进程进行控制管理，查看对应日志等.

注意：处于安全可能会需要配置该web的用户名和密码，但是为了方便进行程序管理，最好不要配置鉴权，否则程序可能由于鉴权失败无法进行控制.

3. go处理库

这里给个go-supervisor的处理库：https://github.com/abrander/go-supervisord 。

https://pkg.go.dev/github.com/abrander/go-supervisord#section-readme 。

?
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
import "github.com/abrander/go-supervisord"
  
func main() {
     c, err := supervisord.NewClient("http://127.0.0.1:9001/RPC2")
     if err != nil {
         panic(err.Error())
     }
    
     err = c.ClearLog()
     if err != nil {
         panic(err.Error())
     }
    
     err = c.Restart()
     if err != nil {
         panic(err.Error())
     }
}

对应库中获取stdout的实时日志接口没有实现，我们可以通过websocket的方式来实现该接口自行扩展，主要是通过进程信息获取对应日志文件名.

4. 实时日志处理代码片段

这里给个通过supervisor获取日志文件名，然后通过websocket读取日志进行实时日志上报的代码片段:

?
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
func (s *businessLogService) TailLog(name string, ws *ghttp.WebSocket) error {
     c, err := supervisord.NewClient("http://127.0.0.1:9001/RPC2")
     if err != nil {
         return err
     }
     defer c.Close()
     processInfo, err := c.GetProcessInfo(name)
     if err != nil {
         logger.Error(err)
         return err
     }
     filename = processInfo.StdoutLogfile
     logger.Debug(filename)
     s.serveWs(ws)
     return nil
}
 
/***
编译时需要安装以下依赖：
go get github.com/gorilla/websocket
go get github.com/hpcloud/tail
*/
const (
     // Time allowed to write the file to the client.
     //writeWait = 1 * time.Second
     writeWait = 100 * time.Millisecond
 
     // Time allowed to read the next pong message from the client.
     //pongWait = 24 * time.Hour
     pongWait = 60 * time.Second
 
     // Send pings to client with this period. Must be less than pongWait.
     pingPeriod = (pongWait * 9) / 10
 
     // Poll file for changes with this period.
     filePeriod = 1 * time.Second
)
 
var (
     filename string
)
 
func (s *businessLogService) readFileIfModified(lastMod time.Time) ([]byte, time.Time, error) {
     fi, err := os.Stat(filename)
     if err != nil {
         return nil, lastMod, err
     }
     if !fi.ModTime().After(lastMod) {
         return nil, lastMod, nil
     }
     p, err := ioutil.ReadFile(filename)
     if err != nil {
         return nil, fi.ModTime(), err
     }
     return p, fi.ModTime(), nil
}
 
func (s *businessLogService) reader(ws *ghttp.WebSocket) {
     defer ws.Close()
     ws.SetReadLimit(512)
     ws.SetReadDeadline(time.Now().Add(pongWait))
     ws.SetPongHandler(func(string) error { ws.SetReadDeadline(time.Now().Add(pongWait)); return nil })
     for {
         _, _, err := ws.ReadMessage()
         if err != nil {
             logger.Warn(err)
             break
         }
     }
}
 
func (s *businessLogService) tailFile() *tail.Tail {
     tailFd, err := tail.TailFile(filename, tail.Config{
         ReOpen:    true,                                 // 文件被移除或被打包，需要重新打开
         Follow:    true,                                 // 实时跟踪
         Location:  &tail.SeekInfo{Offset: 0, Whence: 2}, // 如果程序出现异常，保存上次读取的位置，避免重新读取。
         MustExist: false,                                // 如果文件不存在，是否推出程序，false是不退出
         Poll:      true,
     })
 
     if err != nil {
         logger.Error("tail file failed, err:", err)
         return nil
     }
     return tailFd
}
 
func (s *businessLogService) writer(ws *ghttp.WebSocket) {
     tailFd := s.tailFile()
     pingTicker := time.NewTicker(pingPeriod)
     fileTicker := time.NewTicker(filePeriod)
     maxTimeout := time.NewTicker(time.Duration(1) * time.Minute)
     defer func() {
         pingTicker.Stop()
         fileTicker.Stop()
         ws.Close()
     }()
 
     for {
         select {
         case msg, ok := <-tailFd.Lines:
             if ok {
                 ws.SetWriteDeadline(time.Now().Add(writeWait))
                 logger.Debug("read file content： %s\n", msg)
                 if err := ws.WriteMessage(websocket.TextMessage, []byte(msg.Text)); err != nil {
                     return
                 }
             }
         case <-pingTicker.C:
             ws.SetWriteDeadline(time.Now().Add(writeWait))
             if err := ws.WriteMessage(websocket.PingMessage, []byte{}); err != nil {
                 return
             }
         case <-maxTimeout.C:
             ws.WriteMessage(websocket.TextMessage, []byte("Maximum timeout"))
             ws.Close()
         }
     }
}
 
func (s *businessLogService) serveWs(ws *ghttp.WebSocket) {
     go s.writer(ws)
     s.reader(ws)
}

到此这篇关于Go操作supervisor xml rpc接口及注意事项的文章就介绍到这了,更多相关Go操作supervisor xml rpc接口内容请搜索我以前的文章或继续浏览下面的相关文章希望大家以后多多支持我！ 。

原文链接：https://blog.csdn.net/weixin_39510813/article/details/120365508 。

最后此篇关于详解Go操作supervisor xml rpc接口及注意事项的文章就讲到这里了,如果你想了解更多关于详解Go操作supervisor xml rpc接口及注意事项的内容请搜索CFSDN的文章或继续浏览相关文章，希望大家以后支持我的博客！ 。

26 4 0
文章推荐： C语言sqrt函数的实例用法讲解
文章推荐： system idle process占用率高怎么解决?system idle process进程占用率高的原因
文章推荐： 手动添加bits/stdc++.h到vs2017的详细步骤
文章推荐： wmi provider host是什么进程?wmi provider host进程介绍
qq735679552
个人简介

我是一名优秀的程序员,十分优秀！

滴滴打车优惠券免费领取
滴滴打车优惠券
Copyright 2021 - 2024 cfsdn All Rights Reserved 蜀ICP备2022000587号
广告合作:1813099741@qq.com 6ren.com