Spring Cloud Stream 3.2.1整合RabbitMQ无法创建队列与绑定问题

问题根因与解决方案 #

一、无法自动创建队列与绑定的解决步骤 #

• 检查binder依赖
  确保项目引入了与Spring Cloud Stream 3.2.1版本匹配的spring-cloud-starter-stream-rabbit依赖，未引入其他冲突的binder实现。
• 修正source配置分隔符
  你当前配置中spring.cloud.stream.source使用分号分隔多值，Spring Cloud Stream该配置的多值分隔符为逗号，修改配置如下：

spring: 
  cloud:
    stream: 
      source: direct-smtp-gateway-message,direct-smtp-remote-delivery,direct-sta-processor,direct-sta-post-process,direct-sta-last-mile,direct-xd-delivery

• 显式开启Rabbit侧自动声明配置
  可在配置中显式指定消费者端的队列、交换机、绑定自动声明开关，避免全局配置覆盖默认值：

spring: 
  cloud:
    stream: 
      rabbit:
        bindings:
          directXDDeliveryInput-in-0:
            consumer:
              declareExchange: true
              declareQueue: true
              bindQueue: true

• 检查消费者自动启动配置
  确认没有配置spring.cloud.stream.bindings.directXDDeliveryInput-in-0.consumer.auto-startup=false，该配置默认值为true，若设为false会导致消费者Bean不启动，不会触发队列创建逻辑。

二、手动创建队列后无法消费的解决步骤 #

• 统一消息序列化规则
  你发送端使用自定义的SMTPMailMessageConverter转换消息，需要保证消费者侧也注册了相同的转换器，或者统一配置两端的content-type为通用序列化格式：

spring: 
  cloud:
    stream: 
      bindings:
        direct-xd-delivery-out-0:
          content-type: application/json
        directXDDeliveryInput-in-0:
          content-type: application/json

• 检查路由键匹配规则
  Spring Cloud Stream Rabbit binder默认使用topic类型交换机，默认输出路由键为#，如果你手动绑定时指定了非默认的路由键，会导致消息无法匹配进入队列，可显式指定两端路由键保持一致：

spring: 
  cloud:
    stream: 
      rabbit:
        bindings:
          direct-xd-delivery-out-0:
            producer:
              routing-key-expression: "'xd-delivery-rk'"
          directXDDeliveryInput-in-0:
            consumer:
              bindingRoutingKey: "xd-delivery-rk"

• 验证RabbitMQ账号权限
  确认应用使用的RabbitMQ账号拥有目标队列的读取、消费权限，权限不足会导致消费者无法拉取消息。
• 排查启动日志
  应用启动时搜索包含directXDDeliveryInput、direct-xd-delivery-process-group的日志，排查是否有函数初始化失败、绑定失败的报错信息，可快速定位具体问题。

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