Centos7 安装RocketMQ（二进制版）

一、介绍

RocketMQ：云原生“消息、变乱、流”及时数据处理平台，覆盖云边端一体化数据处理场景
   在阿里孕育 RocketMQ的雏形时期，我们将其用于异步通信、搜索、社交网络活动流、数据管道，贸易流程中。随着我们的贸易业务吞吐量的上升，源自我们的消息传递集群的压力也变得紧迫。
根据我们的研究，随着队列和虚拟主题使用的增长，ActiveMQ IO模块达到了一个瓶颈。我们尽力通过节流、断路器或降级来解决这个问题，但效果并不抱负。于是我们尝试了盛行的消息传递解决方案Kafka。不幸的是，Kafka不能满足我们的要求，其尤其表现在低延迟和高可靠性方面，详见这里。在这种环境下，我们决定发明一个新的消息传递引擎来处理更广泛的消息用例，覆盖从传统的pub/sub场景到高容量的及时零误差的生意业务系统。
Apache RocketMQ 自诞生以来，因其架构简单、业务功能丰富、具备极强可扩展性等特点被众多企业开辟者以及云厂商广泛采用。历经十余年的大规模场景打磨，RocketMQ 已经成为业内共识的金融级可靠业务消息首选方案，被广泛应用于互联网、大数据、移动互联网、物联网等范畴的业务场景。
  二、环境要求

• 64位操作系统，推荐 Linux/Unix/macOS
  
• 64位 JDK 1.8+
  
• 本文采用二进制包方式安装，版本为4.4.0
  

三、下载

3.1 二进制包官网下载链接

点击下载
3.2 二进制包百度网盘下载链接

通过百度网盘分享的文件：rocketmq-all-4.4.0-bin-release.zip
链接：https://pan.baidu.com/s/1Bxk9hz27vM62GFq7SN5eow?pwd=6nwd
提取码：6nwd
3.3 二进制包夸克网盘下载链接

我用夸克网盘分享了「rocketmq-all-4.4.0-bin-release.zip」，点击链接即可保存。打开「夸克APP」，无需下载在线播放视频，畅享原画5倍速，支持电视投屏。
链接：https://pan.quark.cn/s/44a5b8eaeb02
3.4 上传到指定目录

我们将文件上传到/root/mq目录下，然后使用unzip下令举行解压

然后我们使用mv下令重命名文件，下令如下

1. mv rocketmq-all-4.4.0-bin-release rocketmq

复制代码

接着使用cd下令进入对应文件夹

1. cd rocketmq

复制代码

四、目录介绍

4.1 benchmark

存放一些demo，可以直接运行。

4.2 bin

启动脚本，包括shell脚本和cmd脚本

4.3 conf

RocketMQ实例配置文件，包过broker配置文件，logback配置文件等

4.4 lib

依靠第三方jar包，包括Netty、commons-lang、FastJSON等

五、启动RocketMQ

5.1 启动NameServer

1. # 1.进入bin目录
2. cd /root/mq/rocketmq/bin
4. # 2.启动NameServer
5. nohup sh mqnamesrv &
6. # 3.查看启动日志
7. tail -f ~/logs/rocketmqlogs/namesrv.log

复制代码

看到下图代表启动乐成

5.2 启动Broker

1. # 1.进入bin目录
2. cd /root/mq/rocketmq/bin
4. # 2.启动Broker
5. nohup sh mqbroker -n localhost:9876 &
6. # 3.查看启动日志
7. tail -f ~/logs/rocketmqlogs/broker.log

复制代码

如果发现tail下令找不到文件的话，说明可能Broker启动失败了。需要我们举行排查（可以参考备注）

启动乐成图片如下

六、测试RocketMQ

我们在启动两个窗口举行测试，两个窗口都进入bin目录

1. cd /root/mq/rocketmq/bin

复制代码

6.1 第一个窗口

然后我们在第一个窗口，输入下面代码，发送消息

1. # 1.设置环境变量
2. export NAMESRV_ADDR=localhost:9876
3. # 2.使用安装包的Demo发送消息
4. sh tools.sh org.apache.rocketmq.example.quickstart.Producer

复制代码

发送乐成如图所示

6.2 第二个窗口

1. # 1.设置环境变量
2. export NAMESRV_ADDR=localhost:9876
3. # 2.接收消息
4. sh tools.sh org.apache.rocketmq.example.quickstart.Consumer

复制代码

我们可以看到第二个窗口一直处于正在担当信息的状态，同时上面输出的消息也是第一个窗口发送的

七、关闭RocketMQ

1. # 1.进入bin目录cd /root/mq/rocketmq/bin
2. # 2.关闭NameServersh mqshutdown namesrv# 3.关闭Brokersh mqshutdown broker

复制代码

八、备注

RocketMQ默认的虚拟机内存为8G，启动Broker如果因为内存不敷失败，需要编辑如下两个配置文件，修改JVM内存巨细

1. # 编辑runbroker.sh和runserver.sh修改默认JVM大小
2. vim runbroker.sh
3. vim runserver.sh
5. # 参考配置 按i键进入插入模式，按ESC后输入 :wq 保存
6. JAVA_OPT="${JAVA_OPT} -server -Xms256m -Xmx256m -Xmn128m"

复制代码

然后重启nameserver和broker

免责声明：如果侵犯了您的权益，请联系站长，我们会及时删除侵权内容，谢谢合作！更多信息从访问主页：qidao123.com:ToB企服之家，中国第一个企服评测及商务社交产业平台。