单机安装RocketMQ(快速开始)

  |   0 评论   |   0 浏览

前面的文章对RocketMQ的介绍,下面我们尝试在单机环境下安装部署RocketMQ。该安装步骤主要参考官网,原文点我

1. 安装准备

在安装部署RocketMQ之前,我们先要确定你的电脑上的环境:

  1. 64位的操作系统,这里我们使用CentOS7.4
  2. 64位 JDK 1.8+
  3. Maven 3.2.x(可选,编译安装必须)
  4. Git (可选,只是用来下载)
  5. 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

标题:单机安装RocketMQ(快速开始)
作者:pangcm
地址:http://pangcm.club/articles/2019/08/28/1566975194981.html