当前位置: 首页 > 科技观察

基于Linux环境安装部署RocketMQ教程

时间:2023-03-13 21:40:13 科技观察

这是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解压安装包下载完成后,我们将其放入linux服务器任意目录下解压。我这里用的是云服务器,放在data目录下。您也可以构建自己的服务器。//解压安装包#unziprocketmq-all-4.9.2-bin-release.zip//解压后修改文件夹名称,或者不修改#mvrocketmq-4.9.2/rocketmq配置环境变量我们需要解压环境变量中配置了rocketmq路径。//启用新修改的配置文件#source/etc/profile//验证刚才的路径配置是否生效#echo$ROCKETMQ_HOME//显示路径地址说明配置/data/rocketmq没有问题配置完成后,退出并保存,如何输入以下命令使其生效启动nameserver#nohupshbin/mqnamesrv&查看是否启动成功#nohupshbin/mqnamesrv&可以看到nameServer有已成功启动。配置jvm参数RocketMQBroker默认配置的jvm虚拟机内存大小可能比较大。如果不修改,会导致无法启动。这里我们根据自己的实际需要进行修改。#vibin/runbroker.sh默认指定8g,我这里修改为256m。启动Broker//启动NameServer命令#nohupshbin/mqbroker-cconf/broker.conf#检查是否启动成功#jps-l模拟发送和消费消息目前我们的NameServer和Broker都已经启动成功,而我们可以发送和消费消息,RocketMQ安装包默认提供了一个模拟发送和消费消息的测试类。我们来验证一下。发送消息//创建生产者发送消息#shbin/tools.shorg.apache.rocketmq.example.quickstart.Producer发现没有启动,报错。为什么?RocketMQNameServer默认的端口号是9876,如果开启了防火墙,要么关闭防火墙,要么在安全组中设置9876端口号允许访问,我这里设置的是允许访问。至此模拟发送成功,默认发送1000条消息。消费消息#shbin/tools.shorg.apache.rocketmq.example.quickstart.Consumer通过模拟发送消费,也验证了我们整个RocketMQ搭建成功。还有一个NameServer和Broker关闭命令://closeBrokershbin/mqshutdownbroker//closeNameServershbin/mqshutdownnamesrv