摘要：可以在地址看到如何使用講解下上面命令行表示控制臺(tái)端口號(hào)，可以在瀏覽器中通過控制臺(tái)來執(zhí)行的相關(guān)操作。同時(shí)從控制臺(tái)可以看到發(fā)送的速率多線程測(cè)試性能開了個(gè)線程，每個(gè)線程發(fā)送條消息。

上次寫了篇文章，《SpringBoot Kafka 整合使用》，閱讀量還挺高的，于是想想還是把其他幾種 MQ 也和 SpringBoot 整合使用下。

下面是四種比較流行的 MQ ：

后面都寫寫和 SpringBoot 整合的文章。

由于換 Mac 了，所以一些環(huán)境就直接在 Mac 搞，但是像安裝 RabbitMQ 這些又會(huì)把自己電腦系統(tǒng)給搞的太亂，所以能在 Docker 里面安裝就安裝在 Docker，這次 RabbitMQ 我也直接在 Docker 里安裝。

啟動(dòng) Docker for Mac，如果沒安裝過的請(qǐng)看我上一篇文章：http://www.54tianzhisheng.cn/...

當(dāng)然你也可以在自己的 Linux 服務(wù)器或者虛擬機(jī)里啟動(dòng)安裝 RabbitMQ 。

Docker 安裝的話很簡單，因?yàn)?RabbitMQ 官方已經(jīng)提供了自己的 Docker 容器，只需要一行命令：（可右移查看完整代碼）

docker run -d  -p 15672:15672  -p  5672:5672  -e RABBITMQ_DEFAULT_USER=admin -e RABBITMQ_DEFAULT_PASS=admin --name rabbitmq rabbitmq:3-management

該鏡像擁有一個(gè)基于 web 的控制臺(tái)和 Http API。Http API 可以在地址看到如何使用：http://localhost:15672/api/

講解下上面命令行：

15672 ：表示 RabbitMQ 控制臺(tái)端口號(hào)，可以在瀏覽器中通過控制臺(tái)來執(zhí)行 RabbitMQ 的相關(guān)操作。

5672 : 表示 RabbitMQ 所監(jiān)聽的 TCP 端口號(hào)，應(yīng)用程序可通過該端口與 RabbitMQ 建立 TCP 連接，并完成后續(xù)的異步消息通信

RABBITMQDEFAULTUSER：用于設(shè)置登陸控制臺(tái)的用戶名，這里我設(shè)置 admin

RABBITMQDEFAULTPASS：用于設(shè)置登陸控制臺(tái)的密碼，這里我設(shè)置 admin

容器啟動(dòng)成功后，可以在瀏覽器輸入地址：http://localhost:15672/ 訪問控制臺(tái)

登陸后：

簡單描述下上圖中中控制臺(tái)的列表的作用：

Overview ：用于查看 RabbitMQ 的一些基本信息（消息隊(duì)列、消息發(fā)送速率、節(jié)點(diǎn)、端口和上下文信息等）

Connections：用于查看 RabbitMQ 客戶端的連接信息

Channels：用戶查看 RabbitMQ 的通道信息

Exchange：用于查看 RabbitMQ 交換機(jī)

Queues：用于查看 RabbitMQ 的隊(duì)列

Admin：用于管理用戶，可增加用戶

在 IDEA 中創(chuàng)建一個(gè) SpringBoot 項(xiàng)目結(jié)構(gòu)：

SpringBoot 框架中已經(jīng)內(nèi)置了對(duì) RabbitMQ 的支持，如果你看過官方文檔的話，就可以看到的，我們需要把依賴 spring-boot-starter-amqp 引入就行。

1、 pom.xml 引入依賴后如下：

    4.0.0
    com.zhisheng
    rabbitmq
    0.0.1-SNAPSHOT
    jar
    rabbitmq
    Demo project for Spring Boot RabbitMQ
    
        org.springframework.boot
        spring-boot-starter-parent
        1.5.9.RELEASE
         
    
    
        UTF-8
        UTF-8
        1.8
    
    
        
            org.springframework.boot
            spring-boot-starter-web
        
        
            org.springframework.boot
            spring-boot-starter-test
            test
        
        
            org.springframework.boot
            spring-boot-starter-amqp
        
    
    
        
            
                org.springframework.boot
                spring-boot-maven-plugin
            
        
    

2、application.properties 配置修改如下：

spring.rabbitmq.addresses=localhost:5672
spring.rabbitmq.username=admin
spring.rabbitmq.password=admin

3、消息發(fā)送類 RabbitMQClient.java

package com.zhisheng.rabbitmq.client;

import org.springframework.amqp.rabbit.core.RabbitTemplate;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;

/** * Created by zhisheng_tian on 2018/1/23 */
@Componentpublic
class RabbitMQClient {
    @Autowired
    private RabbitTemplate rabbitTemplate;

    public void send(String message) { rabbitTemplate.convertAndSend("zhisheng", message); }
}

