0


【 RocketMQ 专栏】基于 Linux 环境安装部署 RocketMQ 教程(一步一步跟着安装就对了)

这里是 RocketMQ 系列的第一篇文章,工欲善其事,必先利其器,先不讲理论,也不具体介绍 RocketMQ,我们先把 RocketMQ先安装上,让你们实地感受下 RocketMQ 整个安装流程,安装完后我们再后续文章对 RocketMQ 手术刀式一层一层进行剖析。

下载安装包

直接从 RocketMQ 官网下载最新的安装包

下载地址https://www.apache.org/dyn/closer.cgi?path=rocketmq/4.9.2/rocketmq-all-4.9.2-bin-release.zip

image-20220202220357356

解压安装包

下载后,我们将它放入linux服务器中任意目录并解压,我这里使用的是云服务器,放到了data目录下,你们也可以自己搭建服务器。

  1. // 解压安装包
  2. # unzip rocketmq-all-4.9.2-bin-release.zip
  3. //解压后修改文件夹名称,也可不修改
  4. # mv rocketmq-4.9.2/ rocketmq

配置环境变量

我们需要将刚刚解压的 rocketmq 路径配置到环境变量中。

  1. //编辑profile文件
  2. # vi /etc/profile
  3. //将以下代码配置进去,我这里路径是/data/rocketmq
  4. //你们只需根据自己实际路径进行替换即可
  5. export ROCKETMQ_HOME=/data/rocketmq
  6. export PATH=$PATH:$ROCKETMQ_HOME/bin:$PATH

配置完成后,退出保存,如何输入以下命令使其生效

  1. //使刚修改的配置文件生效
  2. # source /etc/profile
  3. //验证刚刚的路径配置是否生效
  4. # echo $ROCKETMQ_HOME
  5. //显示出路径地址代表配置没有问题
  6. /data/rocketmq

启动 nameserver

  1. # nohup sh bin/mqnamesrv &

查看是否启动成功

  1. # jps -l

image-20220202224508740

可以看到 nameServer 我们就已经启动成功了。

配置 jvm参数

RocketMQ Broker 默认配置的 jvm 虚拟机内存大小可能比较大,如果不修改会导致启动不起来,这里我们根据自己的实际需要进行修改。

  1. # vi bin/runbroker.sh

image-20220202225426701

默认指定的是 8g,我这里修改为 256m。

image-20220202225644365

启动 Broker

  1. //启动 NameServer 命令
  2. # nohup sh bin/mqbroker -c conf/broker.conf &
  3. # 查看是否启动成功
  4. # jps -l

image-20220202230009972

模拟发送消息 和 消费消息

目前 我们 NameServer 和 Broker 都已经启动成功,就可以进行发送和消费消息,RocketMQ 安装包默认提供了一个模拟发送消息和消费消息的测试类,我们来验证一下。

发送消息

  1. //创建生产者发送消息
  2. # sh bin/tools.sh org.apache.rocketmq.example.quickstart.Producer

image-20220202230320434

我们发现没有启动起来,出现了错误,这是为什么呢?

RocketMQ NameServer 默认端口号是 9876 ,如果你开启了防火墙,你要么关闭防火墙,要么在安全组中将 9876 端口号设置允许访问,我这里就设置了允许访问。

image-20220202233700639

image-20220202233855547

此时,模拟发送成功了,默认是发送 1000 条消息。

消费消息

  1. # sh bin/tools.sh org.apache.rocketmq.example.quickstart.Consumer

image-20220202234053173

通过模拟发送和消费,也就验证了我们整个 RocketMQ 就搭建成功了。

还有个 NameServer 和 Broker 关闭命令也介绍下:

  1. // 关闭 Broker
  2. sh bin/mqshutdown broker
  3. // 关闭 NameServer
  4. sh bin/mqshutdown namesrv
标签: linux java RocketMQ

本文转载自: https://blog.csdn.net/qq_34375473/article/details/122779239
版权归原作者 程序员蛋蛋 所有, 如有侵权,请联系我们删除。

“【 RocketMQ 专栏】基于 Linux 环境安装部署 RocketMQ 教程(一步一步跟着安装就对了)”的评论:

还没有评论