CachingConnectionFactory使用Rabbit客戶端ConnectionFactory的一個實例; 在CachingConnectionFactory上設置等效屬性時,會傳遞許多配置屬性(例如host,port,userName,password,requestedHeartBeat,connectionTimeout)。 要設置其他屬性(例如clientProperties),請定義Rabbit工廠的實例,并使用CachingConnectionFactory的相應構造函數提供對它的引用。 如上所述使用命名空間時,請在connection-factory屬性中提供對已配置工廠的引用。 為方便起見,提供了一個工廠bean來幫助在Spring應用程序上下文中配置連接工廠,如下一節中所述。
~~~
<rabbit:connection-factory
id="connectionFactory" connection-factory="rabbitConnectionFactory"/>
~~~
>4.0.x客戶端默認啟用自動恢復; 雖然與此功能兼容,但Spring AMQP有自己的恢復機制,通常不需要客戶端恢復功能。 建議禁用amqp-client自動恢復,以避免在代理可用時獲取AutoRecoverConnectionNotCurrentlyOpenException,但連接尚未恢復。 您可能會注意到此異常,例如,在RabbitTemplate中配置RetryTemplate時,即使故障轉移到群集中的另一個代理也是如此。 由于自動恢復連接在計時器上恢復,因此可以使用Spring AMQP的恢復機制更快地恢復連接。 從版本1.7.1開始,Spring AMQP禁用它,除非您明確創建自己的RabbitMQ連接工廠并將其提供給CachingConnectionFactory。 RabbitConnectionFactoryBean創建的RabbitMQ ConnectionFactory實例默認情況下也會禁用該選項。
- 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 接收消息
- 介紹
- 輪詢消費者
- 異步消費者