>Spring AMQP還通過使用`@RabbitListener`注解來支持帶注解的偵聽器端點,并提供一個開放式基礎結構來以編程方式注冊端點。 這是設置異步使用者最方便的方法,有關詳細信息,請參閱“注解驅動的偵聽器端點”一節。
>
>預取默認值曾經是1,這可能導致高效消費者利用不足。 從版本2.0開始,默認預取值現在為250,這應該使消費者在大多數常見場景中都很忙,從而提高吞吐量。
>然而,預取值應該是低的情況:例如,對于大消息,特別是如果處理很慢(消息可能在客戶端進程中添加大量內存),并且如果需要嚴格的消息排序( 在這種情況下,預取值應該設置回1)。
>此外,對于低容量消息傳遞和多個使用者(包括單個偵聽器容器實例中的并發),您可能希望減少預取以在消費者之間獲得更均勻的消息分發。 還建議在`MANUAL` ack模式下使用`prefetch = 1`。 `basicAck`是異步操作,如果在Broker上發生錯誤(例如,對于相同的傳遞標記,雙重確認),您最終會在批處理中處理后續處理的消息,但在Broker和其他消費者處可以看到它們。
- 1.前言
- 2.介紹
- 2.1 快速瀏覽
- 3.參考
- 3.1 使用spring amqp
- 3.1.1 AMQP抽象
- 3.1.2 資源的連接和管理
- 介紹
- 配置底層客戶端連接工廠
- RabbitConnectionFactoryBean和配置SSL
- 路由連接工廠
- 隊列親和力和LocalizedQueueConnectionFactory
- 發送確認和返回
- 3.1.3 添加自定義客戶端連接屬性
- 3.1.4 AmqpTemplate
- 介紹
- 添加重試功能
- 發送消息是異步的 - 如何檢測成功和失敗
- 發布的確認和返回
- 3.1.5 發送消息
- 介紹
- 消息構建 API
- 發布的返回
- 3.1.6 接收消息
- 介紹
- 輪詢消費者
- 異步消費者