天天看點

RocketMQ入門啟動篇-Windows

1、從git倉庫克隆源碼:https://gitee.com/apache/rocketmq.git

2、通過控制台的方式啟動rocketmq:

    2.1、cmd 進入到rocketmq 檔案夾,通過mvn打包:

mvn -Prelease-all -DskipTests clean install -U
           

    2.2、配置ROCKET_HOME時需要配置的位址不是你下載下傳下來的源碼的位置,而是編譯後的位置: ~\rocketmq\distribution\target\rocketmq-4.8.0\rocketmq-4.8.0

    2.3、進入 cd distribution/target/apache-rocketmq

        啟動nameserver:

start mqnamesrv.cmd
           

        啟動broker:

start mqbroker.cmd -n 127.0.0.1:9876 autoCreateTopicEnable=true
           

3、通過IDEA打開源碼,調用main函數的方式啟動:

    3.1、啟動nameserver

    3.2、加入broker啟動程式的參數:

-c D:\code\java_yuanma\rocketmq\distribution\conf\broker.conf
           

    3.3、在broker.conf加入以下參數:

autoCreateTopicEnable = true
namesrvAddr = 127.0.0.1:9876
           

    3.4、啟動broker

4、下載下傳可視化管理工具

    https://gitee.com/mirrors/RocketMQ-Externals.git

    3.1、設定application.properties 中的nameserver位址:

rocketmq.config.namesrvAddr=localhost:9876
           

    3.2、啟動裡面的 rocket-console 項目

5、rocketmq的發送和消費,可參考rocketmq中的example工程,裡面包含各種消息類型的發送和消費