RabbitMQ队列自动删除问题：设置auto_delete=false后关闭接收端队列仍被删除，如何解决？

嗨，我仔细看了你的代码和问题描述，一下子就找到问题根源啦——你在接收端创建的是RabbitMQ自动生成的排他队列，这才是队列在接收端关闭后消失的真正原因，和你设置的auto_delete=false完全没关系哦！

问题出在哪？ #

你在接收端调用QueueDeclareAsync的时候，只指定了autoDelete:false和durable:true，但没给队列起名字，也没设置exclusive参数：

QueueDeclareOk queueDeclareResult = await channel.QueueDeclareAsync(autoDelete:false,durable:true);

按照RabbitMQ .NET客户端的默认规则：

1. 留空队列名时，会自动生成一个随机名称的临时队列；
2. 这个临时队列默认开启了排他性（exclusive=true）——这是关键！
3. 排他队列的核心特性是：只有声明它的连接能访问，而且当这个连接关闭（也就是你关掉接收端程序）时，队列会被立刻删除，不管你设置的auto_delete是true还是false！

你用rabbitmqctl list_queues name auto_delete看到的auto_delete是false没错，但排他性的优先级更高，连接一断队列直接就没了。

怎么解决？ #

要让队列持久存在（哪怕没有消费者、连接关闭也不删），你需要做这几个关键修改：

1. 修改接收端代码：创建命名的非排他队列

你需要给队列指定一个明确的名称，并且显式关闭排他性：

using RabbitMQ.Client;
using RabbitMQ.Client.Events;
using System.Text;

var factory = new ConnectionFactory { HostName = "localhost" };
using var connection = await factory.CreateConnectionAsync();
using var channel = await connection.CreateChannelAsync();

await channel.ExchangeDeclareAsync(exchange: "BeatS", type: ExchangeType.Topic, durable: true, autoDelete: false);

// 关键修改：指定固定队列名，显式关闭排他性
const string queueName = "BeatS_Updated_Queue";
await channel.QueueDeclareAsync(
    queue: queueName,
    durable: true, // 保持队列持久化，RabbitMQ重启也不丢
    exclusive: false, // 必须设为false，关闭排他性是核心
    autoDelete: false,
    arguments: null
);

await channel.QueueBindAsync(queue: queueName, exchange: "BeatS", routingKey: "Updated");

Console.WriteLine(" [*] Waiting for messages. To exit press CTRL+C");

var consumer = new AsyncEventingBasicConsumer(channel);
consumer.ReceivedAsync += (model, ea) =>
{
    var body = ea.Body.ToArray();
    var message = Encoding.UTF8.GetString(body);
    var routingKey = ea.RoutingKey;
    Console.WriteLine($" [x] Received '{routingKey}':'{message}'");
    return Task.CompletedTask;
};

await channel.BasicConsumeAsync(queueName, autoAck: true, consumer: consumer);

Console.WriteLine(" Press [enter] to exit.");
Console.ReadLine();

2. 补充修改发送端代码：确保消息持久化

你已经设置了交换器和队列的持久化，但还需要给消息加上持久化标记，这样哪怕RabbitMQ重启，队列里的消息也不会丢失：

using RabbitMQ.Client;
using System.Text;

var factory = new ConnectionFactory { HostName = "localhost" };
using var connection = await factory.CreateConnectionAsync();
using var channel = await connection.CreateChannelAsync();

await channel.ExchangeDeclareAsync(exchange: "BeatS", type: ExchangeType.Topic, durable: true, autoDelete: false);

var routingKey = (args.Length > 0) ? args[0] : "Updated";
var message = (args.Length > 1) ? string.Join(" ", args.Skip(1).ToArray()) : "Hello World!";
var body = Encoding.UTF8.GetBytes(message);

// 新增：标记消息为持久化
var messageProperties = channel.CreateBasicProperties();
messageProperties.Persistent = true;

await channel.BasicPublishAsync(
    exchange: "BeatS",
    routingKey: routingKey,
    basicProperties: messageProperties, // 传入持久化属性
    body: body
);

Console.WriteLine($" [x] Sent '{routingKey}':'{message}'");
Console.Read();

额外注意事项 #

• 如果你需要多个客户端订阅不同的Topic，只需要给每个Topic创建对应的命名队列即可；如果是多个客户端订阅同一个Topic的消息，也可以让它们都绑定到同一个命名队列，这样消息会轮询分发给各个消费者。
• 要确保发送端和接收端使用的队列名称完全一致，否则交换器和队列的绑定会失效。
• 之前自动生成的临时队列不用管，修改后的代码会创建新的持久化命名队列，不会受旧队列影响。

内容来源于stack exchange