栏目分类:
子分类:
返回
名师互学网用户登录
快速导航关闭
当前搜索
当前分类
子分类
实用工具
热门搜索
名师互学网 > IT > 系统运维 > 运维 > Linux

centos7.x搭建rocketmq-4.9.3单机环境

Linux 更新时间: 发布时间: IT归档 最新发布 模块sitemap 名妆网 法律咨询 聚返吧 英语巴士网 伯小乐 网商动力

centos7.x搭建rocketmq-4.9.3单机环境

一、下载rocketmq,本文案例采用的是最新稳定版本rocketmq-all-4.9.3-bin-release,以下是下载路径

Downloading the Apache RocketMQ Releases - Apache RocketMQ

 

二、准备一台虚拟机安装centos7系统

192.168.164.128 hadoop03

三、创建用户
 useradd hxroot
 passwd 密码根据自己的情况进行设置
 

四、关闭防火墙

为避免后续环境出现不必要的踩坑,需要先关闭防火墙。

关闭命令:

systemctl stop firewalld.service

使用命令查看防火墙是否关闭

firewall-cmd --state

 如图表示关闭成功

五、安装jdk

sudo root切换账户,创建目录app,如图

使用如下命令在home目录下新建tools目录,

mkdir /tools

cd到tools目录使用下面的命令解压jdk安装包

tar -zxvf jdk-8u171-linux-x64.tar.gz

同样的方式在根目录下面创建 app目录

 给hxroot用户分配app目录操作权限

chown hxroot:你设置的账户密码  /app

 接下来把解压的jdk移动到app目录下并命名新的目录名称

mv jdk1.8.0_171/ /app/jdk1.8

使用cd命令返回到home目录下

编辑./bash_profile文件

vim ~/.bash_profile 

配置JAVA_HOME环境,此jdk路径根据自己安装的具体目录进行修改 

  

 :wq! 保存退出

再执行以下命令使配置文件中的新配置生效 

source ~/.bash_profile

踩坑 

如果配置环境的时候出现下图中的情况,有空格,那么保存文件后及时执行生效命令,jdk的环境也是不生效的,应该去掉空格后再执行source ~/.bash_profile 命令

 

六、安装rocketmq

上传rocketmq安装包,我这里选用的是 rocketmq-all-4.9.3-bin-release版本

,使用Xshell7工具提供的文件上传工具 xftp7工具上传rocketmq-all-4.9.3-bin-release.zip文件到tools目录下。

解压rocketmq安装包,使用命令

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

出现如下输出表示正常解压中 

再次使用命令

vim ~/.bash_profile

在文件中添加rocketmq的环境配置,如图: 

执行 :wq 保存并退出

使用如下命令使配置文件配置立即生效

source ~/.bash_profile

5.1、先启动nameServer

由于rocketmq默认jvm内存使4g,如果你的机器配置足够可以按要求设计对于虚拟机内存,对于我的机器过大,所以需要制定内存大小,具体步骤如下:

进入bin目录编辑

vim bin/runserver.sh

默认设置

 

修改后

JAVA_OPT="${JAVA_OPT} -server -Xms512m -Xmx512m -Xmn256m -
XX:MetaspaceSize=128m -XX:MaxMetaspaceSize=320m"

 启动namesrv

nohup ./mqnamesrv &

踩坑:找不到自己的主机名对应的ip地址

解决:ERROR RocketmqCommon-Failed to obtain the host name_爱编码阿信的博客-CSDN博客搭建rocketmq单机环境时踩坑,找不到自己的主机名对应的ip地址https://blog.csdn.net/he_xin2009/article/details/124311587?spm=1001.2014.3001.5502

如果输出上图信息表示namesrv启动成功

可以使用jps命令进行验证

5.2、启动broker

同样的启动broker需要定制内存大小,如果你的机器配置足够可以按要求设计对于虚拟机内存,因为本机配置达不到默认要求的8g,因此调整为

vim runbroker.sh

 

Wq!保存退出

启动broker

正确启动方式

方法一:命令中使用autoCreateTopicEnable=true

nohup ./mqbroker -n localhost:9876 autoCreateTopicEnable=true &

方法二、配置broker.conf文件

如果需要测试环境,那么需要进入rocketmq/conf目录,如:

vim broker.conf

在文件末尾加入

autoCreateTopicEnable=true 

:wq!保存退出

再编辑./bash_profile文件,在文件中添加

export NAMESRV_ADDR=localhost:9876

 :wq! 保存并退出

使用source ~/.bash_profile使文件立即生效

执行命令

nohup ./mqbroker -n localhost:9876 &

启动broker踩坑 

解决:org.apache.rocketmq.client.exception.MQClientException: No route info of this topic, TopicTest_爱编码阿信的博客-CSDN博客rocketmq环境搭建踩坑、No route info of this topic, TopicTesthttps://blog.csdn.net/he_xin2009/article/details/124311150?spm=1001.2014.3001.5502

两种方案中看到图中圈出的信息表示启动成功

 使用jps命令进行验证

六、测试 

cd进入rocketmq的bin目录下,执行如下命令

./tools.sh org.apache.rocketmq.example.quickstart.Producer

如果启动测试案例成功会发送1000条消息

至此,rocketmq单机环境搭建完成。有不足之处欢迎大家评论区讨论 

转载请注明:文章转载自 www.mshxw.com
本文地址:https://www.mshxw.com/it/825598.html
我们一直用心在做
关于我们 文章归档 网站地图 联系我们

版权所有 (c)2021-2022 MSHXW.COM

ICP备案号:晋ICP备2021003244-6号