https://github.com/alibaba/spring-cloud-alibaba/wiki/RocketMQ
下载rocketmq-all-4.9.5-bin-release
必须配置一个RocketMQ路径的环境变量(参考博客的第二个)
配置内容如下,目录在bin的上层
解压,进入解压目录conf,修改broker.conf
在该文件中加入两行(建议直接复制,然后再修改为自己的IP),一定是大写IP
namesrvAddr=127.0.0.1:9876 brokerIP1=你自己的ip地址#是大写的IP一定要注意!!!修改成自己的IP地址
编辑bin下的runbroker.cmd,按需修改Xms数据,注意是大写M代表mb,原数据是大写的G
set "JAVA_OPT=%JAVA_OPT% -server -Xms256M -Xmx256M"
调错写在前面
先按后续的启动输入启动命令
如果你使用下面的启动命令时报错
Unrecognized VM option 'UseConcMarkSweepGC’ Error: Could not create the Java Virtual Machine. Error: A fatal exception has occurred. Program will exit.
因为启动的是mqnamesrv,那么就编辑mqnamesrv.cmd 搜索单引号中的UseConcMarkSweepGC,找到后删除整行内容
同理,这类型的报错都可以这样解决
原因应该是高版本的jvm不支持这些参数
偶见RocketMQ非正常会造成下次mqbroker不能正常启动,此时删掉C盘user/store文件夹的所有文件再运行mqbroker(最后的参考博客第五个)
启动:
打开cmd进入目录的bin路径先启动这个命令
mqnamesrv -n "你自己的ip地址" &
新建cmd再启动这个
mqbroker.cmd -n localhost:9876
发送数据
用powershell测试发送数据,发送该命令是在bin文件夹的上层文件夹,你在bin目录下去掉.\bin\运行的话powershell会有报错提示,很简单的
$Env:NAMESRV_ADDR="localhost:9876"
.\bin\tools.cmd org.apache.rocketmq.example.quickstart.Producer
发送成功
接受(开另一个powershell)
$Env:NAMESRV_ADDR="localhost:9876" .\bin\tools.cmd org.apache.rocketmq.example.quickstart.Consumer
打开控台
下载rocketmq-dashboard-1.0.0-source-release.zip这个文件,解压缩并用idea打开,可以简单看作一个springboot项目
进入application.properties修改server.port=改为你想要的端口号
按下列情况编辑App启动项加入
-Drocketmq.nameserv.addr=127.0.0.1:9876
因为是配置在本地,浏览器输入对应ip+application.properties配置的端口就启动到控台
参考博客
https://blog.csdn.net/zhangzengxiu/article/details/119062079
https://blog.csdn.net/qq_37126193/article/details/116991961
https://www.jianshu.com/p/18219e00e1eb
https://blog.csdn.net/lovebosom/article/details/126527191
https://blog.csdn.net/weixin_42578316/article/details/120017025
标签:bin,启动,windows,cmd,发送,https,9876,RocketMQ From: https://www.cnblogs.com/qintee/p/17531792.html