@@ -285,6 +285,11 @@ func (r *Client) SetTradeWebSocket(ws *websocket.Conn) (err error) {
r.wsTradeConn = ws
r.tradeWriteChan = make(chan []byte, 100)
+ r.wsTradeConn.SetCloseHandler(func(code int, text string) error {
+ global.M2A_LOG.Info("交易长连发生断开", zap.Any("LoginID", r.LoginID), zap.Any("SessionID", r.SessionID), zap.Any("code", code), zap.Any("text", text))
+ return nil
+ })
+
// 开始读取客户端发送信息
go r.readClientWsTradeMessage()
// 开始推送客户端信息循环