Rocket MQ 单机搭建（二）

1. 安装JDK

2. 下载RocketMQ：http://rocketmq.apache.org -> Geting Started -> Download

3. 安装

#创建一个操作用户，与root用户区分开
useradd oper
passwd oper
mkdir /app
chown oper:oper /app #赋予app目录 所属主和所属组

#切换到oper用户
su oper
#上传并解压
cd /app/rocketmq 
unzip rocketmq-all-4.8.0-bin-release.zip 

#添加环境变量
vim  ~/.bash_profile 
#export ROCKETMQ_HOME=/app/rocketmq/rocketmq-4.8.0
#PATH=$ROCKETMQ_HOME/bin:$JAVA_HOME/bin:$PATH:$HOME/.local/bin:$HOME/bin
source ~/.bash_profile

4. 启动

#RocketMQ默认预设的JVM内存是4G。通常虚拟机不够4G内存，需要调整JVM内存大小
vim /app/rocketmq/rocketmq-4.8.0/bin/runserver.sh
#修改：JAVA_OPT="${JAVA_OPT} -server -Xms512m -Xmx512m -Xmn256m

#1.启动NameServer：提供轻量级的Broker注册中心
nohup bin/mqnamesrv &

#查看日志如下，表示启动成功
less /app/rocketmq/rocketmq-4.8.0/bin/nohup.out
java HotSpot(TM) 64-Bit Server VM warning: Using the DefNew young collector with the CMS collector is deprecated and will likely be removed in a future release
Java HotSpot(TM) 64-Bit Server VM warning: UseCMSCompactAtFullCollection is deprecated and will likely be removed in a future release.
The Name Server boot success. serializeType=JSON

#JPS查看java进程
[oper@localhost bin]$ jps
4421 Jps
4326 NamesrvStartup

vim /app/rocketmq/rocketmq-4.8.0/bin/runbroker.sh
#修改：JAVA_OPT="${JAVA_OPT} -server -Xms512m -Xmx512m -Xmn256m"

#为了启动后测试验证，配置开启自动创建Topic
vim /app/rocketmq/rocketmq-4.8.0/conf/broker.conf
#最下面一行添加：autoCreateTopicEnable = true

#2.启动Broker：实际处理消息存储、转发等服务的核心组件
#需要先关闭防火墙
nohup /app/rocketmq/rocketmq-4.8.0/bin/mqbroker &

#检查日志
less /app/rocketmq/rocketmq-4.8.0/bin/nohup.out
Java HotSpot(TM) 64-Bit Server VM warning: Using the DefNew young collector with the CMS collector is deprecated and will likely be removed in a future release
Java HotSpot(TM) 64-Bit Server VM warning: UseCMSCompactAtFullCollection is deprecated and will likely be removed in a future release.
The Name Server boot success. serializeType=JSON
The broker[localhost.localdomain, 10.22.101.56:10911] boot success. serializeType=JSON

#JPS查看java进程
[oper@localhost bin]$ jps
4326 NamesrvStartup
30827 BrokerStartup
30879 Jps

4. 验证

#默认发送1000条消息
/app/rocketmq/rocketmq-4.8.0/bin/tools.sh org.apache.rocketmq.example.quickstart.Producer

#接收消息
/app/rocketmq/rocketmq-4.8.0/bin/tools.sh org.apache.rocketmq.example.quickstart.Consumer

5. 关闭RocketMQ服务

#关闭Broker
sh /app/rocketmq/rocketmq-4.8.0/bin/mqshutdown broker
# 关闭NameServer
sh /app/rocketmq/rocketmq-4.8.0/bin/mqshutdown namesrv