机灵未来

文章
13
资源
0
加入时间
4年0月4天

RocketMQ使用批量消息说明生产端消费端遗留问题

目录说明生产端消费端遗留问题说明批量发送消息条件:1、发送到同一个topic2、等待同一个发送结果3、不允许使用定时消息4、不支持半事务特性5、同一批消息大小不能超过1MB,否则需要自己进行切割发送批量消息,最主要的区别是在发送消息的send方法入参一个List。生产端@Test public void sendMessage() throws Exception { DefaultMQProducer defaultMQProducer = RocketMqUt