This commit is contained in:
laodaming 2023-10-18 14:40:50 +08:00
parent 57e6b0227f
commit fbbf6b984f
3 changed files with 7 additions and 8 deletions

View File

@ -238,7 +238,7 @@ func (l *DataTransferLogic) setConnPool(conn *websocket.Conn, userInfo *auth.Use
if isFirefoxBrowser {
time.Sleep(time.Second * 1) //兼容下火狐(直接发回去收不到第一条消息:有待研究)
}
ws.sendToOutChan(ws.respondDataFormat(constants.WEBSOCKET_CONNECT_SUCCESS, websocket_data.ConnectSuccessMsg{Wid: uniqueId}))
ws.sendToOutChan(ws.respondDataFormat(constants.WEBSOCKET_CONNECT_SUCCESS, websocket_data.ConnectSuccessMsg{Wid: uniqueId, Debug: ws.debug != nil}))
//发送累加统计连接书
increaseWebsocketConnectCount()
return ws, nil
@ -454,7 +454,6 @@ func (w *wsConnectItem) respondDataFormat(msgType constants.Websocket, data inte
d := websocket_data.DataTransferData{
T: msgType,
D: data,
Debug: w.debug != nil,
}
b, _ := json.Marshal(d)
return b

View File

@ -2,7 +2,8 @@ package websocket_data
// 基础连接成功返回
type ConnectSuccessMsg struct {
Wid string `json:"wid"`
Wid string `json:"wid"` //websocket连接唯一标识
Debug bool `json:"debug"` //是否开启debug
}
// 连接失败

View File

@ -6,7 +6,6 @@ import "fusenapi/constants"
type DataTransferData struct {
T constants.Websocket `json:"t"` //消息类型
D interface{} `json:"d"` //传递的消息
Debug bool `json:"debug"` //是否开启debug
}
// websocket接受要云渲染处理的数据