RocketMQ 学习之路 | 第一章 :RocketMQ 的安装与配置

一:RocketMQ 简介

RocketMQ 是一款分布式、队列模型的消息中间件,具有以下特点:

  1. 能够保证严格的消息顺序。
  2. 提供丰富的消息拉取模式。
  3. 高效的订阅者水平扩展能力。
  4. 实时的消息订阅机制。
  5. 亿级消息堆积能力。

二:RocketMQ的安装
1.下载RocketMQ源码

下载地址 rocketmq-4.4.0

2.解压 , 进入解压目录

unzip rocketmq-all-4.2.0-source-release.zip
cd rocketmq-all-4.4.0

3.执行安装命令

mvn -Prelease-all -DskipTests clean install -U

4.安装完成后进入启动文件所在目录

cd distribution/target/apache-rocketmq

5.启动服务器, 查看启动日志

nohup sh bin/mqnamesrv &
tail -f ~/logs/rocketmqlogs/namesrv.log

6.启动broker , 查看broker启动日志

nohup sh bin/mqbroker -n localhost:9876 &
tail -f ~/logs/rocketmqlogs/broker.log

7.查看是否启动成功
jps

RocketMQ 学习之路 | 第一章 :RocketMQ 的安装与配置

8.停止服务,停止broker

sh bin/mqshutdown broker
sh bin/mqshutdown namesrv

8.常见问题

  • JAVA_HOME 环境变量未配置,可设置RocketMQ的JDK环境 , 打开bin目录下 runserver.shrunbroker.sh, 将设置JAVA_HOME的第二三行注释掉,在第一行设置JDK的安装目录。如下所示:

[ ! -e "$JAVA_HOME/bin/java" ] && JAVA_HOME=/Library/Java/JavaVirtualMachines/jdk1.8.0_181.jdk/Contents/Home
#[ ! -e "$JAVA_HOME/bin/java" ] && JAVA_HOME=/usr/java
#[ ! -e "$JAVA_HOME/bin/java" ] && error_exit "Please set the JAVA_HOME variable in your environment, We need java(x64)!

上一篇:微服务架构下分布式事务解决方案 | 第一章 : 分布式事务


下一篇:jQuery EasyUI API 中文文档 - 搜索框