在CentOS7上安装RocketMQ 4.8.0

简介: 本文是博主在CentOS7上安装RocketMQ 4.8.0的记录,希望对大家有所帮助。

安装过程

服务器上已经安装了OpenJDK 8,并设置了JAVA_HOME

下载和解压RocketMQ

RocketMQ官网上找到下载RocketMQ4.8.0的链接,下载和解压RocketMQ

下载

wget http://ftp.cuhk.edu.hk/pub/packages/apache.org/rocketmq/4.8.0/rocketmq-all-4.8.0-bin-release.zip  

解压

unzip rocketmq-all-4.8.0-bin-release.zip  

安装到/usr/local/rocketmq

mv rocketmq-all-4.8.0-bin-release /usr/local  
ln -s /usr/local/rocketmq-all-4.8.0-bin-release /usr/local/rocketmq 

调低RocketMQ的JVM大小

RocketMQ的默认JVM太大,不适合在开发测试环境中使用,需要调低JVM大小。

在RocketMQ的安装目录(本例为/usr/local/rocketmq),查找sh脚本中的JVM参数设置:

find . -name '*.sh' | xargs egrep 'Xms' 

需要修改以下sh脚本的JVM参数:

bin/runserver.sh
bin/runbroker.sh
bin/tools.sh
修改前记得先备份相应脚本,具体JVM大小根据实际情况设定。

  • bin/runserver.sh

修改前:

JAVA_OPT="${JAVA_OPT} -server -Xms4g -Xmx4g -Xmn2g -XX:MetaspaceSize=128m -XX:MaxMetaspaceSize=320m" 

修改后:

JAVA_OPT="${JAVA_OPT} -server -Xms256m -Xmx256m -Xmn128m -XX:MetaspaceSize=128m -XX:MaxMetaspaceSize=320m" 
  • bin/runserver.sh

修改前:

JAVA_OPT="${JAVA_OPT} -server -Xms4g -Xmx4g -Xmn2g -XX:MetaspaceSize=128m -XX:MaxMetaspaceSize=320m" 

修改后:

JAVA_OPT="${JAVA_OPT} -server -Xms256m -Xmx256m -Xmn128m -XX:MetaspaceSize=128m -XX:MaxMetaspaceSize=320m" 
  • bin/tools.sh
  • 修改前:
JAVA_OPT="${JAVA_OPT} -server -Xms1g -Xmx1g -Xmn256m -XX:MetaspaceSize=128m -XX:MaxMetaspaceSize=128m" 

修改后:

JAVA_OPT="${JAVA_OPT} -server -Xms256m -Xmx256m -Xmn128m -XX:MetaspaceSize=128m -XX:MaxMetaspaceSize=128m" 

启动Name Server

后台启动

nohup sh bin/mqnamesrv >/dev/null 2>&1 &
Name Server的默认端口为9876,运行sh bin/mqnamesrv -p可查看Name Server的配置项,并可通过-c namesrv.conf方式指定配置文件启动;

RocketMQ的默认日志路径为~/logs/rocketmqlogs/

可以将启动Name Server命令保存为脚本,以方便下次启动。

启动Broker

启动Broker时需要指定要连接的Name Server:

后台启动

nohup sh bin/mqbroker -n localhost:9876 >/dev/null 2>&1 & 

可以将启动Broker命令保存为脚本,以方便下次启动。

查看RocketMQ进程

ps -ef | grep -v grep | grep rocketmq 

测试RocketMQ

测试发送消息和接收消息

使用RocketMQ自带的消息生产者和消费者示例来测试发送消息和接收消息:

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 

关闭RocketMQ

关闭Broker

sh bin/mqshutdown broker 

可以将关闭Broker命令保存为脚本,以方便下次关闭。

关闭Name Server

sh bin/mqshutdown namesrv 

关闭Name Server前需要先关闭Broker;

可以将关闭Name Server命令保存为脚本,以方便下次关闭。

  1. 修改Name Server的端口

RocketMQ Name Server的默认端口为9876,可以通过以下方法修改Name Server的端口:

新增一个Name Server配置文件namesrv.conf,保存内容为:

listenPort=10076 
  1. 启动Name Server时指定配置文件:
nohup sh bin/mqnamesrv -c namesrv.conf >/dev/null 2>&1 & 
  1. 查看RocketMQ进程:
ps -ef | grep rocketmq 
  1. 查看RocketMQ Name Server的端口号:
netstat -tnlp | grep <nameserver_pid>
  1. 修改后Broker需要指定新的Name Server地址(端口)。

安装RocketMQ控制台

克隆rocketmq-externals 项目,并编译rocketmq-console。

命令示例:

git clone https://github.com/apache/rocketmq-externals.git  
cd rocketmq-externals/rocketmq-console  
mvn clean package -Dmaven.test.skip=true 

将target/rocketmq-console-ng*.jar放到和RocketMQ安装目录(本例为/usr/local/rocketmq)下。

在RocketMQ安装目录下新建一个启动RocketMQ控制台的脚本来启动RocketMQ控制台:

nohup java -jar rocketmq-console-ng*.jar --server.port=8080 --rocketmq.config.namesrvAddr=localhost:9876 > /dev/null 2>&1 &
默认RocketMQ控制台不需要密码登录,请参考RocketMQ使用文档 进行配置。

参考:

https://github.com/apache/rocketmq-externals
https://github.com/apache/rocketmq-externals/tree/master/rocketmq-console

