脚本之家,脚本语言编程技术及教程分享平台!
分类导航

Python|VBS|Ruby|Lua|perl|VBA|Golang|PowerShell|Erlang|autoit|Dos|bat|

服务器之家 - 脚本之家 - Golang - 详解Go操作supervisor xml rpc接口及注意事项

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

2021-11-13 11:23xiaoyaoyou.xyz Golang

这篇文章主要介绍了Go操作supervisor xml rpc接口及注意事项,管理web,在配置文件中配置相关信息,通过go-supervisor的处理库进行操作,需要的朋友可以参考下

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

延伸 · 阅读

精彩推荐
  • GolangGolang通脉之数据类型详情

    Golang通脉之数据类型详情

    这篇文章主要介绍了Golang通脉之数据类型,在编程语言中标识符就是定义的具有某种意义的词,比如变量名、常量名、函数名等等,Go语言中标识符允许由...

    4272021-11-24
  • Golanggolang如何使用struct的tag属性的详细介绍

    golang如何使用struct的tag属性的详细介绍

    这篇文章主要介绍了golang如何使用struct的tag属性的详细介绍,从例子说起,小编觉得挺不错的,现在分享给大家,也给大家做个参考。一起跟随小编过来看...

    Go语言中文网11352020-05-21
  • Golanggolang的httpserver优雅重启方法详解

    golang的httpserver优雅重启方法详解

    这篇文章主要给大家介绍了关于golang的httpserver优雅重启的相关资料,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,...

    helight2992020-05-14
  • Golanggolang json.Marshal 特殊html字符被转义的解决方法

    golang json.Marshal 特殊html字符被转义的解决方法

    今天小编就为大家分享一篇golang json.Marshal 特殊html字符被转义的解决方法,具有很好的参考价值,希望对大家有所帮助。一起跟随小编过来看看吧 ...

    李浩的life12792020-05-27
  • Golanggo语言制作端口扫描器

    go语言制作端口扫描器

    本文给大家分享的是使用go语言编写的TCP端口扫描器,可以选择IP范围,扫描的端口,以及多线程,有需要的小伙伴可以参考下。 ...

    脚本之家3642020-04-25
  • Golanggo日志系统logrus显示文件和行号的操作

    go日志系统logrus显示文件和行号的操作

    这篇文章主要介绍了go日志系统logrus显示文件和行号的操作,具有很好的参考价值,希望对大家有所帮助。一起跟随小编过来看看吧...

    SmallQinYan12302021-02-02
  • Golanggolang 通过ssh代理连接mysql的操作

    golang 通过ssh代理连接mysql的操作

    这篇文章主要介绍了golang 通过ssh代理连接mysql的操作,具有很好的参考价值,希望对大家有所帮助。一起跟随小编过来看看吧...

    a165861639710342021-03-08
  • GolangGolang中Bit数组的实现方式

    Golang中Bit数组的实现方式

    这篇文章主要介绍了Golang中Bit数组的实现方式,具有很好的参考价值,希望对大家有所帮助。一起跟随小编过来看看吧...

    天易独尊11682021-06-09