rocketmq批量消息投递

Posted peachyy

tags:

篇首语:本文由小常识网(cha138.com)小编为大家整理,主要介绍了rocketmq批量消息投递相关的知识,希望对你有一定的参考价值。

批量发送消息可提高传递小消息的性能。同时也需要满足以下特征

  • 批量消息要求必要具有同一topic、相同消息配置
  • 不支持延时消息
  • 建议一个批量消息最好不要超过1MB大小

    示例

小于1MB

String topic = "BatchTest";
List<Message> messages = new ArrayList<>();
messages.add(new Message(topic, "TagA", "Order1", "Hello world 0".getBytes()));
messages.add(new Message(topic, "TagA", "Order2", "Hello world 1".getBytes()));
messages.add(new Message(topic, "TagA", "Order3", "Hello world 2".getBytes()));
try {
    producer.send(messages);
} catch (Exception e) {
    e.printStackTrace();
}

大于1MB也可以使用分割消息的方式进行多次批量发送。

技术分享图片

以上是关于rocketmq批量消息投递的主要内容,如果未能解决你的问题,请参考以下文章

小心,丢失的消息!RocketMQ投递策略帮你解决问题!博学谷狂野架构师

RocketMQ源码 — 九 RocketMQ延时消息

RocketMQ源码 — 九 RocketMQ延时消息

RocketMQ源码 — 九 RocketMQ延时消息

RocketMQ源码(24)—DefaultMQPushConsumer延迟消息源码

rocketmq架构设计