.NET Core中RabbitMQ 405 RESOURCE_LOCKED错误及队列处理咨询

异常原因 #

这个405错误的核心是排他队列（exclusive: true）的特性冲突：排他队列只能被声明它的连接独占使用，当生产者和消费者用不同的连接（你的代码里两者各自创建了独立连接）尝试声明同一个名称的排他队列时，RabbitMQ会判定该队列已被锁定，抛出RESOURCE_LOCKED异常。

修改队列名称是否为正确实践？ #

不是。修改队列名称只是绕开了错误，但完全违背了“生产者向队列发消息、消费者从同队列收消息”的核心需求，属于治标不治本的错误做法。

正确处理方法 #

根据业务场景，有两种可行方案：

方案1：使用非排他队列（推荐） #

如果你的业务不需要队列被单个连接独占，直接将生产者和消费者代码中QueueDeclare方法的exclusive参数改为false即可：

生产者修改后代码：

var factory = new ConnectionFactory
{
    Uri = new Uri("amqp://guest:guest@localhost:5672")
};

using var connection= factory.CreateConnection();   
using var channel=  connection.CreateModel();
// 将exclusive改为false，允许多连接访问队列
channel.QueueDeclare("demo-queue", durable:true, exclusive:false, autoDelete:false, arguments:null);
var message = new
{
    Name = "Producer",
    Message = "Hello!"
};
var body = Encoding.UTF8.GetBytes(JsonConvert.SerializeObject(message));

channel.BasicPublish("", "demo-queue", null, body);

消费者修改后代码：

var factory = new ConnectionFactory
{
    Uri = new Uri("amqp://guest:guest@localhost:5672")
};

using var connection = factory.CreateConnection();
using var channel = connection.CreateModel();
// 将exclusive改为false，和生产者保持队列声明参数一致
channel.QueueDeclare("demo-queue", durable: true,
    exclusive: false, autoDelete: false,
    arguments: null);
var consumer = new EventingBasicConsumer(channel);
consumer.Received += (sender, e) =>
{
    var body = e.Body.ToArray();
    var message = Encoding.UTF8.GetString(body);
    Console.WriteLine(message);
};

channel.BasicConsume("demo-queue", true, consumer);

非排他队列是RabbitMQ最常用的队列类型，支持多个生产者、消费者通过不同连接访问，完全满足普通消息传递场景。

方案2：确需排他队列时的正确用法 #

如果你确实需要使用排他队列（比如临时任务队列，仅当前连接使用），需遵循两个规则：

• 不要手动指定队列名称，让RabbitMQ自动生成唯一名称（调用QueueDeclare时传入空字符串）
• 生产者和消费者必须使用同一个连接来声明和使用该队列

示例代码（同一连接下生产消费）：

var factory = new ConnectionFactory
{
    Uri = new Uri("amqp://guest:guest@localhost:5672")
};

using var connection = factory.CreateConnection();
using var channel = connection.CreateModel();
// 自动生成排他队列名称
var queueName = channel.QueueDeclare("", durable: false, exclusive: true, autoDelete: true, arguments: null).QueueName;

// 生产者逻辑
var message = new
{
    Name = "Producer",
    Message = "Hello!"
};
var body = Encoding.UTF8.GetBytes(JsonConvert.SerializeObject(message));
channel.BasicPublish("", queueName, null, body);

// 消费者逻辑
var consumer = new EventingBasicConsumer(channel);
consumer.Received += (sender, e) =>
{
    var body = e.Body.ToArray();
    var message = Encoding.UTF8.GetString(body);
    Console.WriteLine(message);
};
channel.BasicConsume(queueName, true, consumer);

// 保持连接存活，避免程序退出
Console.ReadLine();

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