Как я могу проверить, существует ли очередь сообщений RabbitMQ или нет?

Не утруждайте себя проверкой.

queue.declare — это идемпотентная операция. Итак, если вы запустите его один, два, N раз, результат все равно будет таким же.

Если вы хотите убедиться, что очередь существует, просто объявите ее перед использованием. Убедитесь, что вы объявляете его с одинаковой долговечностью, эксклюзивностью, автоудалением каждый раз, иначе вы получите исключение.

Если вам действительно нужно проверить, существует ли очередь (обычно вам это не нужно), выполните пассивное объявление очереди. Эта операция завершается успешно, если очередь существует, или завершается ошибкой, если ее нет.

Это не будет работать в ситуациях, когда за объявление q отвечает кто-то другой (другое приложение). И я просто не мог знать всех параметров q, только название.

Я бы предпочел использоватьpassiveDeclare и проверить наличие IOException, что q не существует

В настоящее время вы можете узнать эту информацию и многое другое через HTTP API управления RabbitMQ.

Например, чтобы узнать, работает ли одна очередь в данный момент, вы можете вызвать интерфейс GET /api/queues/vhost/name API.

Поместите код ниже в раздел 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);
    }

Используйте QueueDeclare(), чтобы выполнить это, как было предложено. Кроме того, что мы всегда делали, так это делали потребителя очереди владельцем очереди и всегда публиковали на биржах, которые созданы и принадлежат издателям. Затем потребители привязывают свои очереди к биржам, от которых они хотят получать трафик, и используют соответствующий фильтр ключа маршрута для нужного трафика. Таким образом, издатели не отключаются потребителями для неустойчивых очередей, а потребители могут свободно приходить и уходить с устойчивыми или кратковременными очередями, сопоставленными с соответствующими ключами маршрута.

Это приводит к легко администрируемой системе и позволяет использовать веб-администрирование для создания надежной очереди и привязки ее к обмену, получения некоторого трафика, отсоединения его, а затем проверки содержимого очереди, чтобы понять, какой трафик и нагрузка проходят через обмен. .

В 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);
}