Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Jump to bottom

fix(adapter): 修复了sealchat触发高频率重连的问题，并将重试次数减少到15次 #1134

Merged
merged 1 commit into from
Nov 11, 2024
Merged

fix(adapter): 修复了sealchat触发高频率重连的问题，并将重试次数减少到15次 #1134

Changes from all commits
Commits
Show all changes
1 commit
Select commit
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
49 changes: 28 additions & 21 deletions dice/platform_adapter_sealchat.go
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -24,8 +24,9 @@ type PlatformAdapterSealChat struct {
EchoMap SyncMap[string, chan any] `yaml:"-" json:"-"`
UserID string `yaml:"-" json:"-"`

Reconnecting bool `yaml:"-" json:"-"`
RetryTimes int `yaml:"-" json:"-"`
Reconnecting bool `yaml:"-" json:"-"`
RetryTimes int `yaml:"-" json:"-"`
RetryTimesLimit int `yaml:"-" json:"-"`
}

func (pa *PlatformAdapterSealChat) Serve() int {
Expand All @@ -36,6 +37,7 @@ func (pa *PlatformAdapterSealChat) Serve() int {
pa.Socket = &socket
pa.EndPoint.Nickname = "SealChat Bot"
pa.EndPoint.UserID = "SEALCHAT:BOT"
pa.RetryTimesLimit = 1
d := pa.Session.Parent
d.LastUpdatedTime = time.Now().Unix()
d.Save(false)
Expand All @@ -62,7 +64,6 @@ func (pa *PlatformAdapterSealChat) socketSetup() {
pa.Reconnecting = true
ep.State = 2
ep.Enable = true
pa.RetryTimes = 0

d := pa.Session.Parent
d.LastUpdatedTime = time.Now().Unix()
Expand All @@ -75,7 +76,7 @@ func (pa *PlatformAdapterSealChat) socketSetup() {
},
})

log.Info("SealChat 已连接，正在发送身份验证信息")
log.Info("SealChat 建立连接，正在发送身份验证信息")
pa.Reconnecting = false
}
socket.OnTextMessage = func(message string, socket gowebsocket.Socket) {
Expand Down Expand Up @@ -109,6 +110,10 @@ func (pa *PlatformAdapterSealChat) socketSetup() {
ep.Nickname = data.Body.User.Nick
ep.State = 1
log.Infof("SealChat 连接成功: %s", ep.Nickname)

// 握手成功，通过验证
pa.RetryTimes = 0
pa.RetryTimesLimit = 15
}

go func() {
Expand Down Expand Up @@ -143,44 +148,46 @@ func (pa *PlatformAdapterSealChat) socketSetup() {
log.Errorf("SealChat websocket出现错误: %s", err)
if !socket.IsConnected && !pa.Reconnecting {
// socket.Close()
time.Sleep(time.Duration(10) * time.Second)
if !pa.tryReconnect(*pa.Socket) {
log.Errorf("短时间内连接失败次数过多，不再进行重连")
ep.State = 3
}
}
}
socket.OnDisconnected = func(err error, socket gowebsocket.Socket) {
log.Errorf("与SealChat服务器断开连接")
log.Info("与SealChat服务器断开连接，尝试进行重连")
time.Sleep(time.Duration(2) * time.Second)
if !pa.tryReconnect(*pa.Socket) {
log.Errorf("尝试进行重连")
ep.State = 3
log.Errorf("到达连接次数上限，不再进行重连")
}
}
pa.Socket = socket
}

func (pa *PlatformAdapterSealChat) tryReconnect(socket gowebsocket.Socket) bool {
log := pa.Session.Parent.Logger
if pa.Reconnecting {
return false
if socket.IsConnected {
return true
}
pa.Reconnecting = true
pa.RetryTimes = 0
allTimes := 500
for pa.RetryTimes <= allTimes && !socket.IsConnected {
if !pa.EndPoint.Enable {
return false
}

pa.RetryTimes++
log.Infof("尝试重新连接SealChat中[%d/%d]", pa.RetryTimes, allTimes)
socket = gowebsocket.New(pa.ConnectURL)
pa.Socket = &socket
pa.socketSetup()
socket.Connect()
time.Sleep(time.Duration(10) * time.Second)
if !pa.EndPoint.Enable {
return true
}

if pa.RetryTimes >= pa.RetryTimesLimit {
return false
}

pa.RetryTimes++
log.Infof("尝试重新连接SealChat中[%d/%d]", pa.RetryTimes, pa.RetryTimesLimit)
socket = gowebsocket.New(pa.ConnectURL)
pa.Socket = &socket
pa.socketSetup()
socket.Connect()

pa.Reconnecting = false
return true
}
Expand Down