要每次讀取50條訊息,進入演算法模塊
uj5u.com熱心網友回復:
可以結合多消費者和預取來控制吧uj5u.com熱心網友回復:
分為多個佇列,每個佇列擁有多個消費者,具體的配置根據你服務器的性能決定。uj5u.com熱心網友回復:
有批量發送的配置,配置一次發送多少條訊息給消費者uj5u.com熱心網友回復:
container.setConcurrentConsumers(50);uj5u.com熱心網友回復:
prefetch="120" 批量取120
concurrency="2" 并發2個
<rabbit:listener-container connection-factory="connectionFactory" acknowledge="auto" prefetch="120" concurrency="2">
<rabbit:listener ref="com.xxx.Listener" queues="xxxQueue" method="listener"/>
</rabbit:listener-container>
uj5u.com熱心網友回復:
你好,請問一下,在basicAck方法中multiple引數是指的就是批量提交prefetch的個訊息嗎?
轉載請註明出處,本文鏈接:https://www.uj5u.com/qita/242040.html
標籤:高性能WEB開發
上一篇:羅斯蒙特流量計指示故障的原因
