前面的文章对RocketMQ的介绍,下面我们尝试在单机环境下安装部署RocketMQ。该安装步骤主要参考官网,原文点我
1. 安装准备
在安装部署RocketMQ之前,我们先要确定你的电脑上的环境:
- 64位的操作系统,这里我们使用CentOS7.4
- 64位 JDK 1.8+
- Maven 3.2.x(可选,编译安装必须)
- Git (可选,只是用来下载)
- 4G以上的磁盘空间
2. 下载并编译
点击 这里 下载 4.4.0的源码包。 如果你不想编译安装的话,可以直接下载二进制包,点击 这里.
接下来执行下面的命令编译刚刚下载好的源码包:
#解压
unzip rocketmq-all-4.4.0-source-release.zip
cd rocketmq-all-4.4.0/
#使用mvn来编译
mvn -Prelease-all -DskipTests clean install -U
cd distribution/target/apache-rocketmq
注意:
mvn的下载速度可能有点慢,建议修改为国内的源。修改 maven的配置文件,conf/settings.xml 。找到 mirrors 标签修改
<mirror>
<id>alimaven</id>
<name>aliyun maven</name>
<url>http://maven.aliyun.com/nexus/content/groups/public/</url>
<mirrorOf>central</mirrorOf>
</mirror>
3. 启动RocketMQ
在前面我们已经编译好了RocketMQ了,如果使用的是二进制安装,直接解压然后进入目录即可。
3.1 首先我们先启动 Name Server
#nohup来启动
nohup sh bin/mqnamesrv &
#查看日志
tail -f ~/logs/rocketmqlogs/namesrv.log
3.2 然后,我们来启动Broker
#nohup来启动
nohup sh bin/mqbroker -n localhost:9876 &
#查看日志
tail -f ~/logs/rocketmqlogs/broker.log
注意:
启动NameServer 和Broker的时候可能会出现错误,请留意对应的日志文件。在测试环境中常见的错误是内存不足的错误,这时候可以修改NameSever和Broker的启动脚本。
#shell脚本里面配置java的内存大小
bin/runserver.sh
bin/runbroker.sh
#mqbroker.xml和mqnamesrv.xml的内存不要超过runbroker.sh 和runserver.sh的内存,不然会引起内存不够导致奔溃。
bin/mqnamesrv.xml
bin/mqbroker.xml
4. 发送和收取消息
在发送和收取消息之前,我们需要告诉客户端Name Server的位置。RocketMQ有多种办法来实现,在这里我们使用最简单的环境变量 NAMESRV_ADDR
。
export NAMESRV_ADDR=localhost:9876
#生产者
sh bin/tools.sh org.apache.rocketmq.example.quickstart.Producer
#消费者
sh bin/tools.sh org.apache.rocketmq.example.quickstart.Consumer
5. 关闭服务
#关闭broker
sh bin/mqshutdown broker
#关闭nameserver
sh bin/mqshutdown namesrv
网友评论