批量發送消息可提高傳遞小消息的性能。同時也需要滿足以下特征

• 批量消息要求必要具有同一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批量消息投遞