|
@@ -110,9 +110,10 @@ rabbitmq:
|
|
|
tasks:
|
|
|
# IP白名单更新任务
|
|
|
ip_white:
|
|
|
- exchange: "tasks_direct_exchange" # 使用一个统一的direct交换机
|
|
|
+ exchange: "tasks_direct_exchange" # 改为使用 Topic 交换机,与域名任务保持一致
|
|
|
+ exchange_type: "topic" # 显式指定交换机类型
|
|
|
queue: "ip_white_queue"
|
|
|
- routing_key: "task.ip_white.update"
|
|
|
+ routing_key: "task.ip_white.*" # 使用通配符路由键,匹配 task.ip_white.add, task.ip_white.del 等
|
|
|
consumer_count: 2
|
|
|
prefetch_count: 1
|
|
|
|