RabbitMQ消费者启动时收大量重复消息，求排查配置问题

你的配置确实存在几个明显问题，直接导致了消费者启动时收到大量重复消息：

1. 每次启动消费者都会创建全新的随机队列 #

消费端代码中QueueDeclare未指定固定队列名称，RabbitMQ会自动生成唯一的随机名称队列。每次启动消费者都会创建新队列并绑定到交换机，这意味着：

• 交换机将同一条消息路由到所有绑定的队列（包括历史遗留的旧队列）
• 如果是多个消费服务实例，每个实例都会收到完整的消息副本，而非分摊消费，这就是你看到的“重复消息”

2. 历史队列未自动清理 #

消费端创建队列时未设置autoDelete参数（默认值为false），导致消费者停止后，队列依然保留在Broker中。这些无消费者的队列会持续接收交换机的消息，直到达到x-max-length上限后丢弃旧消息，既浪费资源，也可能在意外重新绑定消费者时触发旧消息的重复投递。

3. 不必要的队列清空操作 #

启动时调用QueuePurge是多余的：如果是新创建的随机队列，本身就是空的；如果改为固定队列，清空操作会删除所有未消费消息，虽然符合你“未被消费的数据允许丢失”的需求，但需要明确是否真的需要在启动时清空历史消息。

修改建议 #

针对重复消息的核心修复：使用固定名称队列 #

如果你的多个消费服务需要分摊消费消息（负载均衡），所有消费者实例必须绑定到同一个固定名称的队列：

// 修改消费端的QueueDeclare，指定固定队列名称
let queue = channel.QueueDeclare(queue = "your-fixed-queue-name", arguments = properties)

如果你的需求是广播消息（每个消费服务都收到所有消息），则保留随机队列，但需要添加autoDelete参数，确保消费者停止后队列自动删除：

let queue = channel.QueueDeclare(arguments = properties, autoDelete = true)

优化配置以符合“允许丢失未消费数据”的需求 #

1. 给消息设置TTL（过期时间）：发布消息时添加过期属性，让未被消费的消息自动过期，无需等待队列满才丢弃：

// 发布端Send方法修改，添加消息属性
member this.Send(message: byte array, ?key: string) =
    try
        let key = defaultArg key String.Empty
        let props = channel.CreateBasicProperties()
        props.Expiration <- "30000" // 30秒过期，根据需求调整
        channel.BasicPublish(exchangeName, key, props, message)
    with ex ->
        error $"error while sending message to '{exchangeName}': {ex.Humanize()}"

2. 给队列设置自动删除：确保消费者停止后队列被自动清理，避免无效队列占用资源：

let queue = channel.QueueDeclare(
    queue = "your-fixed-queue-name", // 固定队列名或留空用随机名
    arguments = properties,
    autoDelete = true
)

可选：移除不必要的QueuePurge #

如果使用固定队列且不需要在启动时清空历史消息，直接删除channel.QueuePurge(queue.QueueName) |> ignore这一行即可。

内容的提问来源于stack exchange，提问作者Thomas