rocketmq提供批量发送消息的机制，但消息发送的数据包大小不能超过1M 示例代码：
String topic = "BatchTest";List messages = new ArrayList<>();
messages.add(new Message(topic, "TagA", "OrderID001", "Hello world 0".getBytes()));
messages.add(new Message(topic, "TagA", "OrderID002", "Hello world 1".getBytes()));
messages.add(new Message(topic, "TagA", "OrderID003", "Hello world 2".getBytes()));
try {
producer.send(messages);
} catch (Exception e) {
e.printStackTrace();
//handle the error
}
当数据量超过1M的时候,或者不确定数据量是否会超过1M 最好使用分割的方式 ：参考链接 ：批量分割
网友评论