代碼已經(jīng)上傳：rabbitMQTest: rabbitMQ測試代碼，需要的自取

1.springboot整合rabbitMQ

1.1 springboot整合rabbitMQ消費者

1.導(dǎo)入pom.xml依賴

2.定義隊列，交換機，隊列綁定交換機關(guān)系

3.定義springboot啟動類

4. 創(chuàng)建測試springboot啟動類

#rabbitMQ主要依賴

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

1.2 springboot整合rabbitMQ消費者

1.導(dǎo)入pom.xml依賴

2.定義監(jiān)聽器

3.定義springboot啟動類? ??

1.3 消息可靠性保證-消息確認(rèn)和返回機制

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

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

消費端還有一種默認(rèn)簽收機制，簽收機制參數(shù)默認(rèn)有三種：

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

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

1.3.1 實戰(zhàn)講解

消費者服務(wù)springboot-rabbitmq-consumer-advanced

????????啟動類：App，監(jiān)聽類：AckListener

生產(chǎn)者服務(wù)springboot-rabbitmq-advanced

? ? ? ? 啟動類：ProducerAdvancedTest-testConfirmCallback（測試生產(chǎn)者調(diào)用交換機測試案例）ProducerAdvancedTest-testReturnCallback（交換機調(diào)用隊列）

1.4 限流

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

1.4.1 限流實戰(zhàn)案例講解

?消費者服務(wù)springboot-rabbitmq-consumer-advanced

????????啟動類：App，監(jiān)聽類：QosListener

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

生產(chǎn)者服務(wù)springboot-rabbitmq-advanced

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

1.5 rabbit-ttl

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

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

?

?

?

?

?

?

?