Spring RabbitMQ如何在运行时动态添加绑定配置路由键

结论 #

Spring AMQP 完全支持运行时动态新增/移除绑定、调整监听路由键，无需重启应用，不需要直接操作原生Channel即可实现和原生Java客户端一致的效果。

实现方式 #

你现有的启动阶段声明Queue、Exchange、初始绑定、SimpleMessageListenerContainer的代码不需要改动，只需要基于Spring AMQP内置的AmqpAdmin客户端做动态资源操作即可：

1. 注入依赖Bean
   引入spring-boot-starter-amqp依赖后，Spring会自动装配AmqpAdmin实例，直接注入使用即可，同时注入你已经声明的队列、交换机实例：

   @Autowired
   private AmqpAdmin amqpAdmin;
   @Autowired
   private Queue springQueue; // 对应定义的SPRINGQUEUE实例
   @Autowired
   private TopicExchange springExchange; // 对应定义的SPRINGEXCHANGE实例
   

2. 动态新增路由键绑定
   在业务逻辑触发需要新增监听路由键的时机，调用以下方法即可，绑定生效后匹配该路由键的消息会自动投递到你正在监听的队列，现有监听器无需做任何调整就能收到消息：

   public void addQueueBinding(String routingKey) {
       Binding binding = BindingBuilder.bind(springQueue)
               .to(springExchange)
               .with(routingKey);
       amqpAdmin.declareBinding(binding);
   }
   

3. 动态移除路由键绑定
   如果需要取消某个路由键的监听，调用移除绑定方法即可，操作完成后对应路由键的消息就不会再投递到当前队列：

   public void removeQueueBinding(String routingKey) {
       Binding binding = BindingBuilder.bind(springQueue)
               .to(springExchange)
               .with(routingKey);
       amqpAdmin.removeBinding(binding);
   }
   

注意事项 #

• 动态添加/移除的绑定是直接操作RabbitMQ Broker端的资源，操作即时生效
• 动态绑定关系不会在应用重启后自动保留，重启后会回到你启动阶段配置的初始绑定状态，如果需要持久化动态配置，可以将自定义路由键存储在数据库/配置中心，应用启动时遍历加载声明即可
• 重复声明相同的绑定关系不会抛出异常，但会生成冗余绑定记录，建议在业务层加本地缓存做校验，避免重复执行绑定操作

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