RabbitMQ 入門 與 RabbitMQ 在 Spring Boot 中的使用

##Message Broker與AMQP簡介

Message Broker是一種消息驗證、傳輸、路由的架構模式，其設計目標主要應用於下面這些場景：

• 消息路由到一個或多個目的地

• 消息轉化爲其餘的表現方式

• 執行消息的彙集、消息的分解，並將結果發送到他們的目的地，而後從新組合相應返回給消息用戶

• 調用Web服務來檢索數據

• 響應事件或錯誤

• 使用發佈-訂閱模式來提供內容或基於主題的消息路由

• AMQP是Advanced Message Queuing Protocol的簡稱，它是一個面向消息中間件的開放式標準應用層協議。AMQP定義了這些特性：

• 消息方向

• 消息隊列

• 消息路由（包括：點到點和發佈-訂閱模式）

• 可靠性

• 安全性 ##RabbitMQ

本文要介紹的RabbitMQ就是以AMQP協議實現的一種中間件產品，它能夠支持多種操做系統，多種編程語言，幾乎能夠覆蓋全部主流的企業級技術平臺。

##安裝

在RabbitMQ官網的下載頁面https://www.rabbitmq.com/download.html中，咱們能夠獲取到針對各類不一樣操做系統的安裝包和說明文檔。這裏，咱們將對幾個經常使用的平臺一一說明。

下面咱們採用的Erlang和RabbitMQ Server版本說明：

Erlang/OTP 19.1 RabbitMQ Server 3.6.5 ##Windows安裝

一、安裝Erland，經過官方下載頁面http://www.erlang.org/downloads獲取exe安裝包，直接打開並完成安裝。 二、安裝RabbitMQ，經過官方下載頁面https://www.rabbitmq.com/download.html獲取exe安裝包。 三、下載完成後，直接運行安裝程序。 四、RabbitMQ Server安裝完成以後，會自動的註冊爲服務，並以默認配置啓動起來。

##Mac OS X安裝

在Mac OS X中使用brew工具，能夠很容易的安裝RabbitMQ的服務端，只須要按以下命令操做便可：

一、brew更新到最新版本，執行：brew update 二、安裝Erlang，執行：brew install erlang 三、安裝RabbitMQ Server，執行：brew install rabbitmq 四、經過上面的命令，RabbitMQ Server的命令會被安裝到/usr/local/sbin，並不會自動加到用戶的環境變量中去，因此咱們須要在.bash_profile或.profile文件中增長下面內容：

PATH=$PATH:/usr/local/sbin 這樣，咱們就能夠經過rabbitmq-server命令來啓動RabbitMQ的服務端了。

##Ubuntu安裝

在Ubuntu中，咱們可使用APT倉庫來進行安裝

一、安裝Erlang，執行：apt-get install erlang

echo 'deb http://www.rabbitmq.com/debian/ testing main'
sudo tee /etc/apt/sources.list.d/rabbitmq.list

三、更新APT倉庫的package list，執行sudo apt-get update命令

四、安裝Rabbit Server，執行sudo apt-get install rabbitmq-server命令 ##Rabbit管理

咱們能夠直接經過配置文件的訪問進行管理，也能夠經過Web的訪問進行管理。下面咱們將介紹如何經過Web進行管理。

• 執行rabbitmq-plugins enable rabbitmq_management命令，開啓Web管理插件，這樣咱們就能夠經過瀏覽器來進行管理了。

-> rabbitmq-plugins enable rabbitmq_management
The following plugins have been enabled:
  mochiweb
  webmachine
  rabbitmq_web_dispatch
  amqp_client
  rabbitmq_management_agent
  rabbitmq_management
Applying plugin configuration to rabbit@PC-201602152056... started 6 plugins.

• 打開瀏覽器並訪問：http://localhost:15672/，並使用默認用戶guest登陸，密碼也爲guest。咱們能夠看到以下圖的管理頁面：

從圖中，咱們能夠看到以前章節中提到的一些基本概念，好比：Connections、Channels、Exchanges、Queue等。第一次使用的讀者，能夠都點開看看都有些什麼內容，熟悉一下RabbitMQ Server的服務端。

• 點擊Admin標籤，在這裏能夠進行用戶的管理。 ##Spring Boot整合

下面，咱們經過在Spring Boot應用中整合RabbitMQ，並實現一個簡單的發送、接收消息的例子來對RabbitMQ有一個直觀的感覺和理解。

