Spring Cloud Stream 3集成RabbitMQ函数式消费模式消费者无法正常工作

核心原因 #

你遇到的问题最核心的原因是Spring Cloud Stream 3.x 函数式模式必须显式声明需要启用的函数Bean，你当前配置中缺少该配置，框架不会自动识别你定义的approved Consumer Bean，因此不会初始化消费者实例，自然不会创建对应队列。

具体解决步骤 #

1. 新增函数声明配置
   在application.properties中添加以下配置，指定要启用的函数名称：

spring.cloud.function.definition=approved

如果存在多个函数需要启用，用分号分隔即可，例如：spring.cloud.function.definition=approved;otherConsumer。
2. 可选：简化Binding配置（非必须）
你当前通过spring.cloud.stream.function.bindings.approved-in-0=approved将默认的binding名称自定义为approved的写法是合法的，只要后续所有binding相关配置都统一使用approved作为binding名即可正常生效。
如果不想自定义别名，也可以直接使用框架默认的binding命名规则（消费者为[函数名]-in-0，生产者为[函数名]-out-0），删除自定义绑定别名配置，将所有binding配置中的approved替换为approved-in-0即可，示例如下：

spring.cloud.stream.bindings.approved-in-0.destination=myTopic.exchange
spring.cloud.stream.bindings.approved-in-0.group=myGroup.approved
spring.cloud.stream.bindings.approved-in-0.consumer.back-off-initial-interval=2000
spring.cloud.stream.rabbit.bindings.approved-in-0.consumer.queueNameGroupOnly=true
spring.cloud.stream.rabbit.bindings.approved-in-0.consumer.bindingRoutingKey=myRoutingKey

3. 补充建议：规范Bean注册
   你当前将Consumer Bean定义在标注了@Service的类中，虽然可以正常运行，但语义不符合规范，建议将存放函数Bean的类改为标注@Configuration注解，避免潜在的代理异常问题。

验证 #

配置修改完成后重启服务，即可在RabbitMQ控制台看到生成的消费者队列（你配置了queueNameGroupOnly=true，队列名称为myGroup.approved），同时能看到对应的消费者实例。

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