package/go_process_manager
1
0
Fork 0
mirror of https://github.com/lzh-1625/go_process_manager.git synced 2025-10-04 23:52:53 +08:00
Code Issues Packages Projects Releases Wiki Activity

add ws connect timeout config

Browse Source
This commit is contained in:
akrike
2025-02-14 00:41:52 +08:00
parent b2a1ef94e9
commit 0566b259a1
2 changed files with 3 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

1
config/config.go
View File

@@ -20,6 +20,7 @@ type configuration struct {
ProcessExpireTime int64 `default:"60" describe:"进程控制权过期时间（秒）"` ProcessExpireTime int64 `default:"60" describe:"进程控制权过期时间（秒）"`
PerformanceInfoListLength int `default:"30" describe:"性能信息存储长度"` PerformanceInfoListLength int `default:"30" describe:"性能信息存储长度"`
PerformanceInfoInterval int `default:"60" describe:"监控获取间隔时间（秒）"` PerformanceInfoInterval int `default:"60" describe:"监控获取间隔时间（秒）"`
TerminalConnectTimeout int `default:"10" describe:"终端连接超时时间（分钟）"`
UserPassWordMinLength int `default:"4" describe:"用户密码最小长度"` UserPassWordMinLength int `default:"4" describe:"用户密码最小长度"`
LogMinLenth int `default:"0" describe:"过滤日志最小长度"` LogMinLenth int `default:"0" describe:"过滤日志最小长度"`
LogHandlerPoolSize int `default:"10" describe:"日志处理并行数"` LogHandlerPoolSize int `default:"10" describe:"日志处理并行数"`

3
internal/app/api/ws.go
View File

@@ -4,6 +4,7 @@ import (
"context" "context"
"time" "time"
"github.com/lzh-1625/go_process_manager/config"
"github.com/lzh-1625/go_process_manager/internal/app/constants" "github.com/lzh-1625/go_process_manager/internal/app/constants"
"github.com/lzh-1625/go_process_manager/internal/app/logic" "github.com/lzh-1625/go_process_manager/internal/app/logic"
"github.com/lzh-1625/go_process_manager/internal/app/middle" "github.com/lzh-1625/go_process_manager/internal/app/middle"
@@ -75,7 +76,7 @@ func (w *wsApi) WebsocketHandle(ctx *gin.Context) {
select { select {
case <-proc.StopChan: case <-proc.StopChan:
log.Logger.Infow("ws连接断开", "操作类型", "进程已停止，强制断开ws连接") log.Logger.Infow("ws连接断开", "操作类型", "进程已停止，强制断开ws连接")
case <-time.After(time.Minute * 10): case <-time.After(time.Minute * time.Duration(config.CF.TerminalConnectTimeout)):
log.Logger.Infow("ws连接断开", "操作类型", "连接时间超过最大时长限制") log.Logger.Infow("ws连接断开", "操作类型", "连接时间超过最大时长限制")
case <-wsCtx.Done(): case <-wsCtx.Done():
log.Logger.Infow("ws连接断开", "操作类型", "tcp连接建立已被关闭") log.Logger.Infow("ws连接断开", "操作类型", "tcp连接建立已被关闭")