update

initialize/rabbitmq.go

@@ -257,15 +257,17 @@ func (t *MQProc) onNtf(funcode uint32, sessionId uint32, bytes *[]byte) {
 			c := client.Clients[sessionId]
 			// c.WriteTradeWsBuf(b)
 
+			// 给客户端通知
+			global.M2A_LOG.Info("[S->C]给客户端通知", zap.Any("ntf", funcode), zap.Any("clients", c.LoginID), zap.Any("SessionID", c.SessionID), zap.Any("len", len(b)))
+
 			// 分发给订阅者
 			m := make(map[string][]byte)
 			m[item.SessionID] = b
 			global.M2A_Publish.Publish(publish.Topic_Trading, m)
-
-			// 给客户端通知
-			global.M2A_LOG.Info("[S->C]给客户端通知", zap.Any("ntf", funcode), zap.Any("clients", c.LoginID), zap.Any("SessionID", c.SessionID), zap.Any("len", len(b)))
 		}
 	}
+
+	global.M2A_LOG.Info("----------退出通知逻辑", zap.Any("funcode", funcode), zap.Any("sessionId", sessionId))
 }
 
 // getRspProtobuf 将总线回复的数据反序列化为Protobuf
@@ -286,6 +288,8 @@ func (t *MQProc) getRspProtobuf(msg *[]byte) (funcode uint32, sessionId uint32,
 		global.LogoutRsp,
 		global.ListingOrderChangeNtf: // 资金变化通知等
 
+		global.M2A_LOG.Info("进入通知逻辑----------", zap.Any("funcode", funcode), zap.Any("sessionId", sessionId))
+
 		bytes = &b
 	case global.ModifyPwdRsp: // 修改账户密码应答
 		var p pb.ModifyPwdRsp