update

initialize/rabbitmq.go

@@ -234,6 +234,9 @@ func (t *MQProc) onNtf(funcode uint32, sessionId uint32, bytes *[]byte) {
 		for i := range clients {
 			c := clients[i]
 			c.WriteTradeWsBuf(b)
+
+			// 给客户端通知
+			global.M2A_LOG.Info("[S->C]", zap.Any("ntf", funcode), zap.Any("clients", c.LoginID), zap.Any("len", len(b)))
 		}
 	}
 }