From 8850ed283e2a3fba555dc1b4d4c4c8acfdd03658 Mon Sep 17 00:00:00 2001
From: Cold <16419454+cold502@user.noreply.gitee.com>
Date: Fri, 19 Dec 2025 15:23:20 +0800
Subject: [PATCH] =?UTF-8?q?=E7=94=B1message=E7=BB=91=E5=AE=9Aqueue?=
 =?UTF-8?q?=E5=88=B0exchange?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 rabbitmq/consumer.go | 16 +---------------
 1 file changed, 1 insertion(+), 15 deletions(-)

diff --git a/rabbitmq/consumer.go b/rabbitmq/consumer.go
index 0ddca60..305b3f7 100644
--- a/rabbitmq/consumer.go
+++ b/rabbitmq/consumer.go
@@ -84,6 +84,7 @@ func (c *Consumer) Start(ctx context.Context) (err error) {
 	}
 
 	// 声明队列（如果不存在则创建）
+	// 注意：Queue到Exchange的绑定应由message服务在发送响应时动态创建，或通过运维工具提前配置
 	_, err = ch.QueueDeclare(
 		c.queue, // name
 		true,    // durable（持久化）
@@ -96,21 +97,6 @@ func (c *Consumer) Start(ctx context.Context) (err error) {
 		return gerror.Newf("声明队列失败: %v", err)
 	}
 
-	// TODO: 队列绑定逻辑暂时注释，避免重复binding导致消息重复投递
-	// 绑定队列到Exchange（使用队列名作为routingKey，支持多租户）
-	// Exchange类型应该是topic，绑定模式为 #（接收所有消息）
-	// err = ch.QueueBind(
-	// 	c.queue,           // queue name
-	// 	"#",               // routing key（通配符，接收所有消息）
-	// 	"ragflow.response", // exchange name
-	// 	false,             // noWait
-	// 	nil,               // arguments
-	// )
-	// if err != nil {
-	// 	g.Log().Warningf(ctx, "绑定队列到Exchange失败（可能Exchange不存在或类型不匹配）: %v", err)
-	// 	// 不返回错误，继续启动消费者（可能是direct exchange或队列已绑定）
-	// }
-
 	// 设置 QoS（并发控制）
 	err = ch.Qos(
 		c.prefetchCount, // prefetchCount: 每个 consumer 最多同时处理的消息数