其他问题

问题1: 启动Name Server和Broker,或测试时报错Please set the JAVA_HOME variable in your environment, We need java(x64)!但是系统已经安装了OpenJDK8,并且已经设置了JAVA_HOME。

解决方法: 运行which java来查看java的路径,比如为/usr/bin/java。

修改bin/runserver.sh和bin/runbroker.sh和bin/tools.sh,注释掉校验JAVA_HOME语句,并明确指定JAVA路径:

#[ ! -e "$JAVA_HOME/bin/java" ] && JAVA_HOME=$HOME/jdk/java  
#[ ! -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)!"  
#export JAVA_HOME  
export JAVA="/usr/bin/java"  
相关实践学习
快速体验阿里云云消息队列RocketMQ版
本实验将带您快速体验使用云消息队列RocketMQ版Serverless系列实例进行获取接入点、创建Topic、创建订阅组、收发消息、查看消息轨迹和仪表盘。
消息队列 MNS 入门课程
1、消息队列MNS简介 本节课介绍消息队列的MNS的基础概念 2、消息队列MNS特性 本节课介绍消息队列的MNS的主要特性 3、MNS的最佳实践及场景应用 本节课介绍消息队列的MNS的最佳实践及场景应用案例 4、手把手系列:消息队列MNS实操讲 本节课介绍消息队列的MNS的实际操作演示 5、动手实验:基于MNS,0基础轻松构建 Web Client 本节课带您一起基于MNS,0基础轻松构建 Web Client
目录
相关文章
|
1月前
|
存储 Ubuntu Linux
VMware-安装CentOS系统教程及安装包
虚拟机相当于是一个独立于你电脑的环境,在这个环境上面,你可以安装Linux、Windows、Ubuntu等各个类型各个版本的系统,在这个系统里面你不用担心有病读等,不用担心文件误删导致系统崩溃。 虚拟机也和正常的电脑系统是一样的,也可以开关机,不用的时候,你关机就可以了,也不会占用你的系统资源,使用起来还是比较方便 这里也有已经做好的CentOS 7系统,下载下来解压后直接用VMware打开就可以使用
362 69
|
1月前
|
Ubuntu Linux 索引
Centos 7、Debian及Ubuntu系统中安装和验证tree命令的指南。
通过上述步骤,我们可以在CentOS 7、Debian和Ubuntu系统中安装并验证 `tree`命令。在命令行界面中执行安装命令,然后通过版本检查确认安装成功。这保证了在多个平台上 `tree`命令的一致性和可用性,使得用户无论在哪种Linux发行版上都能使用此工具浏览目录结构。
181 78
|
2月前
|
Linux 网络安全 Apache
针对在Centos/Linux安装Apache过程中出现的常见问题集锦
以上每个问题的解决方案应深入分析错误日志、系统消息和各种配置文件,以找到根本原因并加以解决。务必保持系统和Apache软件包更新到最新版本,以修复已知的bugs和安全漏洞。安装和管理Web服务器是一项需要细致关注和不断学习的任务。随着技术的发展,推荐定期查看官方文档和社区论坛,以保持知识的更新。
163 80
|
10天前
|
存储 关系型数据库 MySQL
在CentOS 8.x上安装Percona Xtrabackup工具备份MySQL数据步骤。
以上就是在CentOS8.x上通过Perconaxtabbackup工具对Mysql进行高效率、高可靠性、无锁定影响地实现在线快速全量及增加式数据库资料保存与恢复流程。通过以上流程可以有效地将Mysql相关资料按需求完成定期或不定期地保存与灾难恢复需求。
54 10
|
22天前
|
运维 网络协议 Linux
CentOS下Bind服务的安装与故障排查
通过以上的步骤,您应该能够在CentOS系统上安装并配置BIND DNS服务,并进行基本的故障排查。
140 0
|
2月前
|
人工智能 数据挖掘 Linux
Centos安装Python3.7(亲测可用)
本指南详细介绍了在基于Linux(以CentOS系统为例,使用yum包管理器)的系统上安装Python 3.7版本的完整流程。Python是一种广泛使用的高级编程语言,在各种领域如软件开发、数据分析、人工智能和区块链开发等都有着重要的应用。
204 3
|
3月前
|
机器人 Linux
CentOS 7系统中安装特定版本CMake 3.21.2的方法。
到这里,过程已经全部完成。如果你跟随上面的步骤来,那么你现在已经拥有了一个全新的CMake版本在你的CentOS 7系统上了。这个过程就像是你通过一系列仪式,唤醒了一个沉睡已久的古老机器人,它现在完全按照你的意愿来帮你构建和编译软件了。
179 18
|
2月前
|
物联网 Linux 开发者
快速部署自己私有MQTT-Broker-下载安装到运行不到一分钟,快速简单且易于集成到自己项目中
本文给物联网开发的朋友推荐的是GMQT,让物联网开发者快速拥有合适自己的MQTT-Broker,本文从下载程序到安装部署手把手教大家安装用上私有化MQTT服务器。
682 5
|
3月前
|
安全 Linux
安装EPEL Repository Centos 7.9
记住,行走在Linux的世界,把“学习”作为你不可或缺的随身宝典。今天你学会了如何将EPEL这座外来的宝库接入你的系统,明天,你或许就能在这座宝库中发现一款能领你走向Linux大师之路的神器。
153 5