如何检查RabbitMQ消息队列是否存在？

Question

如何检查消息队列是否已存在？

我有两个不同的应用程序，一个创建队列，另一个从该队列读取。

因此，如果我运行首先从队列中读取的客户端，它就会崩溃。
因此，为了避免这种情况，我想首先检查队列是否存在。

这是我如何读取队列的代码片段：

QueueingBasicConsumer <ConsumerName> = new QueueingBasicConsumer(<ChannelName>); 
<ChannelName>.BasicConsume("<queuename>", null, <ConsumerName>); 
BasicDeliverEventArgs e = (BasicDeliverEventArgs)<ConsumerName>.Queue.Dequeue();

Answer 1

不用费心检查。

queue.declare 是一个幂等操作。所以，如果你运行一次、两次、N次，结果仍然是一样的。

如果要确保队列存在，只需在使用前声明即可。确保每次都以相同的持久性、排他性、自动删除性来声明它，否则您将得到例外。

如果您确实需要检查队列是否存在（通常不需要），请对队列进行被动声明。如果队列存在，则该操作成功；如果不存在，则操作失败并出现错误。

Answer 2

将以下代码放入 try catch 部分。如果队列或交换器不存在，则会抛出错误。如果存在它不会做任何事情。

  var channel = connection.CreateModel();


  channel.ExchangeDeclarePassive(sExchangeName);

  QueueDeclareOk ok = channel.QueueDeclarePassive(sQueueName);

   if (ok.MessageCount > 0)
    {
      // Bind the queue to the exchange

     channel.QueueBind(sQueueName, sExchangeName, string.Empty);
    }

Answer 3

当有其他人（其他应用程序）负责 q 声明时，这将不起作用。我根本不知道 q 的所有参数，只知道名称。

我宁愿使用 PassiveDeclare 并检查 q 不存在的 IOException

Answer 4

目前，您可以通过 RabbitMQ 管理 HTTP API。

例如，要了解此时是否有一个队列已启动，可以调用 API 的 GET /api/queues/vhost/name 接口。

Answer 5

spring-amqp中有一个meta api（java实现）

@Autowired
public RabbitAdmin rabbitAdmin;

//###############get you queue details##############
Properties properties = rabbitAdmin.getQueueProperties(queueName);

//do your custom logic
if( properties == null)
{
    createQueue(queueName);
}

Answer 6

正如其他答案中提到的，channel.QueueDeclarePassive(QueueName) 将允许您检查队列是否存在，而无需尝试重​​新声明（例如，如果您更改了队列设置，否则会导致异常）。

但是，QueueDeclarePassive()似乎只检查根虚拟主机。如果您的目标队列实际上位于自定义虚拟主机中，您可能（尚未测试）得到漏报。如果根虚拟主机中存在同名队列，您将（经过测试）得到误报。

也许将 QueueDeclare() 包装在 try-catch 中可能是一个更好的方法，尽管在我看来，您将得到的 RabbitMQ.Client.Exceptions.OperationInterruptedException 太包罗万象了使其成为一种安全的方法。

Answer 7

按照建议使用 QueueDeclare() 执行此操作。此外，我们一直所做的就是让队列的使用者成为队列的所有者，并始终发布到由发布者创建和拥有的 Exchange。然后，消费者将他们的队列绑定到他们希望从中接收流量的交换机，并为他们想要的流量使用适当的路由键过滤器。通过这种方式，发布者不会被非持久队列的消费者静音，并且消费者可以自由地使用与适当的路由键映射的持久或非持久队列来来去去。

这会形成一个易于管理的系统，并允许使用 Web 管理来创建持久队列并将其绑定到交换器，获取一些流量，解除绑定，然后检查队列内容以了解通过交换器的流量和负载。

Answer 8

以我的愚见，最好的方法是覆盖rabbitmq的默认配置。

主类应该禁用默认的rabbit配置：

    @SpringBootApplication
    @EnableAutoConfiguration(exclude 
  {org.springframework.boot.autoconfigure.amqp.RabbitAutoConfiguration.class})
  public class MyApplication {

    public static void main(String[] args) {
        SpringApplication.run(MyApplication.class, args);
    }

}

我的rabbitmq属性位于rabbitmq.properties文件中：

...
    rabbitmq.queue=my-queue
...

然后只需创建自己的配置rabbitmq组件：

@Component
@EnableRabbit
@PropertySource("classpath:rabbitmq.properties")
public class RabbitMQConfiguration
{
...
    @Value("${rabbitmq.queue}")
    private String queueName;

...

    @Bean
    public Queue queue() {
        return new Queue(queueName, false);
    }
...

还应该设置消费者：

@Component
@PropertySource("classpath:rabbitmq.properties")
public class MyConsumer
{
    private static Logger LOG = LogManager.getLogger(MyConsumer.class.toString());

    @RabbitListener(queues = {"${rabbitmq.queue}"})
    public void receive(@Payload Object data) {
        LOG.info("Message: " + data) ;
    }

现在，当客户端启动时，它会自动创建队列，如果它不存在。如果队列存在，则不执行任何操作。