Message Broker與AMQP簡介

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

• 訊息路由到一個或多個目的地
• 訊息轉化為其他的表現方式
• 執行訊息的聚集、訊息的分解，並將結果傳送到他們的目的地，然後重新組合相應返回給訊息使用者
• 呼叫Web服務來檢索資料
• 響應事件或錯誤
• 使用釋出-訂閱模式來提供內容或基於主題的訊息路由

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

• 訊息方向
• 訊息佇列
• 訊息路由（包括：點到點和釋出-訂閱模式）
• 可靠性
• 安全性

RabbitMQ

     本文要介紹的RabbitMQ就是以AMQP協議實現的一種中介軟體產品，它可以支援多種作業系統，多種程式語言，幾乎可以覆蓋所有主流的企業級技術平臺。

    本文是在window7的環境下進行安裝完成的。首先我們需要下載Erlang/OTP ，在官網出可進行下載http://www.erlang.org/downloadshttp://www.erlang.org/download。

在此我選擇的時候用win64版本的。

之後我選擇的是下載rabbitMQ的客戶端版本，https://www.rabbitmq.com/download.html，然後選擇如下圖處，

下載完成之後，就可以一直點選下一步，可以選擇系統預設的位置進行儲存。同時，在window的服務中，rabbitmq會自動的啟動，然後我們可以直接在命令列的模式下去進行web的管理。（注意自己的安裝位置）。

然後登入http://localhost:15672，如果可以正常顯示則表示安裝是順利的。之後會進行登入，系統的預設的使用者民和密碼時候guest,然後就可以直接進入了。

與springboot的整合

首先在pom.xml中我們要去引入關於rabbitMQ的依賴，如圖所示：

模組的結構大致如下：

其中在application.properties中我們可以對它進行一定的配置，比如在這裡我們可以配置為

spring.application.name=rabbitmq-hello

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

在此的生產者主要是用來發送資訊的，比如，在此就是我們可以傳送一個hello+日期的字串一樣（達到大概的目的即可）。之中的AmqpTemplate 介面定義了一系列的AMqp的基礎操作。並且通過converandsend方法傳送給一個訊息佇列（這裡的名字叫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的連線。

同時，我們通過RabbitMQ的控制面板，可以看到Connection和Channels中包含當前連線的條目。

• 執行單元測試類，我們可以看到控制檯中輸出下面的內容，訊息被髮送到了RabbitMQ Server的hello佇列中。

• 切換到應用主類的控制檯，我們可以看到類似如下輸出，消費者對hello佇列的監聽程式執行了，並輸出了接受到的訊息資訊。

通過上面的示例，我們在Spring Boot應用中引入spring-boot-starter-amqp模組，進行簡單配置就完成了對RabbitMQ的訊息生產和消費的開發內容。