這篇文章將為大家詳細講解有關(guān)SpringMVC消費RabbitMQ隊列的示例分析，小編覺得挺實用的，因此分享給大家做個參考，希望大家閱讀完這篇文章后可以有所收獲。

長洲ssl適用于網(wǎng)站、小程序/APP、API接口等需要進行數(shù)據(jù)傳輸應用場景，ssl證書未來市場廣闊！成為創(chuàng)新互聯(lián)的ssl證書銷售渠道，可以享受市場價格4-6折優(yōu)惠！如果有意向歡迎電話聯(lián)系或者加微信：18980820575（備注：SSL證書合作）期待與您的合作！

1.環(huán)境介紹

• Jdk1.8.0_202

• Spring 4.3.9.RELEASE

• spring-webmvc 4.3.9.RELEASE

2.添加Maven依賴

   com.rabbitmq
   amqp-client
   5.6.0


   org.springframework.amqp
   spring-amqp
   2.0.12.RELEASE


   org.springframework.amqp
   spring-rabbit
   2.0.12.RELEASE


   org.springframework.retry
   spring-retry
   1.2.4.RELEASE

3.添加RabbitMQ配置

在jdbc.properties文件中加入RabbitMQ地址端口用戶密碼等信息

#RabbitMQ地址
mq_host=127.0.0.1
#RabbitMQ端口
mq_port=5672
#RabbitMQ虛擬主機
mq_virtual_host=/
#RabbitMQ用戶名
mq_username=admin
#RabbitMQ密碼
mq_password=your rabbitmq password

4.創(chuàng)建RabbitMQ配置文件

新建 applicationContext-rabbitmq.xml

內(nèi)容如下

    RabbitMQ 連接服務配置
    
    
    
    
    
    
    
    
    
    
    
    
    
    
        
            
            
        
    

    
    
        
        
        
    

5.創(chuàng)建監(jiān)聽器消費者

創(chuàng)建與ref="plateNumRabbitConsumer"對應的消費者類，必須添加注解@Component加入Spring管理，實例名可自定義，但必須與ref關(guān)聯(lián)的名字一致；消費者類必須實現(xiàn)MessageListener，監(jiān)聽隊列的變化，實現(xiàn)實時消費；

遇到的問題

• 同一個項目中若同時存在生產(chǎn)者和消費者，applicationContext-rabbitmq.xml中聲明的工廠，路由，隊列都無特別注意的地方；生產(chǎn)者需要使用到rabbit:template，消費者不需要此配置即可行

• 若只需消費隊列，在聲明隊列時，若rabbitmq服務中已創(chuàng)建過同名隊列，則必須配置ignore-declaration-exceptions="true"，否則項目啟動時將報錯

• 監(jiān)聽容器的配置，需注意prefetch="1" 和 acknowledge="auto"，prefetch表示單次從隊列中消費的數(shù)量，prefetch=”1”，說明單次消費1條消息，若容器中配置多個監(jiān)聽器消費，則會公平分發(fā)；acknowledge="auto" 表示自動應答，消費完成后回復確認，改消息將從rabbitmq服務中刪除，并且會自動消費下一條消息，acknowledge=" manual"表示手動應答 當消息處理失敗時:會一直重發(fā) 直到消息處理成功,需要自己手動提交；否則不會繼續(xù)消費；手動應答方式需要配置template的confirm-callback回調(diào)方法；

關(guān)于“SpringMVC消費RabbitMQ隊列的示例分析”這篇文章就分享到這里了，希望以上內(nèi)容可以對大家有一定的幫助，使各位可以學到更多知識，如果覺得文章不錯，請把它分享出去讓更多的人看到。