消費RabbitMQ時的注意事項,如何禁止大量的消息涌到Consumer,保證線程安全

按照官網提供的訂閱型寫法( Retrieving Messages By Subscription ("push API")) 我發現,RabbitMQ服務器會在短時間內發送大量的消息給Consumer,然後,如果你沒有來得及Ack的話,那麼服務端會積壓大量的UnAcked消息,而Consumer如果來不急處理也會處於假死(也可能引起程序崩潰)。 僅有兩個Channel,結果積壓了大量的UnAck
相關文章
相關標籤/搜索