spring-cloud-stream - Spring Cloud Stream + RabbitMQ Publisher 确认

标签 spring-cloud-stream

我计划在我的项目中使用 Spring Cloud Stream。 是否可以使用发布者确认(又名发布者确认),即注册确认回调,如 http://docs.spring.io/spring-amqp/reference/html/_reference.html#cf-pub-conf-ret 中所述。 ?或者是否有其他可能性从 RabbitMQ 接收来自客户端的消息的确认?

最佳答案

没有;它不受支持。但是,您可以在生产者上设置transactional 标志,这会在发送失败时引发异常。

虽然发布者确认通常比交易“快”得多,但实际上只有当您发送一堆消息并稍后等待他们的确认时才会出现这种情况。

因为我们在这里处于流中;您将发送一条消息,然后等待确认。这不会比仅使用事务快得多。

如果你想使用确认;您必须直接使用 RabbitTemplate 或 Spring Integration 出站 channel 适配器,而不是 Binder 。

关于spring-cloud-stream - Spring Cloud Stream + RabbitMQ Publisher 确认,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/43234942/

相关文章:

java - 仅拦截来自消费者的 Spring Cloud Stream 消息

java - Spring Cloud Contract 和两个既是生产者又是消费者的服务

java - 如何使用Spring Cloud Stream实现自定义kafka分区

spring-cloud-stream - 在 Spring Cloud Data Flow 中使用一个源、两个并行处理器和一个接收器创建流

java - 如何使用 Spring Cloud Stream 和 Kafka Streams Binder 暂停(打开/关闭)流处理?

java - Spring Cloud Stream Kinesis Binder - 并发

java - kafka 0.8.2.2有spring支持吗?

spring-boot - Kafka 消费者指标从 Spring Boot 2.2.2 升级到 2.3.0

spring - 响应式Spring Cloud Stream从队列中读取所有数据,但非响应式则一条一条地读取消息

apache-kafka - 卡夫卡流 : Define multiple Kafka Streams using Spring Cloud Stream for each set of topics