rocketmq批量消息投递
Posted peachyy
tags:
篇首语:本文由小常识网(cha138.com)小编为大家整理,主要介绍了rocketmq批量消息投递相关的知识,希望对你有一定的参考价值。
批量发送消息可提高传递小消息的性能。同时也需要满足以下特征
小于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投递策略帮你解决问题!博学谷狂野架构师