运行Pika消费者声明独占队列q1时报RESOURCE_LOCKED错误如何解决

该405 RESOURCE_LOCKED错误是RabbitMQ服务端返回的，核心触发点和你声明的exclusive（独占）队列特性相关：

• exclusive队列的规则是仅能被声明它的连接独占使用，连接断开后队列会自动删除。你指定了固定队列名q1作为独占队列，出现以下任意一种情况就会触发报错：
  • 已经有另一个处于存活状态的连接先声明了同名的q1独占队列，当前连接无法获取独占权限
  • 此前已经有连接声明过同名的q1队列，但当时没有加exclusive=True参数，现在你用不匹配的属性声明同名队列，被服务端直接拒绝

根据你的业务场景可以选择以下任意一种方案解决：

• 方案1：不指定固定队列名，让RabbitMQ自动生成随机名称的独占队列
  适合fanout广播场景下每个消费者用独立临时队列接收广播的需求，修改队列声明相关代码即可：

  # 不传queue参数，RabbitMQ会自动生成随机唯一的队列名
  result = ch.queue_declare(queue='', exclusive=True)
  queue_name = result.method.queue
  # 绑定和消费都使用自动生成的队列名
  ch.queue_bind(exchange='ex1', queue=queue_name)
  ch.basic_consume(queue=queue_name, on_message_callback=callback, auto_ack=True)
  

• 方案2：如果必须使用固定队列名q1，移除exclusive=True参数
  适合多消费者共同消费同一个队列的场景，修改队列声明代码：

  ch.queue_declare(queue='q1')
  

  注意如果此前已经存在属性不匹配的旧q1队列，需要先登录RabbitMQ管理后台删除旧队列后再运行代码。
• 方案3：关闭占用q1独占队列的旧连接
  如果你确定要独占使用固定名的q1队列，先排查所有存活的RabbitMQ连接，断开占用q1队列的旧连接后再启动当前程序即可。

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