RocketMQ原理解析-consumer 4.長輪詢push消息—併發消費消息

經過長輪詢拉取到消息後會提交到消息服務ConsumeMessageConcurrentlyService,性能 ConsumeMessageConcurrentlyServic的submitConsumeRequest方法構建ConsumeRequest任務提交到線程池。 線程 長輪詢向broker拉取消息是批量拉取的, 默認設置批量的值爲pullBatchSize= 32,可配置blog 消費端
相關文章
相關標籤/搜索