Merge remote-tracking branch 'gitea/feature-im' into feature-im-gitea

This commit is contained in:
junleea 2024-08-07 15:44:06 +08:00
commit a9d1d4542a
1 changed files with 13 additions and 0 deletions

View File

@ -277,6 +277,7 @@ func SRMessage(c *gin.Context) {
} }
}(ws, res, to_user_id) }(ws, res, to_user_id)
var status_cnt int
// 从Redis中读取消息并发送到客户端 // 从Redis中读取消息并发送到客户端
for { for {
if v := clients[ws]; v == true { if v := clients[ws]; v == true {
@ -307,6 +308,18 @@ func SRMessage(c *gin.Context) {
msg.Session = res msg.Session = res
res3, _ = json.Marshal(msg) res3, _ = json.Marshal(msg)
} }
} else {
if status_cnt > 5 {
//对方不在线
msg.Type = "offline"
msg.Msg = "offline"
msg.From_user_id = -1
msg.Session = res
res3, _ = json.Marshal(msg)
} else {
status_cnt++
}
} }
err2 := ws.WriteMessage(websocket.TextMessage, res3) err2 := ws.WriteMessage(websocket.TextMessage, res3)
if err2 != nil { if err2 != nil {