天天看點
傳回

Spring Boot中使用RabbitMQ

很久沒有寫Spring Boot的内容了，正好最近在寫Spring Cloud Bus的内容，因為内容會有一些相關性，是以先補一篇關于AMQP的整合。

https://blog.didispace.com/spring-boot-rabbitmq/#Message-Broker%E4%B8%8EAMQP%E7%AE%80%E4%BB%8B Message Broker與AMQP簡介

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

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

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

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

https://blog.didispace.com/spring-boot-rabbitmq/#RabbitMQ RabbitMQ

本文要介紹的RabbitMQ就是以AMQP協定實作的一種中間件産品，它可以支援多種作業系統，多種程式設計語言，幾乎可以覆寫所有主流的企業級技術平台。

https://blog.didispace.com/spring-boot-rabbitmq/#%E5%AE%89%E8%A3%85 安裝

在RabbitMQ官網的下載下傳頁面

https://www.rabbitmq.com/download.html

中，我們可以擷取到針對各種不同作業系統的安裝包和說明文檔。這裡，我們将對幾個常用的平台一一說明。

下面我們采用的Erlang和RabbitMQ Server版本說明：

  • Erlang/OTP 19.1
  • RabbitMQ Server 3.6.5

https://blog.didispace.com/spring-boot-rabbitmq/#Windows%E5%AE%89%E8%A3%85 Windows安裝

  1. 安裝Erland，通過官方下載下傳頁面

    http://www.erlang.org/downloads

         擷取exe安裝包，直接打開并完成安裝。
  2. 安裝RabbitMQ，通過官方下載下傳頁面

    https://www.rabbitmq.com/download.html

         擷取exe安裝包。
  3. 下載下傳完成後，直接運作安裝程式。
  4. RabbitMQ Server安裝完成之後，會自動的注冊為服務，并以預設配置啟動起來。
Spring Boot中使用RabbitMQ

Mac OS X安裝

在Mac OS X中使用brew工具，可以很容易的安裝RabbitMQ的服務端，隻需要按如下指令操作即可：

  1. brew更新到最新版本，執行：brew update
  2. 安裝Erlang，執行：

    brew install erlang
  3. 安裝RabbitMQ Server，執行：

    brew install rabbitmq

通過上面的指令，RabbitMQ Server的指令會被安裝到

/usr/local/sbin

，并不會自動加到使用者的環境變量中去，是以我們需要在

.bash_profile

或

.profile

檔案中增加下面内容：

PATH=$PATH:/usr/local/sbin

這樣，我們就可以通過

rabbitmq-server

指令來啟動RabbitMQ的服務端了。

https://blog.didispace.com/spring-boot-rabbitmq/#Ubuntu%E5%AE%89%E8%A3%85 Ubuntu安裝

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

  1. apt-get install erlang
  2. 執行下面的指令，新增APT倉庫到

    /etc/apt/sources.list.d

     
echo 'deb http://www.rabbitmq.com/debian/ testing main' |
        sudo tee /etc/apt/sources.list.d/rabbitmq.list
  1. 更新APT倉庫的package list，執行

    sudo apt-get update

     指令
  2. 安裝Rabbit Server，執行

    sudo apt-get install rabbitmq-server

https://blog.didispace.com/spring-boot-rabbitmq/#Rabbit%E7%AE%A1%E7%90%86 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

     。我們可以看到如下圖的管理頁面：
Spring Boot中使用RabbitMQ

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

  • 點選

    Admin

     标簽，在這裡可以進行使用者的管理。

https://blog.didispace.com/spring-boot-rabbitmq/#Spring-Boot%E6%95%B4%E5%90%88 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://[email protected]: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的官方教程，有更全面的了解。

https://blog.didispace.com/spring-boot-rabbitmq/#%E4%BB%A3%E7%A0%81%E7%A4%BA%E4%BE%8B 代碼示例

本文的相關例子可以檢視下面倉庫中的

chapter5-2-1

目錄：

消息中間件 ubuntu java 中間件 測試技術 資料安全/隐私保護 iOS開發 macOS Windows spring spring使用rabbitmq spring rabbitmq無效 rabbitmq spring連接配接 spring配置rabbitmq spring rabbitmq消息
上一篇: 一文帶你玩轉對象存儲COS文檔預覽
下一篇: JavaWeb全棧開發前後端互動通用标準(下）AJAX get() 和 post() 方法$.get()

繼續閱讀