RocketMQ环境搭建

官网:http://rocketmq.apache.org/

下载:选择Binary(已经编译好了的),Source是源码,需要手动编译。我用的版本是4.5.2,下载什么版本可自行选择

跳到了Apache页面,因为这个项目已经被阿里贡献给了Apache。
选择这个:下载速度快一点

下载好了之后,进入到bin目录,如果用的是window系统,只需要关心.cmd文件,如果是linux系统,则只需关心.sh文件:

有两个文件需要注意,mqnamesrv文件是用来启动Name Server的,mqbroker是启动Topic的。在启动RocketMQ服务之前,需要添加环境变量ROCKETMQ_HOME,value就是RocketMQ目录的路径。和NAMESRV_ADDR,因为是在本地运行,value就写localhost:9876就行了。还有RocketMQ是基于JAVA环境的,需要配置JAVA_HOME,value是jdk安装目录。

启动mqnamesrv

 启动mqbroker,记得带上-n参数,如果报错,加载不到某某主类,那么需要在runbroker文件修改配置

 启动成功

 测试,发消息:. ools.cmd org.apache.rocketmq.example.quickstart.Producer

 消费消息:. ools.cmd org.apache.rocketmq.example.quickstart.Consumer

 测试成功,RocketMQ环境搭建成功!

关闭RocketMQ服务可通过:.mqshutdown broker.mqshutdown namesrv完成

原文地址:https://www.cnblogs.com/dagger9527/p/11834299.html