tongchenkeji
发表于：0次点击

各位大佬 Apache RocketMQ4.9.4 设置了获取的消息还是一条?都消费了 但是每次都是[阿里云消息队列MQ]

各位大佬 Apache RocketMQ4.9.4 设置了consumeMessageBatchMaxSize=32为什么每次MessageListenerConcurrently获取的消息还是一条?都消费了 但是每次都是一条一条的消费，因为我在消费端有入库操作 这样的话每次只能插入一条 不是性能很低

「点点赞赏，手留余香」

    还没有人赞赏，快来当第一个赞赏的人吧！
消息队列 MQ# Apache292# 云消息队列 MQ1430
=====这是一个广告位，招租中，联系qq 78315851====
消息队列 MQ
各位大佬 RocketMQ的nodejs客户端库 是否只支持Linux系统,在Windows系统是？[阿里云消息队列MQ]
消息队列 MQ
请教一下，我在配外网访问rocketmq。但是console总提示链接失败，不知道咋回事。能指导以？[阿里云消息队列MQ]
2 条回复 A 作者 M 管理员

  1. 你看看你你数据没有消费的是多少， 最大消费不是每次都这样,你数据没有积压,他都是来一条消费一条 这么达到32，此回答整理自钉群“群2-Apache RocketMQ 中国开发者钉钉群”

    已喜欢 已反对
    1. 设置consumeMessageBatchMaxSize参数,指定一次能拉取的最大消息数,例如你设置为32。
    2. 消费端实现MessageListenerOrderly接口,而不是MessageListenerConcurrently接口。Orderly表示有序消费,会批量消费消息。
    3. 在MessageListenerOrderly#consumeMessage接口实现中,可以获取到消息列表List,而不是单条消息。
    4. 消费实现中,可以循环该列表,批量处理多条消息。
    5. 消息处理完后,需要调用consumeOrderly(); 表示批量消费完,可以拉取下一批消息。
    已喜欢 已反对

  3. 可以看下消息是不是以批量的方式发送到 RocketMQ Broker。如果消息发送端是逐条发送消息，即使在消费端设置了批量消费的参数，也无法批量获取到消息。

    还有就是确认配置生效，可以打印日志看下是否是配置的却是consumeMessageBatchMaxSize=32

    已喜欢 已反对