Rabbit MQ 是建立在強大的Erlang OTP平台上,是以安裝Rabbit MQ的前提是安裝Erlang。通過下面兩個連接配接下載下傳安裝3.2.3 版本:
本人遇到的問題
1.建立一個新的maven工程demo1。
2.pom檔案依賴如下。

View Code
3.建立application.properties檔案。
4.建立spring公共配置檔案applicationContext.xml。

5.建立Rabbit MQ的配置檔案。

6.建立MQ消息實體類(MqMessage.java)。

7.建立MQ消息發送接口 (MQSender.java)。
8.建立MQ消息發送實作類 MQSenderImpl.java。
9.建立消息監聽器QueueListenter.java。
10.終于到最後一步了,建立測試類。
11.最終結果,消息監聽器中的輸出如下。
12.浏覽器中輸入“http://localhost:15672/”,進入 Rabbit MQ的管理系統,檢視 queue和exchange對應的相關資訊如下。
1.對MQ的生産者和消費者做了一些簡單的封裝,同一放到了一個工程下面裡。無論是生産者還是消費者,隻需要依賴上這個工程對應的jar就可以了。另外就是依賴上這個工程中MQ對應的XML檔案。工程的基本結構如下所示。
2.XML檔案如下。

3.消費者。

4.生産者。

示例中去掉了 Exchange,可以在完整項目中檢視關于Exchange的配置。
5.消費者web2工程
繼承封裝過的MQ消費者抽象類,實作為實作的方法,将消息放入全局application對象中。

從全局application對象中擷取消息并傳回。

spring公共配置檔案中<beans/>屬相中加入如下配置。
6.生産者web1工程

7.簡單模拟MQ消息發送和接收web工程

8.tomcat下啟動demo2中的web,web1,web2三個工程。浏覽器中輸入:http://127.0.0.1:port/web,參看 MQ 模拟示例。