1

app/Amqp/Consumer/MqConsumer.php

@@ -33,6 +33,7 @@ class MqConsumer extends ConsumerMessage
         try {
             // 数据存储
             $this->logger->info('消费数据', ['data' => $data]);
+            var_dump($data, '=================消费数据==============');
             // 调用数据处理服务
             $result = $this->chatServiceClient->addChatRecords($data);
             // 记录处理结果