update

global/client.go

@@ -96,6 +96,10 @@ func (r *Client) DeleteAsyncTask(key string) {
 	delete(r.asyncTasks, key)
 }
 
+func (r *Client) GetAllAsyncTask() *map[string]*AsyncTask {
+	return &r.asyncTasks
+}
+
 // MQPacket 与总线交互的数据体
 type MQPacket struct {
 	FunCode   uint32  // 功能码

initialize/rabbitmq.go

@@ -77,6 +77,8 @@ func (t *MQProc) Process(topic, queuename string, msg *[]byte) {
 					Data:        rspData,
 				}
 				asyncTask.Rsp <- r
+			} else {
+				global.M2A_LOG.Info("找不到对应KEY的异步任务", zap.Any("key", key), zap.Any("AsyncMap", client.GetAllAsyncTask()))
 			}
 		}
 	}