就這樣，發(fā)送消息代碼就實(shí)現(xiàn)了。

這里關(guān)鍵的代碼為 rabbitTemplate.convertAndSend() 方法， zhisheng 這個(gè)是路由規(guī)則（routingKey），它的值表明將消息發(fā)送到指定的隊(duì)列 zhisheng 中去，這里跟了下源碼，發(fā)現(xiàn) convertAndSend() 方法最后調(diào)用的方法其實(shí)是一個(gè) doSend() 方法。

4、消息接收類

package com.zhisheng.rabbitmq.server;

import org.springframework.amqp.rabbit.annotation.RabbitListener;
import org.springframework.stereotype.Component;

/** * Created by zhisheng_tian on 2018/1/23 */
@Componentpublic
class RabbitMQServer {
    @RabbitListener(queues = "zhisheng")
    public void receive(String message) { System.out.println("收到的 message 是：" + message); }
}

你看，這里就有個(gè) RabbitListener 一直在監(jiān)聽著隊(duì)列 zhisheng 。

當(dāng)然這個(gè)隊(duì)列是必須要我們自己在應(yīng)用程序中創(chuàng)建好，它不會(huì)像我之前寫的文章 《SpringBoot Kafka 整合使用》 中的 Kafka 一樣，Kafka 它會(huì)在用到隊(duì)列的時(shí)候動(dòng)態(tài)的創(chuàng)建，不需要我們提前創(chuàng)建好。

那么在 RabbitMQ 中該如何創(chuàng)建隊(duì)列呢？

如上圖所示：這樣我們就創(chuàng)建好了一個(gè) zhisheng 的隊(duì)列，當(dāng)程序開始運(yùn)行時(shí)，消息接收類會(huì)持續(xù)監(jiān)聽隊(duì)列 zhisheng 中即將到來的消息。

5、運(yùn)行項(xiàng)目

需要在啟動(dòng)類中注入發(fā)送消息的類，并且提供 init 方法，在 init 方法中調(diào)用發(fā)送消息類的 send() 方法

@PostConstructpublic
void init() { rabbitMQClient.send("發(fā)送消息----zhisheng-----"); }

需要注意的是：init() 方法帶有 @PostConstruct 注解，被 @PostConstruct 修飾的方法會(huì)在構(gòu)造函數(shù)之后執(zhí)行。

啟動(dòng)項(xiàng)目就可以發(fā)現(xiàn)控制臺(tái)已經(jīng)接收到消息了。

6、單線程測(cè)試性能

看到上面圖片中注釋掉的代碼沒？那就是用來測(cè)試消息發(fā)送的性能的，我發(fā)送 10000 條消息看看總共耗時(shí)多少。

10000 條消息發(fā)送耗時(shí)：215ms。這是在單線程下，下次可以和其他的 MQ 測(cè)試對(duì)比下，并且也可以在多線程的環(huán)境下測(cè)試性能。

同時(shí)從控制臺(tái)可以看到發(fā)送的速率：

7、多線程測(cè)試性能

開了10 個(gè)線程，每個(gè)線程發(fā)送 10000 條消息。

init 方法代碼如下：

@PostConstruct
public void init() {
    StopWatch stopWatch = new StopWatch(); stopWatch.start();
    int threads = 10; ExecutorService executorService = Executors.newFixedThreadPool(threads);
    final CountDownLatch start = new CountDownLatch(1); final CountDownLatch end = new CountDownLatch(threads);
    for (int i = 0; i < threads; i++) {
        executorService.execute(( ) -> {
        try {
            start.await(); for (int i1 = 0; i1 < 10000; i1++) {
                rabbitMQClient.send("發(fā)送消息----zhisheng-----");
            }
        } catch (InterruptedException e) {
            e.printStackTrace();
        } finally {
            end.countDown();
        }
    } );
    }
    start.countDown(); try {
        end.await();
    } catch (InterruptedException e) {
        e.printStackTrace();
    } finally {
        executorService.shutdown();
    }

    stopWatch.stop(); System.out.println("發(fā)送消息耗時(shí)：" + stopWatch.getTotalTimeMillis());
}

耗時(shí)：4063ms

控制臺(tái)顯示如下圖：

8、注意

這里測(cè)試發(fā)送的消息直接是 String 類型的，你也可以測(cè)試下 Bean 類，這需要注意需要序列化。

推薦閱讀：

《深入理解 Java 內(nèi)存模型》讀書筆記

面試-基礎(chǔ)篇

Spring Boot 2.0 遷移指南

SpringBoot使用Docker快速部署項(xiàng)目

為什么選擇 Spring 作為 Java 框架？

SpringBoot RocketMQ 整合使用和監(jiān)控

Spring Boot 面試的十個(gè)問題

使用 Spring Framework 時(shí)常犯的十大錯(cuò)誤

SpringBoot Admin 使用指南

上篇好文：

SpringBoot Kafka 整合使用