在 spring-rabbitmq 中连接到队列或创建不存在

Question

我正在使用带有 spring-rabbitmq 的 Spring Boot。我的连接工厂是在application.properties 中配置的，看起来不错。

我的目标是：在开始检查是否存在特定名称的队列，如果不存在则创建这样的队列。我不知道如何处理它。我应该在配置类中创建什么 bean？从我读到的应该是 RabbitAdmin，但我不确定。你能帮助我吗？

Answer 1

Reference Manual 中的所有内容都描述得很清楚：

AMQP 规范描述了如何使用该协议在代理上配置队列、交换和绑定。这些可从 0.8 及更高版本移植的操作存在于 org.springframework.amqp.core 包的 AmqpAdmin 接口中。

还有：

当 CachingConnectionFactory 缓存模式为 CHANNEL（默认）时，RabbitAdmin 实现会自动延迟声明在同一 ApplicationContext 中声明的队列、交换和绑定。

因此，您应该在应用程序上下文中声明 Queue、Exchange 和 Binding bean，AmqpAdmin 将注意它们在目标代理上的定义。

需要注意的是，根据AMQP协议，如果实体已经存在于Broker上，则声明只是静默和幂等的。

因此，在您的情况下，您无需担心队列的存在，只需在应用程序上下文中将它们的声明作为 bean 提供。