下載最新的二進制版本。並將壓縮文件解壓縮到本地磁盤中。例如:D:\rocketmq
添加環境變量
您需要設置環境變量。
- 在桌面上,右擊計算機圖標。
- 從上下文菜單中選擇“屬性”。
- 單擊“高級系統設置”鏈接。
- 單擊“環境變量”。
- 然后添加或更改環境變量。
ROCKETMQ_HOME="D:\rocketmq" NAMESRV_ADDR="localhost:9876"
或者僅僅在打開的Powershell中,鍵入所需的環境變量。
$Env:ROCKETMQ_HOME="D:\rocketmq" $Env:NAMESRV_ADDR="localhost:9876"
如果你選擇Powershell的方式。您應該為每個新打開的Powershell窗口執行此操作。
啟動名稱服務器(NameServer)
設置正確的環境變量后,打開新的Powershell窗口。然后將目錄更改為rocketmq類型並運行:
.\bin\mqnamesrv.cmd
啟動經紀人(Broke)
設置正確的環境變量后,打開新的Powershell窗口。然后將目錄更改為rocketmq類型並運行: (autoCreateTopicEnable=true 這個是自動創建主題topic的意思)
.\bin\mqbroker.cmd -n localhost:9876 autoCreateTopicEnable=true
發送和接收消息
發送消息
設置正確的環境變量后,打開新的Powershell窗口。然后將目錄更改為rocketmq類型並運行:
.\bin\tools.cmd org.apache.rocketmq.example.quickstart.Producer
接收消息
然后您將看到產生的消息。現在我們可以試試消費者信息了。
設置正確的環境變量后,打開新的Powershell窗口。然后將目錄更改為rocketmq類型並運行:
.\bin\tools.cmd org.apache.rocketmq.example.quickstart.Consumer
關機服務器
通常,您只需關閉這些Powershell窗口即可。(不要在生產環境中這樣做)