这两天在玩RocketMQ。
之前都是直接使用阿里云提供的RocketMQ服务,没有自建MQ服务,所以想着在本地自建一个MQ服务玩一下。
RocketMQ目前托管在apache基金会下,官网地址为:
http://rocketmq.apache.org/
直接到官网下载最新的release版本即可。
Windows下单机配置步骤大致如下,未做个性化配置:
1、解压RocketMQ到指定目录,这里解压目录为 C:\rocketmq-all-4.8.0-bin-release。
2、在系统的环境变量添加配置:
变量名:ROCKETMQ_HOME
变量值:MQ解压文件夹全路径,这里为C:\rocketmq-all-4.8.0-bin-release。
3、命令行 cd 至解压目录下的bin目录。
$ cd C:\rocketmq-all-4.8.0-bin-release\bin
4、开启mqnameserver。
$ start mqnamesrv.cmd
此时会弹出新的cmd窗口,切勿关闭此窗口。
可以通过jps命令确认nameserver是否已经启动:
5、启动mqbroker。
$ start mqbroker.cmd -n 127.0.0.1:9876 autoCreateTopicEnable=true
若提示错误"找不到或无法加载主类”,则可编辑mqbroker.cmd,
修改
set "JAVA_OPT=%JAVA_OPT% -cp %CLASSPATH%"
为
set "JAVA_OPT=%JAVA_OPT% -cp "%CLASSPATH%""
也就是在%CLASSPATH%加上了""。
再一次尝试启动。
如无意外,则mqbroker启动成功。
可以通过jps命令查看服务的启动情况:
此时初步的一个安装过程即完成。
后续RocketMQ的其他一些配置还待研究。