update

client/client.go

@@ -339,7 +339,7 @@ func (r *Client) writeClientWsTradeMessage() {
 		}
 		err := r.wsTradeConn.WriteMessage(websocket.BinaryMessage, buf)
 		if err != nil {
-			global.M2A_LOG.Info("writeClientWsTradeMessage 向客户端发送信息时发生错误", zap.Any("LoginID", r.LoginID), zap.Any("SessionID", r.SessionID))
+			global.M2A_LOG.Info("writeClientWsTradeMessage 向客户端发送信息时发生错误", zap.Any("LoginID", r.LoginID), zap.Any("SessionID", r.SessionID), zap.Any("err", err))
 			return
 		}
 	}

initialize/rabbitmq.go

@@ -251,7 +251,8 @@ func (t *MQProc) onNtf(funcode uint32, sessionId uint32, bytes *[]byte) {
 
 		// 发送信息
 		for i := range clients {
-			c := clients[i]
+			// c := clients[i]
+			c := client.Clients[i]
 			c.WriteTradeWsBuf(b)
 
 			// 给客户端通知