微服务 Spring Cloud Alibaba 项目搭建（七、

一、RocketMQ下载

官网下载：https://mirrors.tuna.tsinghua.edu.cn/apache/rocketmq/5.1.3/

百度链接: https://pan.baidu.com/s/1NyHBQPF72GRPnx8psgATZA  密码: cqe9

二、调整内存

# 调整内存使用：（内存不够会导致启动失败）

vi /usr/local/alibaba/rocketmq/rocketmq-all-5.1.3-bin-release/bin/runserver.sh

# -Xms4g -Xmx4g -Xmn2g 改为 -Xms256m -Xmx256m -Xmn128m

vi /usr/local/alibaba/rocketmq/rocketmq-all-5.1.3-bin-release/bin/runbroker.sh

# -server -Xms8g -Xmx8g 改为 -server -Xms1g -Xmx1g

三、启动namesrv

mkdir logs

# namesrv启动命令：
nohup sh /usr/local/alibaba/rocketmq/rocketmq-all-5.1.3-bin-release/bin/mqnamesrv -n 127.0.0.1:9876 >/usr/local/alibaba/rocketmq/rocketmq-all-5.1.3-bin-release/logs/mqnamesrv.log  2>&1 &

# 查看日志
tail -300f /usr/local/alibaba/rocketmq/rocketmq-all-5.1.3-bin-release/logs/mqnamesrv.log

四、启动broker

# 强制加上本机ip,注意是公网IP
vi /usr/local/alibaba/rocketmq/rocketmq-all-5.1.3-bin-release/conf/broker.conf

# 在最后一行加入
namesrvAddr = 127.0.0.1:9876
brokerIP1 = 127.0.0.1

echo "brokerIP1=127.0.0.1" > /usr/local/alibaba/rocketmq/rocketmq-all-5.1.3-bin-release/conf/broker.properties

# broker启动命令：
nohup /usr/local/alibaba/rocketmq/rocketmq-all-5.1.3-bin-release/bin/mqbroker -n 127.0.0.1:9876 -c /usr/local/alibaba/rocketmq/rocketmq-all-5.1.3-bin-release/conf/broker.conf autoCreateTopicEnable=true >/usr/local/alibaba/rocketmq/rocketmq-all-5.1.3-bin-release/logs/mqbroker.log 2>&1 &

# 查看日志
tail -300f /usr/local/alibaba/rocketmq/rocketmq-all-5.1.3-bin-release/logs/mqbroker.log

五、 检查是否启动成功

localhost:~ ds$ jps -l

2512 org.jetbrains.idea.maven.server.RemoteMavenServer36
3348 sun.tools.jps.Jps
950 org.jetbrains.idea.maven.server.RemoteMavenServer36
3318 org.apache.rocketmq.broker.BrokerStartup
873 
3194 org.apache.rocketmq.namesrv.NamesrvStartup
2188 /usr/local/alibaba/sentinel/sentinel-dashboard-1.8.6.jar
2142 /usr/local/alibaba/nacos/target/nacos-server.jar

六、检查broker与namesrv的连接是否正常

# 检查broker与namesrv的连接是否正常
mqadmin clusterList -n 127.0.0.1:9876

# 需要开放端口9876 、10909 、10911 、10912 
# 查看端口是否开放 10909
nc -zv -w 2 -u 127.0.0.1 10909
# Connection to 127.0.0.1 port 10909 [udp/*] succeeded!

查看端口占用(lsof -i tcp:port，端口10911为例)：
lsof -i tcp:10911
# COMMAND  PID      USER   FD   TYPE             DEVICE SIZE/OFF NODE NAME
# java    6157 ds  175u  IPv6 0x63559c23bf700b13      0t0  TCP *:10911 (LISTEN)

七、 验证生产消息、消费消息正常

export NAMESRV_ADDR=127.0.0.1:9876
# 验证生产消息正常
sh /usr/local/alibaba/rocketmq/rocketmq-all-5.1.3-bin-release/bin/tools.sh org.apache.rocketmq.example.quickstart.Producer

# SendResult [sendStatus=SEND_OK, msgId=C0A800771B0E3D494FBF8E362D7703E7, offsetMsgId=7F00000100002A9F000000000003AC09, messageQueue=MessageQueue [topic=TopicTest, brokerName=broker-a, queueId=2], queueOffset=249]

# 验证消费消息正常
sh /usr/local/alibaba/rocketmq/rocketmq-all-5.1.3-bin-release/bin/tools.sh org.apache.rocketmq.example.quickstart.Consumer

# ConsumeMessageThread_please_rename_unique_group_name_4_7 Receive New Messages: [MessageExt [brokerName=broker-a, queueId=0, storeSize=241, queueOffset=248, sysFlag=0, bornTimestamp=1690526715252, bornHost=/127.0.0.1:54737, storeTimestamp=1690526715252, storeHost=/127.0.0.1:10911, msgId=7F00000100002A9F000000000003A663, commitLogOffset=239203, bodyCRC=1188845061, reconsumeTimes=0, preparedTransactionOffset=0, toString()=Message{topic='TopicTest', flag=0, properties={CONSUME_START_TIME=1690526748781, MSG_REGION=DefaultRegion, UNIQ_KEY=C0A800771B0E3D494FBF8E362D7403E1, CLUSTER=DefaultCluster, MIN_OFFSET=0, TAGS=TagA, WAIT=true, TRACE_ON=true, MAX_OFFSET=250}, body=[72, 101, 108, 108, 111, 32, 82, 111, 99, 107, 101, 116, 77, 81, 32, 57, 57, 51], transactionId='null'}]] 

八、 关闭RocketMQ

3.关闭 RocketMQ 命令
/usr/local/alibaba/rocketmq/rocketmq-all-5.1.3-bin-release/bin/mqshutdown broker
/usr/local/alibaba/rocketmq/rocketmq-all-5.1.3-bin-release/bin/mqshutdown namesrv

九、 RocketMQ 控制台安装

官方地址：https://github.com/apache/rocketmq-dashboard/releases/tag/rocketmq-dashboard-1.0.0

百度链接: https://pan.baidu.com/s/1yXVjmlGPw-mSAETdn7hxYg  密码: avo6

十、 修改application.properties

server.port=9877
rocketmq.config.namesrvAddr=127.0.0.1:9876

十一、 maven打包 并 运行

cd /Users/ds/Documents/bjzx/rocketmq-dashboard-rocketmq-dashboard-1.0.0
# maven 打包
mvn clean package -Dmaven.test.skip=true

cd target/
mv rocketmq-dashboard-1.0.0.jar /usr/local/alibaba/rocketmq-dashboard

# 运行jar
nohup java -jar /usr/local/alibaba/rocketmq-dashboard/rocketmq-dashboard-1.0.0.jar >/usr/local/alibaba/rocketmq-dashboard/log.out  2>&1 &

# 查看日志
tail -300f /usr/local/alibaba/rocketmq-dashboard/log.out

十二、 打开浏览器

http://127.0.0.1:9877/

image.png

参考：
https://www.jianshu.com/p/e56bd2dcab26