如何检查消息队列是否已经存在？
我有两个不同的应用程序，一个创建队列，另一个从队列中读取。
因此，如果我先运行从队列中读取的客户端，则会崩溃。为了避免这种情况，我想先检查队列是否存在。
这里是我读取队列的代码片段：
QueueingBasicConsumer <ConsumerName> = new QueueingBasicConsumer(<ChannelName>);
<ChannelName>.BasicConsume("<queuename>", null, <ConsumerName>);
BasicDeliverEventArgs e = (BasicDeliverEventArgs)<ConsumerName>.Queue.Dequeue();
不用费力查看。
queue.declare 是一个幂等操作。因此，无论您运行一次、两次还是N次，结果仍然相同。
如果您想确保队列存在，请在使用之前先声明它。确保每次声明的耐久性、排他性和自动删除性相同，否则您将会得到异常。
如果您确实需要检查队列是否存在（通常情况下不需要），请对队列进行被动声明。该操作成功表示队列存在，如果不存在，则返回错误信息。
将以下代码放入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);
}
当有其他应用程序负责q声明时，这种方法将无效。而且我可能不知道q的所有参数，只知道其名称。
我更倾向于使用passiveDeclare并检查IOException以确保q不存在。
目前您可以通过RabbitMQ Management HTTP API获取这些信息和更多内容。
例如，要了解当前是否有一个队列正在运作，您可以调用API的/api/queues/vhost/name接口的GET方法。
Spring AMQP（Java 实现）中有一个元数据 API。
@Autowired
public RabbitAdmin rabbitAdmin;
//###############get you queue details##############
Properties properties = rabbitAdmin.getQueueProperties(queueName);
//do your custom logic
if( properties == null)
{
createQueue(queueName);
}
channel.QueueDeclarePassive(QueueName)可以让您在不尝试重新声明队列的情况下检查队列的存在（例如，如果更改了队列设置，否则会引发异常）。QueueDeclarePassive()似乎只检查根虚拟主机。如果您的目标队列实际上位于自定义虚拟主机中，则可能会得到错误的负面结果（未经测试）。如果在根虚拟主机中存在具有相同名称的队列，则肯定会得到错误的正面结果（已经测试）。QueueDeclare()放在try-catch中可能是更好的方法，但依我个人的看法，您将获得的RabbitMQ.Client.Exceptions.OperationInterruptedException过于宽泛，这样做并不安全。 @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.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) ;
}