欧美bbbwbbbw肥妇,免费乱码人妻系列日韩,一级黄片

詳解Go操作supervisor xml rpc接口及注意事項(xiàng)

 更新時(shí)間:2021年09月18日 15:49:13   作者:xiaoyaoyou.xyz  
這篇文章主要介紹了Go操作supervisor xml rpc接口及注意事項(xiàng),管理web,在配置文件中配置相關(guān)信息,通過(guò)go-supervisor的處理庫(kù)進(jìn)行操作,需要的朋友可以參考下

1. 前言

之前提到過(guò)目前我們的進(jìn)程都是通過(guò)supervisor(http://supervisord.org/)這樣一個(gè)進(jìn)程管理軟件進(jìn)行管理的,也專(zhuān)門(mén)做過(guò)專(zhuān)題翻譯過(guò)supervisor的一些內(nèi)容:https://blog.csdn.net/weixin_39510813/category_11128455.html

我們會(huì)發(fā)現(xiàn)3.0以上的版本會(huì)有xml-rpc接口(http://supervisord.org/xmlrpc.html)可以通過(guò)對(duì)應(yīng)接口控制supervisor管理的進(jìn)程,包括獲取對(duì)應(yīng)的日志、運(yùn)行狀態(tài)等功能,這在實(shí)際開(kāi)發(fā)過(guò)程中獲取這些信息在web上進(jìn)行控制、查詢也是非常有幫助的,所以這里對(duì)go如何進(jìn)行supervisor管理進(jìn)程的信息的處理做簡(jiǎn)單的總結(jié)。

2. 管理web

一般在配置文件中添加:

[inet_http_server]
port=9001

即可通過(guò)9001端口訪問(wèn)一個(gè)web頁(yè)面:

在這里插入圖片描述

而通過(guò)xml-rpc可以獲取狀態(tài),對(duì)這些進(jìn)程進(jìn)行控制管理,查看對(duì)應(yīng)日志等。

注意:處于安全可能會(huì)需要配置該web的用戶名和密碼,但是為了方便進(jìn)行程序管理,最好不要配置鑒權(quán),否則程序可能由于鑒權(quán)失敗無(wú)法進(jìn)行控制。

3. go處理庫(kù)

這里給個(gè)go-supervisor的處理庫(kù):https://github.com/abrander/go-supervisord

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

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())
	}
}

對(duì)應(yīng)庫(kù)中獲取stdout的實(shí)時(shí)日志接口沒(méi)有實(shí)現(xiàn),我們可以通過(guò)websocket的方式來(lái)實(shí)現(xiàn)該接口自行擴(kuò)展,主要是通過(guò)進(jìn)程信息獲取對(duì)應(yīng)日志文件名。

4. 實(shí)時(shí)日志處理代碼片段

這里給個(gè)通過(guò)supervisor獲取日志文件名,然后通過(guò)websocket讀取日志進(jìn)行實(shí)時(shí)日志上報(bào)的代碼片段:

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
}

