码迷,mamicode.com
首页 > 其他好文 > 详细

rocketmq批量消息投递

时间:2018-08-02 13:58:28      阅读:133      评论:0      收藏:0      [点我收藏+]

标签:str   messages   stack   style   发送   分割   批量   特征   示例   

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

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

标签:str   messages   stack   style   发送   分割   批量   特征   示例   

原文地址:https://www.cnblogs.com/peachyy/p/9406550.html

(0)
(0)
   
举报
评论 一句话评论(0
登录后才能评论!
© 2014 mamicode.com 版权所有  联系我们:gaon5@hotmail.com
迷上了代码!