RocketMQ原理解析-consumer 4.长轮询push消息—并发消费消息

经过长轮询拉取到消息后会提交到消息服务ConsumeMessageConcurrentlyService,性能 ConsumeMessageConcurrentlyServic的submitConsumeRequest方法构建ConsumeRequest任务提交到线程池。 线程 长轮询向broker拉取消息是批量拉取的, 默认设置批量的值为pullBatchSize= 32,可配置blog 消费端
相关文章
相关标签/搜索