消息隊列——RabbitMQ

1. 寫在前面

昨天簡單學習了一個消息隊列項目——RabbitMQ，今天趁熱打鐵，將學到的東西記錄下來。

學習的資料主要是官網(wǎng)給出的6個基本的消息發(fā)送/接收模型，或者稱為6種不同的使用場景，本文便是對這6種模型加以敘述。

2. Tutorials

在學習6種模型之前，我們首先需要安裝RabbitMQ。RabbitMQ支持多種系統(tǒng)平臺，各平臺的安裝方法可以點此查看。安裝好之后，我們使用如下命令啟用Web端的管理插件：rabbitmq-plugins enable rabbitmq_management，然后啟動RabbitMQ。接著用瀏覽器訪問http://localhost:15672/，若能看到RabbitMQ相關Web頁面，說明啟動成功。

2.1 Hello World

正所謂萬事開頭難，我們先從最簡單的Hello World開始。首先當然是新建一個項目，導入RabiitMQ相關jar。我采用Maven來構建項目，因此只需要在pom文件中添加如下依賴： 

<dependency>
    <groupId>com.rabbitmq</groupId>
    <artifactId>amqp-client</artifactId>
    <version>3.6.5</version>
</dependency>

接下來學習最簡單的消息隊列模型，如下圖：

在圖中，P代表producer，它是消息的生產者；C代表consumer，它是消息的消費者；而紅色的矩形正是我們所謂的消息隊列，它位于RabbitMQ中（RabbitMQ中可以有很多這樣的隊列，并且每個隊列都有一個唯一的名字）。生產者（們）可以將消息發(fā)送到消息隊列中，消費者（們）可以從消息隊列中取出消息。

這種模型是不是很簡單呢？下面我們使用Java，借助于RabbitMQ來實現(xiàn)這種模型的消息通信。

首先我們介紹如何send消息到消息隊列。send之前，當然是和RabbitMQ服務器建立連接：