摘要:可以在地址看到如何使用講解下上面命令行表示控制臺端口號,可以在瀏覽器中通過控制臺來執行的相關操作。同時從控制臺可以看到發送的速率多線程測試性能開了個線程,每個線程發送條消息。
前提
上次寫了篇文章,《SpringBoot Kafka 整合使用》,閱讀量還挺高的,于是想想還是把其他幾種 MQ 也和 SpringBoot 整合使用下。
下面是四種比較流行的 MQ :
后面都寫寫和 SpringBoot 整合的文章。
安裝 RabbitMQ由于換 Mac 了,所以一些環境就直接在 Mac 搞,但是像安裝 RabbitMQ 這些又會把自己電腦系統給搞的太亂,所以能在 Docker 里面安裝就安裝在 Docker,這次 RabbitMQ 我也直接在 Docker 里安裝。
啟動 Docker for Mac,如果沒安裝過的請看我上一篇文章:http://www.54tianzhisheng.cn/...
當然你也可以在自己的 Linux 服務器或者虛擬機里啟動安裝 RabbitMQ 。
Docker 安裝的話很簡單,因為 RabbitMQ 官方已經提供了自己的 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
該鏡像擁有一個基于 web 的控制臺和 Http API。Http API 可以在地址看到如何使用:http://localhost:15672/api/
講解下上面命令行:
15672 :表示 RabbitMQ 控制臺端口號,可以在瀏覽器中通過控制臺來執行 RabbitMQ 的相關操作。
5672 : 表示 RabbitMQ 所監聽的 TCP 端口號,應用程序可通過該端口與 RabbitMQ 建立 TCP 連接,并完成后續的異步消息通信
RABBITMQDEFAULTUSER:用于設置登陸控制臺的用戶名,這里我設置 admin
RABBITMQDEFAULTPASS:用于設置登陸控制臺的密碼,這里我設置 admin
容器啟動成功后,可以在瀏覽器輸入地址:http://localhost:15672/ 訪問控制臺
登陸后:
簡單描述下上圖中中控制臺的列表的作用:
Overview :用于查看 RabbitMQ 的一些基本信息(消息隊列、消息發送速率、節點、端口和上下文信息等)
Connections:用于查看 RabbitMQ 客戶端的連接信息
Channels:用戶查看 RabbitMQ 的通道信息
Exchange:用于查看 RabbitMQ 交換機
Queues:用于查看 RabbitMQ 的隊列
Admin:用于管理用戶,可增加用戶
創建項目在 IDEA 中創建一個 SpringBoot 項目結構:
SpringBoot 框架中已經內置了對 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、消息發送類 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); } }
就這樣,發送消息代碼就實現了。
這里關鍵的代碼為 rabbitTemplate.convertAndSend() 方法, zhisheng 這個是路由規則(routingKey),它的值表明將消息發送到指定的隊列 zhisheng 中去,這里跟了下源碼,發現 convertAndSend() 方法最后調用的方法其實是一個 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); } }
你看,這里就有個 RabbitListener 一直在監聽著隊列 zhisheng 。
當然這個隊列是必須要我們自己在應用程序中創建好,它不會像我之前寫的文章 《SpringBoot Kafka 整合使用》 中的 Kafka 一樣,Kafka 它會在用到隊列的時候動態的創建,不需要我們提前創建好。
那么在 RabbitMQ 中該如何創建隊列呢?
如上圖所示:這樣我們就創建好了一個 zhisheng 的隊列,當程序開始運行時,消息接收類會持續監聽隊列 zhisheng 中即將到來的消息。
5、運行項目
需要在啟動類中注入發送消息的類,并且提供 init 方法,在 init 方法中調用發送消息類的 send() 方法
@PostConstructpublic void init() { rabbitMQClient.send("發送消息----zhisheng-----"); }
需要注意的是:init() 方法帶有 @PostConstruct 注解,被 @PostConstruct 修飾的方法會在構造函數之后執行。
啟動項目就可以發現控制臺已經接收到消息了。
6、單線程測試性能
看到上面圖片中注釋掉的代碼沒?那就是用來測試消息發送的性能的,我發送 10000 條消息看看總共耗時多少。
10000 條消息發送耗時:215ms。這是在單線程下,下次可以和其他的 MQ 測試對比下,并且也可以在多線程的環境下測試性能。
同時從控制臺可以看到發送的速率:
7、多線程測試性能
開了10 個線程,每個線程發送 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("發送消息----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("發送消息耗時:" + stopWatch.getTotalTimeMillis()); }
耗時:4063ms
控制臺顯示如下圖:
8、注意
這里測試發送的消息直接是 String 類型的,你也可以測試下 Bean 類,這需要注意需要序列化。
推薦閱讀:
《深入理解 Java 內存模型》讀書筆記
面試-基礎篇
Spring Boot 2.0 遷移指南
SpringBoot使用Docker快速部署項目
為什么選擇 Spring 作為 Java 框架?
SpringBoot RocketMQ 整合使用和監控
Spring Boot 面試的十個問題
使用 Spring Framework 時常犯的十大錯誤
SpringBoot Admin 使用指南
上篇好文:
SpringBoot Kafka 整合使用
文章版權歸作者所有,未經允許請勿轉載,若此文章存在違規行為,您可以聯系管理員刪除。
轉載請注明本文地址:http://specialneedsforspecialkids.com/yun/75715.html
摘要:創建消息監聽,并發送一條消息在程序中,提供了發送消息和接收消息的所有方法。 這篇文章帶你了解怎么整合RabbitMQ服務器,并且通過它怎么去發送和接收消息。我將構建一個springboot工程,通過RabbitTemplate去通過MessageListenerAdapter去訂閱一個POJO類型的消息。 準備工作 15min IDEA maven 3.0 在開始構建項目之前,機器需...
摘要:介紹它是出品,最流行的,能力強勁的開源消息總線。是一個完全支持和規范的實現,盡管規范出臺已經是很久的事情了,但是在當今的應用中間仍然扮演著特殊的地位。相關文章整合使用整合使用關注我轉載請務必注明原創地址為安裝同之前一樣,直接在里面玩吧。 showImg(https://segmentfault.com/img/remote/1460000012996066?w=1920&h=1281)...
閱讀 2314·2021-11-08 13:13
閱讀 1245·2021-10-09 09:41
閱讀 1683·2021-09-02 15:40
閱讀 3186·2021-08-17 10:13
閱讀 2546·2019-08-29 16:33
閱讀 3122·2019-08-29 13:17
閱讀 3131·2019-08-29 11:00
閱讀 3295·2019-08-26 13:40