rocketmq设置批量消费的消息数

在 RocketMQ 中，可以通过设置消费者的 MessageListenerConcurrently 或 MessageListenerOrderly 的 consumeMessage 方法中的 List<MessageExt> msgs 参数来控制一次批量消费的消息数。默认情况下，一次消费只消费一条消息，如果需要批量消费，则可以将该参数中的消息列表大小设置为大于 1 的值。

例如，在 MessageListenerConcurrently 中，可以像下面这样设置批量消费的消息数：

public class MyMessageListener implements MessageListenerConcurrently {
    @Override
    public ConsumeConcurrentlyStatus consumeMessage(List<MessageExt> msgs, ConsumeConcurrentlyContext context) {
        // 将消息列表大小设置为 10，表示一次消费最多消费 10 条消息
        if (msgs.size() > 10) {
            msgs = msgs.subList(0, 10);
        }
        // 处理消息
        for (MessageExt msg : msgs) {
            // TODO: 处理消息
        }
        return ConsumeConcurrentlyStatus.CONSUME_SUCCESS;
    }
}

类似地，在 MessageListenerOrderly 中也可以通过设置 batchToList 参数来实现批量消费。例如：

public class MyMessageListener implements MessageListenerOrderly {
    @Override
    public ConsumeOrderlyStatus consumeMessage(List<MessageExt> msgs, ConsumeOrderlyContext context) {
        // 将消息列表大小设置为 10，表示一次消费最多消费 10 条消息
        if (msgs.size() > 10) {
            msgs = msgs.subList(0, 10);
        }
        // 处理消息
        for (MessageExt msg : msgs) {
            // TODO: 处理消息
        }
        return ConsumeOrderlyStatus.SUCCESS;
    }
}