代碼已經上傳：rabbitMQTest: rabbitMQ測試代碼，需要的自取

1.springboot整合rabbitMQ

1.1 springboot整合rabbitMQ消費者

1.導入pom.xml依賴

2.定義隊列，交換機，隊列綁定交換機關系

3.定義springboot啟動類

4. 創建測試springboot啟動類

#rabbitMQ主要依賴

            org.springframework.boot
            spring-boot-starter-amqp
        

1.2 springboot整合rabbitMQ消費者

1.導入pom.xml依賴

2.定義監聽器

3.定義springboot啟動類? ??

1.3 消息可靠性保證-消息確認和返回機制

?producer->broker->exchange過程可以使用消息確認機制判斷交換機是否接收到。

exchange->queue過程可以使用消息返回機制判斷隊列是否存在，不存在還可以退回，我們可以做一些日志持久化的操作保證消息可靠性。

消費端還有一種默認簽收機制，簽收機制參數默認有三種：

"manual":手動簽收 none-自動簽收 auto-根據異常情況簽收

異常也可以選擇拒收，拒收以后會返回queue，broker會繼續返回給消費者。

1.3.1 實戰講解

消費者服務springboot-rabbitmq-consumer-advanced

????????啟動類：App，監聽類：AckListener

生產者服務springboot-rabbitmq-advanced

? ? ? ? 啟動類：ProducerAdvancedTest-testConfirmCallback（測試生產者調用交換機測試案例）ProducerAdvancedTest-testReturnCallback（交換機調用隊列）

1.4 限流

?設置限流需要設置消費端配置文件spring-rabbitmq-consumer.xml中得prefetch參數，表示消費者每次抓取多少消息。

1.4.1 限流實戰案例講解

?消費者服務springboot-rabbitmq-consumer-advanced

????????啟動類：App，監聽類：QosListener

????????spring-rabbitmq-consumer.xml-prefetch參數代表每次拉取多少消息

生產者服務springboot-rabbitmq-advanced

? ? ? ? 啟動類：ProducerAdvancedTest-testQosListener（測試限流）

1.5 rabbit-ttl

?延時隊列，在rabbitmq得頁面可以設置，在建立隊列時設置最多保持幾秒失效參數。

1.建立交換機 2.建立隊列，設置ttl參數?3. 綁定隊列到交換機 4. 發布消息 5.測試消息失效

?

?

?

?

?

?

?