阿⾥云服务器—Linux安装rocketMQ教程
1、RocketMQ简介
是⼀款分布式、队列模型的，具有以下特点：
能够保证严格的消息顺序
提供丰富的消息拉取模式
⾼效的订阅者⽔平扩展能⼒
实时的消息订阅机制
亿级消息堆积能⼒
2 、准备⼯作
JDK1.8以上
安装maven环境
rocketMQ4.4(我这⾥安装的是4.4版本)
3、开始安装
⾸先将rocketmq安装包上传到服务器上，然后进⾏解压
如果是tar包使⽤
tar -zxvf 包名
进⾏解压
如果zip包使⽤
unzip rocketmq-all-4.4.0-source-release.zip
进⾏解压要先安装解压软件执⾏这个命令： yum install unzip
解压完成后使⽤命令 ：cd rocketmq-all-4.4.0/
然后执⾏（这个要下载很多东西，可能要⼗⼏分钟）：mvn -Prelease-all -DskipTests clean install -U
完成后执⾏：cd distribution/target/apache-rocketmq
启动nameServer: nohup sh bin/mqnamesrv &
查看⽇志：tail -f nohup.out （结尾：The Name Server boot success. serializeType=JSON。表⽰启动成功）
启动broker：nohup sh bin/mqbroker -n localhost:9876 &
验证
在发送/接收消息之前，我们需要告诉客户名称服务器的位置。RocketMQ 提供了多种⽅法来实现这⼀点。为了简单起见，我们使⽤环境变量NAMESRV_ADDR
1发送
export NAMESRV_ADDR=localhost:9876
sh bin/tools.sh ample.quickstart.Producer
2 接收
sh bin/tools.sh ample.quickstart.Consumer
关闭服务器
sh bin/mqshutdown broker    //停⽌ broker
sh bin/mqshutdown namesrv  //停⽌ nameserver
修改内存配置
默认配置太⼤，top命令下消耗内存太多，可按需求更改
cd /rocketmq-all-4.2.0/distribution/target/apache-rocketmq/bin
使⽤vim xxx.sh命令进⾏JVM参数配置修改：
将runbroker.sh的第⼀个JAVA_OPT改成JAVA_OPT="${JAVA_OPT} -server -Xms256m -Xmx256m -Xmn128m"
将runserver.sh的第⼀个JAVA_OPT改成JAVA_OPT="${JAVA_OPT} -server -Xms128m -Xmx256m -Xmn256m -
XX:MetaspaceSize=128m -XX:MaxMetaspaceSize=320m"
常⽤命令
查看集情况 ./mqadmin clusterList -n 192.168.102.84:9876
查看 broker 状态 ./mqadmin brokerStatus -n 192.168.102.84:9876 -b 192.168.102.84:10911 (注意换成你的 broker 地址)查看 topic 列表 ./mqadmin topicList -n 192.168.102.84:9876
linux安装jdk教程查看 topic 状态 ./mqadmin topicStatus -n 192.168.102.84:9876 -t MyTopic (换成你想查询的 topic)
查看 topic 路由 ./mqadmin topicRoute -n 192.168.102.84:9876 -t MyTopic

版权声明：本站内容均来自互联网，仅供演示用，请勿用于商业和其他非法用途。如果侵犯了您的权益请与我们联系QQ:729038198，我们将在24小时内删除。