/***
編譯時(shí)需要安裝以下依賴:
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,                                 // 文件被移除或被打包,需要重新打開(kāi)
		Follow:    true,                                 // 實(shí)時(shí)跟蹤
		Location:  &tail.SeekInfo{Offset: 0, Whence: 2}, // 如果程序出現(xiàn)異常,保存上次讀取的位置,避免重新讀取。
		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)
}

到此這篇關(guān)于Go操作supervisor xml rpc接口及注意事項(xiàng)的文章就介紹到這了,更多相關(guān)Go操作supervisor xml rpc接口內(nèi)容請(qǐng)搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家!

相關(guān)文章

  • go select的用法

    go select的用法

    本文主要介紹了go select的用法,文中通過(guò)示例代碼介紹的非常詳細(xì),具有一定的參考價(jià)值,感興趣的小伙伴們可以參考一下
    2022-01-01
  • 詳解golang中的閉包與defer

    詳解golang中的閉包與defer

    閉包一個(gè)函數(shù)與其相關(guān)的引用環(huán)境組合的一個(gè)實(shí)體,其實(shí)可以理解為面向?qū)ο笾蓄?lèi)中的屬性與方法,這篇文章主要介紹了golang的閉包與defer,需要的朋友可以參考下
    2022-09-09
  • 一文完全掌握 Go math/rand(源碼解析)

    一文完全掌握 Go math/rand(源碼解析)

    這篇文章主要介紹了一文完全掌握 Go math/rand(源碼解析),本文可以幫助大家快速使用Go Rand.,感興趣的朋友跟隨小編一起看看吧
    2021-04-04
  • Go語(yǔ)言中實(shí)現(xiàn)enum枚舉的方法詳解

    Go語(yǔ)言中實(shí)現(xiàn)enum枚舉的方法詳解

    枚舉,即?enum,可用于表示一組范圍固定的值,它能助我們寫(xiě)出清晰、安全的代碼,那么你是否了解過(guò)?Go?中的枚舉呢?下面就跟隨小編一起來(lái)學(xué)習(xí)一下Go語(yǔ)言中實(shí)現(xiàn)enum枚舉的常用方法吧
    2024-02-02
  • Go 字符串比較的實(shí)現(xiàn)示例

    Go 字符串比較的實(shí)現(xiàn)示例

    本文主要介紹了Go 字符串比較的實(shí)現(xiàn)示例,主要包括三種比較方式,具有一定的參考價(jià)值,感興趣的可以了解一下
    2022-01-01
  • Go語(yǔ)言結(jié)構(gòu)體Go range的學(xué)習(xí)教程

    Go語(yǔ)言結(jié)構(gòu)體Go range的學(xué)習(xí)教程

    這篇文章主要為大家介紹了Go語(yǔ)言結(jié)構(gòu)體Go range的學(xué)習(xí)教程示例詳解,有需要的朋友可以借鑒參考下,希望能夠有所幫助,祝大家多多進(jìn)步,早日升職加薪
    2022-07-07
  • GO常見(jiàn)的錯(cuò)誤99%程序員會(huì)遇到(解決方法)

    GO常見(jiàn)的錯(cuò)誤99%程序員會(huì)遇到(解決方法)

    這篇文章主要介紹了GO常見(jiàn)的錯(cuò)誤99%程序員會(huì)遇到,本文給出了解決方法,非常不錯(cuò),具有一定的參考借鑒價(jià)值,需要的朋友可以參考下
    2020-01-01
  • 詳解Go語(yǔ)言如何檢查系統(tǒng)命令是否可用

    詳解Go語(yǔ)言如何檢查系統(tǒng)命令是否可用

    這篇文章主要為大家詳細(xì)介紹了Go語(yǔ)言通過(guò)編寫(xiě)一個(gè)函數(shù),利用Go語(yǔ)言標(biāo)準(zhǔn)庫(kù)中的功能來(lái)檢查系統(tǒng)命令是否可用,感興趣的小伙伴可以跟隨小編一起學(xué)習(xí)一下
    2024-01-01
  • 使用go gin來(lái)操作cookie的講解

    使用go gin來(lái)操作cookie的講解

    今天小編就為大家分享一篇關(guān)于使用go gin來(lái)操作cookie的講解,小編覺(jué)得內(nèi)容挺不錯(cuò)的,現(xiàn)在分享給大家,具有很好的參考價(jià)值,需要的朋友一起跟隨小編來(lái)看看吧
    2019-04-04
  • go程序執(zhí)行交叉編譯的流程步驟

    go程序執(zhí)行交叉編譯的流程步驟

    go程序可用通過(guò)交叉編譯的方式在一個(gè)平臺(tái)輸出多個(gè)平臺(tái)可運(yùn)行的二進(jìn)制包,本文給大家詳細(xì)介紹了go程序執(zhí)行交叉編譯的流程步驟,文中有詳細(xì)的代碼示例供大家參考,需要的朋友可以參考下
    2024-07-07

最新評(píng)論