1、rocketmq服务关闭
关闭namesrv服务：
sh bin/mqshutdown namesrv
关闭broker服务 ：
sh bin/mqshutdown broker
2、
cd rocketmq到文件夹
修改大小参数
runbroker.sh
JAVA_OPT="${JAVA_OPT} -server -Xms512m -Xmx512m -Xmn256m"
runserver.sh
JAVA_OPT="${JAVA_OPT} -server -Xms256m -Xmx256m -Xmn128m -XX:MetaspaceSize=128m -XX:MaxMetaspaceSize=320m"
先启动mqnamesrv
nohup sh bin/mqnamesrv -n localhost:9876 >/www/service/rocketmq-4.8.0/mqnamesrv.log 2>&1 &
查看日志
tail -f mqnamesrv.log
出现 boot success字眼就是启动成功
再启动broker
nohup sh bin/mqbroker -n localhost:9876 autoCreateTopicEnable=true >/www/service/rocketmq-4.8.0/broker.log 2>&1 &
刷新配置文件
nohup sh bin/mqbroker -n localhost:9876 autoCreateTopicEnable=true -c conf/broker.conf >/www/service/rocketmq-4.8.0/broker.log 2>&1 &
查看日志
tail -f broker.log
出现 boot success 字眼就是启动成功
3、队列测试
编辑
vim tools.sh
在export JAVA_HOME上面添加如下这段代码
export NAMESRV_ADDR=localhost:9876
生成消息
sh bin/tools.sh org.apache.rocketmq.example.quickstart.Producer
刷一大串 多个字眼true就是成功
消费消息
sh bin/tools.sh org.apache.rocketmq.example.quickstart.Consumer
刷一大串 多个字眼true就是成功
rocketmq扩展
https://github.com/apache/rocketmq-externals/
根据作者提示原来的console改为dashboard了
https://github.com/apache/rocketmq-dashboard
注意：
若要远程访问：
namesrvAddr=公网ip:9876
brokerIP1=公网ip
