在Windows下搭建RocketMQ


原文:http://blog.csdn.net/u014134180/article/details/51790988

目錄

 

 

一 准備工作

1.1 RocketMQ部署架構1

本文安裝和測試都在同一台電腦中進行,所有IP都是127.0.0.1,其中NameServer一個,Broker一個,Producer一個,Consumer一個。

這里寫圖片描述

1.2 環境配置

操作系統:Windows 7 64位旗艦版 
JDK:1.7以上

二 安裝RocketMQ

注:僅支持64位Windows,請安裝64位JDK,最好用jdk7的。

2.1 下載編譯好的RocketMQ

下載編譯好的RocketMQ的發布版,也可以自行編譯:https://github.com/alibaba/RocketMQ/releases

RocketMQ

2.2 解壓縮,並進入bin目錄

RocketMQ

2.3 啟動name server

打擊mqnamesrv.exe,啟動name server,保持mqnamesrv.exe運行,不要關閉這個終端。

這里寫圖片描述

2.4 啟動broker

方法一:開啟另一個windows終端cmd,進入解壓的bin目錄,先輸入set NAMESRV_ADDR=127.0.0.1:9876設置環境變量,輸入mqbroker.exe啟動broker,保持mqbroker.exe運行,不要關閉這個終端。 
方法二:開啟另一個windows終端cmd,進入解壓的bin目錄,也可一步輸入mqbroker -n 127.0.0.1:9876啟動broker,保持mqbroker.exe運行,不要關閉這個終端。

這里寫圖片描述

2.5 MQ安裝完畢

三 驗證MQ是否安裝成功

3.1 下載測試環境

初賽的DEMO,並解壓 
Git clone https://code.aliyun.com/MiddlewareRace/PreliminaryDemo.git

3.2 方法一:在cmd終端使用mvn進行測試

3.2.1 配置mvn環境

自行到Apache 下載mvn工具,解壓,並如下配置mvn(同配置Java jdk)

這里寫圖片描述 
這里寫圖片描述 
這里寫圖片描述

3.2.1 進入目錄,運行mvn install編譯DEMO

這里寫圖片描述

3.2.2 進入生成的target目錄

這里寫圖片描述

3.2.3 啟動生產者生產數據

要先保持mqnamesrv.exe和mqbroker.exe兩個服務器運行。 
在target目錄輸入: 
Java -Drocketmq.namesrv.addr=127.0.0.1:9876 -cp preliminary.demo-1.0-SNAPSHOT.jar com.alibaba.middleware.race.rocketmq.Producer

3.2.4 啟動消費者消費數據

在target目錄輸入: 
java -Drocketmq.namesrv.addr=127.0.0.1:9876 -cp preliminary.demo-1.0-SNAPSHOT.jar com.alibaba.middleware.race.rocketmq.Consumer

這里寫圖片描述

3.3 方法二:在Ecplise導入Mavan項目進入測試

3.3.1 導入存在Maven項目

這里寫圖片描述 
這里寫圖片描述 
這里寫圖片描述

3.3.2 按Alt+Enter 修改為UTF-8編碼

這里寫圖片描述

3.3.3 取消設置服務器IP和商品代碼的注釋

這里寫圖片描述

3.3.4 運行生產者和消費者代碼

要先保持mqnamesrv.exe和mqbroker.exe兩個服務器運行。

這里寫圖片描述
這里寫圖片描述

四 更多資料


免責聲明!

本站轉載的文章為個人學習借鑒使用,本站對版權不負任何法律責任。如果侵犯了您的隱私權益,請聯系本站郵箱yoyou2525@163.com刪除。



 
粵ICP備18138465號   © 2018-2025 CODEPRJ.COM