天天看點

RabbitMQ安裝和使用(和Spring內建)

  Rabbit MQ 是建立在強大的Erlang OTP平台上,是以安裝Rabbit MQ的前提是安裝Erlang。通過下面兩個連接配接下載下傳安裝3.2.3 版本:

本人遇到的問題

  1.建立一個新的maven工程demo1。

  2.pom檔案依賴如下。

RabbitMQ安裝和使用(和Spring內建)
RabbitMQ安裝和使用(和Spring內建)

View Code

  3.建立application.properties檔案。

  4.建立spring公共配置檔案applicationContext.xml。

RabbitMQ安裝和使用(和Spring內建)
RabbitMQ安裝和使用(和Spring內建)

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

RabbitMQ安裝和使用(和Spring內建)
RabbitMQ安裝和使用(和Spring內建)

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

RabbitMQ安裝和使用(和Spring內建)
RabbitMQ安裝和使用(和Spring內建)

  7.建立MQ消息發送接口 (MQSender.java)。

   8.建立MQ消息發送實作類 MQSenderImpl.java。

  9.建立消息監聽器QueueListenter.java。

  10.終于到最後一步了,建立測試類。

   11.最終結果,消息監聽器中的輸出如下。

   12.浏覽器中輸入“http://localhost:15672/”,進入 Rabbit MQ的管理系統,檢視 queue和exchange對應的相關資訊如下。

  

RabbitMQ安裝和使用(和Spring內建)

   

RabbitMQ安裝和使用(和Spring內建)
RabbitMQ安裝和使用(和Spring內建)

  1.對MQ的生産者和消費者做了一些簡單的封裝,同一放到了一個工程下面裡。無論是生産者還是消費者,隻需要依賴上這個工程對應的jar就可以了。另外就是依賴上這個工程中MQ對應的XML檔案。工程的基本結構如下所示。

RabbitMQ安裝和使用(和Spring內建)

  2.XML檔案如下。

RabbitMQ安裝和使用(和Spring內建)
RabbitMQ安裝和使用(和Spring內建)

  3.消費者。

RabbitMQ安裝和使用(和Spring內建)
RabbitMQ安裝和使用(和Spring內建)

  4.生産者。

RabbitMQ安裝和使用(和Spring內建)
RabbitMQ安裝和使用(和Spring內建)

  示例中去掉了 Exchange,可以在完整項目中檢視關于Exchange的配置。

  5.消費者web2工程

  繼承封裝過的MQ消費者抽象類,實作為實作的方法,将消息放入全局application對象中。

RabbitMQ安裝和使用(和Spring內建)
RabbitMQ安裝和使用(和Spring內建)

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

RabbitMQ安裝和使用(和Spring內建)
RabbitMQ安裝和使用(和Spring內建)

  spring公共配置檔案中<beans/>屬相中加入如下配置。

  6.生産者web1工程

RabbitMQ安裝和使用(和Spring內建)
RabbitMQ安裝和使用(和Spring內建)

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

RabbitMQ安裝和使用(和Spring內建)
RabbitMQ安裝和使用(和Spring內建)
RabbitMQ安裝和使用(和Spring內建)

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

RabbitMQ安裝和使用(和Spring內建)