windows配置RocketMQ并测试发送消息

发布时间 2023-07-06 12:01:31作者: qintee

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