开发者社区 > 云原生 > 云消息队列 > 正文

RocketMQ中5.x sdk 消费的时候 如何保证同一个队列的消息只会被同一个消费者消费?

"RocketMQ中5.x sdk 消费的时候 PushConsumer 如何保证 消费顺序的 同一个消费者组 中 如何保证 同一个队列的消息 只会被同一个消费者消费。
2eb93d5366f703c933fd5a6e1355d7d9.png
"

展开
收起
十一0204 2023-08-15 23:32:35 288 0
1 条回答
写回答
取消 提交回答
  • 在 RocketMQ 5.x 中,可以通过设置 MessageListenerConcurrently 的 consumeConcurrently 属性来保证同一个队列的消息只会被同一个消费者消费。

    如果 consumeConcurrently 属性为 false,则表示单线程消费,同一个队列的消息只能被一个消费者消费。如果 consumeConcurrently 属性为 true,则表示多线程消费,同一个队列的消息可以被多个消费者消费。

    默认情况下,consumeConcurrently 属性的值为 false。

    2023-09-27 15:42:06
    赞同 展开评论 打赏

涵盖 RocketMQ、Kafka、RabbitMQ、MQTT、轻量消息队列(原MNS) 的消息队列产品体系,全系产品 Serverless 化。RocketMQ 一站式学习:https://rocketmq.io/

相关产品

  • 云消息队列 MQ
  • 相关电子书

    更多
    RocketMQ Client-GO 介绍 立即下载
    RocketMQ Prometheus Exporter 打造定制化 DevOps 平台 立即下载
    基于 RocketMQ Prometheus Exporter 打造定制化 DevOps 平台 立即下载