https://github.com/alibaba/spring-cloud-alibaba/wiki/RocketMQ
下载rocketmq-all-4.9.5-bin-release
保险起见配置一个RocketMQ路径的环境变量(反正我配置了,配置方法见最下面参考博客的第二个)
解压,进入解压目录conf,修改broker.conf
在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不支持这些参数
启动:
打开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
发送成功
接受
$Env:NAMESRV_ADDR="localhost:9876" .\bin\tools.cmd org.apache.rocketmq.example.quickstart.Consumer
参考博客
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