Spring Cloud Stream 3 RabbitMQ使用者不工作

Question

我可以让Spring+Rabbit以非功能性的方式工作（在2.0之前？），但我试图与功能性模式一起使用，因为以前的模式是不推荐的。

我一直在关注这个文档:https://docs.spring.io/spring-cloud-stream/docs/3.1.0/reference/html/spring-cloud-stream.html#_binding_and_binding_names

队列（使用者）不是用新方法在Rabbit中创建的。我可以看到连接正在创建，但没有任何消费者。

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

它正在取代：

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

和新的班级

@Slf4j
@Service
public class ApprovedReceiver {

    @Bean
    public Consumer<String> approved() {
        // I also saw that it's recommended to not use Consumer, but use Function instead
        // https://docs.spring.io/spring-cloud-stream/docs/3.1.0/reference/html/spring-cloud-stream.html#_consumer_reactive
        return value -> log.info("value: {}", value);
    }

}

它正在取代

// BindableApprovedChannel.class
@Configuration
public interface BindableApprovedChannel {
    @Input("approved")
    SubscribableChannel getApproved();
}

// ApprovedReceiver.class
@Service
@EnableBinding(BindableApprovedChannel.class)
public class ApprovedReceiver {

    @StreamListener("approved")
    public void handleMessage(String payload) {
        log.info("value: {}", payload);
    }
}

Answer 1

如果您有多个类型为函数、供应商或消费者的beans（它们可以由第三方库声明），框架不知道要绑定到哪一个。

尝试将spring.cloud.function.definition属性设置为approved。

https://docs.spring.io/spring-cloud-stream/docs/3.1.3/reference/html/spring-cloud-stream.html#spring_cloud_function

如果您只有java.util.function.[supplier/function/consumer]类型的单个bean，您可以跳过spring.cloud.function.definition属性，因为这样的函数bean将被自动发现。但是，使用这种属性避免任何混淆被认为是最佳做法。有时，这种自动发现可能会成为障碍，因为java.util.function.[suppliver/function/consumer]类型的单个bean可能用于处理消息以外的其他目的，但作为单个bean是自动发现和自动绑定的。对于这些罕见的场景，您可以通过提供将值设置为false的spring.cloud.stream.function.AutoDetect属性来禁用自动发现。