update

client/client.go

@@ -298,7 +298,7 @@ func (r *Client) readClientWsTradeMessage() {
 		fmt.Println("readClientWsTradeMessage start")
 
 		// 40秒心跳超时
-		// r.wsTradeConn.SetReadDeadline(time.Now().Add(40 * time.Second))
+		r.wsTradeConn.SetReadDeadline(time.Now().Add(40 * time.Second))
 
 		mt, msg, err := r.wsTradeConn.ReadMessage()
 		if err != nil {

initialize/rabbitmq.go

@@ -267,7 +267,7 @@ func (t *MQProc) getRspProtobuf(msg *[]byte) (funcode uint32, sessionId uint32,
 	sessionId = utils.BytesToUint32((*msg)[4:8])
 	b := (*msg)[8:]
 
-	// global.M2A_LOG.Info("收到总线消息", zap.Any("funcode", funcode), zap.Any("sessionId", sessionId), zap.Any("len", len(b)))
+	global.M2A_LOG.Info("收到总线消息", zap.Any("funcode", funcode), zap.Any("sessionId", sessionId), zap.Any("len", len(b)))
 
 	switch int(funcode) {
 	case global.PosChangedNtf,