网站首页 > 博客文章 正文
这里是 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目录下,你们也可以自己搭建服务器。
// 解压安装包
# unzip rocketmq-all-4.9.2-bin-release.zip
//解压后修改文件夹名称,也可不修改
# mv rocketmq-4.9.2/ rocketmq
配置环境变量
我们需要将刚刚解压的 rocketmq 路径配置到环境变量中。
//编辑profile文件
# vi /etc/profile
//将以下代码配置进去,我这里路径是/data/rocketmq
//你们只需根据自己实际路径进行替换即可
export ROCKETMQ_HOME=/data/rocketmq
export PATH=$PATH:$ROCKETMQ_HOME/bin:$PATH
配置完成后,退出保存,如何输入以下命令使其生效
//使刚修改的配置文件生效
# source /etc/profile
//验证刚刚的路径配置是否生效
# echo $ROCKETMQ_HOME
//显示出路径地址代表配置没有问题
/data/rocketmq
启动 nameserver
# nohup sh bin/mqnamesrv &
查看是否启动成功
# jps -l
可以看到 nameServer 我们就已经启动成功了。
配置 jvm参数
RocketMQ Broker 默认配置的 jvm 虚拟机内存大小可能比较大,如果不修改会导致启动不起来,这里我们根据自己的实际需要进行修改。
# vi bin/runbroker.sh
默认指定的是 8g,我这里修改为 256m。
启动 Broker
//启动 NameServer 命令
# nohup sh bin/mqbroker -c conf/broker.conf &
# 查看是否启动成功
# jps -l
模拟发送消息 和 消费消息
目前 我们 NameServer 和 Broker 都已经启动成功,就可以进行发送和消费消息,RocketMQ 安装包默认提供了一个模拟发送消息和消费消息的测试类,我们来验证一下。
发送消息
//创建生产者发送消息
# sh bin/tools.sh org.apache.rocketmq.example.quickstart.Producer
我们发现没有启动起来,出现了错误,这是为什么呢?
RocketMQ NameServer 默认端口号是 9876 ,如果你开启了防火墙,你要么关闭防火墙,要么在安全组中将 9876 端口号设置允许访问,我这里就设置了允许访问。
此时,模拟发送成功了,默认是发送 1000 条消息。
消费消息
# sh bin/tools.sh org.apache.rocketmq.example.quickstart.Consumer
通过模拟发送和消费,也就验证了我们整个 RocketMQ 就搭建成功了。
还有个 NameServer 和 Broker 关闭命令也介绍下:
// 关闭 Broker
sh bin/mqshutdown broker
// 关闭 NameServer
sh bin/mqshutdown namesrv
猜你喜欢
- 2024-11-18 快速使用docker方式部署安装RocketMQ
- 2024-11-18 介绍新版RocketMQ v4.9.3 下载、安装、配置的完成过程
- 2024-11-18 docker-4:mac使用docker部署开发用rocketmq
- 2024-11-18 扩展RocketMQ 使其支持任意时间精度的消息延迟
- 2024-11-18 RocketMQ如何突破内网限制,实现内外网互通
- 2024-11-18 SpringBoot3.0 + RocketMq 构建企业级数据中台完结
- 2024-11-18 centos7安装部署RocketMQ分布式集群
- 2024-11-18 「转」Spring Cloud异步场景分布式事务怎样做?试试RocketMQ
- 2024-11-18 RocketMQ集群搭建
- 2024-11-18 RocketMQ 的持久化配置
你 发表评论:
欢迎- 最近发表
- 标签列表
-
- powershellfor (55)
- messagesource (56)
- aspose.pdf破解版 (56)
- promise.race (63)
- 2019cad序列号和密钥激活码 (62)
- window.performance (66)
- qt删除文件夹 (72)
- mysqlcaching_sha2_password (64)
- ubuntu升级gcc (58)
- nacos启动失败 (64)
- ssh-add (70)
- jwt漏洞 (58)
- macos14下载 (58)
- yarnnode (62)
- abstractqueuedsynchronizer (64)
- source~/.bashrc没有那个文件或目录 (65)
- springboot整合activiti工作流 (70)
- jmeter插件下载 (61)
- 抓包分析 (60)
- idea创建mavenweb项目 (65)
- vue回到顶部 (57)
- qcombobox样式表 (68)
- vue数组concat (56)
- tomcatundertow (58)
- pastemac (61)
本文暂时没有评论,来添加一个吧(●'◡'●)