在Spring Boot中整合RabbitMQ是一件很是容易的事，由於以前咱們已經介紹過Starter POMs，其中的AMQP模塊就能夠很好的支持RabbitMQ，下面咱們就來詳細說說整合過程：

• 新建一個Spring Boot工程，命名爲：「rabbitmq-hello」。
• 在pom.xml中引入以下依賴內容，其中spring-boot-starter-amqp用於支持RabbitMQ。

<parent>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-parent</artifactId>
    <version>1.3.7.RELEASE</version>
    <relativePath/> <!-- lookup parent from repository -->
</parent>
<dependencies>
    <dependency>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-amqp</artifactId>
    </dependency>
    <dependency>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-test</artifactId>
        <scope>test</scope>
    </dependency>
</dependencies>

• 在application.properties中配置關於RabbitMQ的鏈接和用戶信息，用戶能夠回到上面的安裝內容，在管理頁面中建立用戶。

spring.application.name=rabbitmq-hello

spring.rabbitmq.host=localhost
spring.rabbitmq.port=5672
spring.rabbitmq.username=spring
spring.rabbitmq.password=123456

• 建立消息生產者Sender。經過注入AmqpTemplate接口的實例來實現消息的發送，AmqpTemplate接口定義了一套針對AMQP協議的基礎操做。在Spring Boot中會根據配置來注入其具體實現。在該生產者，咱們會產生一個字符串，併發送到名爲hello的隊列中。

@Component
public class Sender {

    @Autowired
    private AmqpTemplate rabbitTemplate;

    public void send() {
        String context = "hello " + new Date();
        System.out.println("Sender : " + context);
        this.rabbitTemplate.convertAndSend("hello", context);
    }

}

• 建立消息消費者Receiver。經過@RabbitListener註解定義該類對hello隊列的監聽，並用@RabbitHandler註解來指定對消息的處理方法。因此，該消費者實現了對hello隊列的消費，消費操做爲輸出消息的字符串內容。

@Component
@RabbitListener(queues = "hello")
public class Receiver {

    @RabbitHandler
    public void process(String hello) {
        System.out.println("Receiver : " + hello);
    }

}

• 建立RabbitMQ的配置類RabbitConfig，用來配置隊列、交換器、路由等高級信息。這裏咱們以入門爲主，先以最小化的配置來定義，以完成一個基本的生產和消費過程。

@Configuration
public class RabbitConfig {

    @Bean
    public Queue helloQueue() {
        return new Queue("hello");
    }

}

• 建立應用主類：

@SpringBootApplication
public class HelloApplication {

    public static void main(String[] args) {
        SpringApplication.run(HelloApplication.class, args);
    }

}

• 建立單元測試類，用來調用消息生產：

@RunWith(SpringJUnit4ClassRunner.class)
@SpringApplicationConfiguration(classes = HelloApplication.class)
public class HelloApplicationTests {

    @Autowired
    private Sender sender;

    @Test
    public void hello() throws Exception {
        sender.send();
    }

}

• 完成程序編寫以後，下面開始嘗試運行。首先確保RabbitMQ Server已經開始，而後進行下面的操做：

• 啓動應用主類，從控制檯中，咱們看到以下內容，程序建立了一個訪問127.0.0.1:5672中springcloud的鏈接。

o.s.a.r.c.CachingConnectionFactory       : Created new connection: SimpleConnection@29836d32 [delegate=amqp://springcloud@127.0.0.1:5672/]

• 同時，咱們經過RabbitMQ的控制面板，能夠看到Connection和Channels中包含當前鏈接的條目。

• 運行單元測試類，咱們能夠看到控制檯中輸出下面的內容，消息被髮送到了RabbitMQ Server的hello隊列中。

Sender : hello Sun Sep 25 11:06:11 CST 2016

• 切換到應用主類的控制檯，咱們能夠看到相似以下輸出，消費者對hello隊列的監聽程序執行了，並輸出了接受到的消息信息。

Receiver : hello Sun Sep 25 11:06:11 CST 2016

• 經過上面的示例，咱們在Spring Boot應用中引入spring-boot-starter-amqp模塊，進行簡單配置就完成了對RabbitMQ的消息生產和消費的開發內容。然而在實際應用中，咱們還有不少內容沒有演示，這裏不作更多的講解，讀者能夠自行查閱RabbitMQ的官方教程，有更全面的瞭解。

完整示例：Chapter5-2-1

開源中國：http://git.oschina.net/didispace/SpringBoot-Learning/tree/master/Chapter5-2-1 GitHub：https://github.com/dyc87112/SpringBoot-Learning/tree/master/Chapter5-2-1