Rocketmq专题-01 v5版单机部署篇

2024-03-11 10:52
文章标签 部署 01 rocketmq 专题 单机 v5

本文主要是介绍Rocketmq专题-01 v5版单机部署篇，希望对大家解决编程问题提供一定的参考价值，需要的开发者们随着小编来一起学习吧！

Rocketmq专题

注：

  • 本教程由羞涩梦整理同步发布，本人技术分享站点：blog.hukanfa.com

  • 转发本文请备注原文链接，本文内容整理日期：2024-01-28

  • csdn 博客名称：五维空间-影子，欢迎关注

  • 说明

    • 地址相关：
    # 官网地址
https://rocketmq.apache.org/
# 下载地址
https://rocketmq.apache.org/zh/download
    • 环境相关
    # 要求
64位操作系统，推荐 Linux/Unix/macOS    64位 JDK 1.8+
# jdk请加入全局变量中
$ vim /etc/profile
export JAVA_HOME=/usr/local/jdk1.8.0_77
export PATH=$JAVA_HOME/bin:$PATH
$ source /etc/profile

1 下载

  • 操作步骤

    • 截至目前，5.0及以上的版本如下。建议用5.0.0稳定版本

    image-20231011173059643

    • 本次下载5.0.0版本
    # 地址 ， 选择 Binary 下载
https://dist.apache.org/repos/dist/release/rocketmq/5.0.0/rocketmq-all-5.0.0-bin-release.zip
# 百度网盘
https://pan.baidu.com/s/1kyybjTSeJzZ2bf8js_QZFg?pwd=uxns
    • 将下载好的压缩包上传到服务器并解压
    # 解压
unzip rocketmq-all-5.0.0-bin-release.zip
# 按照需要，放到规划好的目录
mv rocketmq-all-5.0.0-bin-release /usr/local/rocketmq-5.0.0
    • 配置环境变量
    $ vim /etc/profile
export ROCKETMQ_HOME=/usr/local/rocketmq-5.0.0
export PATH=$ROCKETMQ_HOME/bin:$PATH
$ source /etc/profile

2 调整配置

  • 操作步骤

    • 调整namesrv的内存资源
    # 操作路径  /usr/local/rocketmq-5.0.0/bin
$ vim runserver.sh   # 输入Xms搜索 
# 71行，按需修改
JAVA_OPT="${JAVA_OPT} -server -Xms512m -Xmx512m -Xmn256m
# 76行，按需修改
JAVA_OPT="${JAVA_OPT} -server -Xms512m -Xmx512m
    • 调整brocker内存资源
    # 操作路径  /usr/local/rocketmq-5.0.0/bin
$ vim runbroker.sh   # 输入Xms搜索 
# 85行，按需修改
JAVA_OPT="${JAVA_OPT} -server -Xms1g-Xmx2g"
    • 修改broker.conf配置文件，示例路径：/home/hukanfa/rocketmq/conf
    brokerClusterName = DefaultCluster
brokerName = broker-a
brokerIP1=192.168.26.21
brokerIP2=192.168.26.21
namesrvAddr=localhost:9876
brokerId = 0
deleteWhen = 04
fileReservedTime = 48
brokerRole = ASYNC_MASTER
flushDiskType = ASYNC_FLUSH
# 持久化消息存储根路径
storePathRootDir=/home/hukanfa/rocketmq/store
    • 添加 namesrv.properties
    # 路径：conf 目录下
listenPort=9876
    • 修改运行日志文件路径
    # 路径：conf 目录下，默认存在当前用户logs目录下，如果这个logs目录不存在则直接放在当前用户家目录下
sed -i 's#${user.home}#/home/hukanfa/rocketmq#g' logback_broker.xml
sed -i 's#${user.home}#/home/hukanfa/rocketmq#g' logback_controller.xml
sed -i 's#${user.home}#/home/hukanfa/rocketmq#g' logback_namesrv.xml
sed -i 's#${user.home}#/home/hukanfa/rocketmq#g' logback_proxy.xml
sed -i 's#${user.home}#/home/hukanfa/rocketmq#g' logback_tools.xml

3 启动

  • 方式一：操作如下

    • 启动脚本 manager.sh，这个脚本适合集群方式，单机方式请按需调整下
    #/bin/bash
# 参数个数
if [ $# -eq 1 ];theninStr="default"action=$1
elif [ $# -eq 2 ];theninStr=$1action=$2
elseecho "提示01：传入1个参数，只能是 ps ,查看节点管理服务"echo "提示02：传入2个参数，分别为： namesrv/broker-(a/b/c)|-s  start/stop/status"echo "start 启动 | stop 停止 | status 查看服务运行状态 |　ps 查看本节点管理的服务 --> sh manager.sh ps" exit 0
fi
# rocketmq存放路径
mqPath=/data_mq/rocketmq-5.0.0
# 存放服务数组
brokerArry=(default namesrv broker-a broker-a-s broker-b broker-b-s  broker-c  broker-c-s broker)
# 存放动作数组
actionArry=(start stop status ps)
# 存放本节点管理的服务
localSrvArry=(namesrv broker-a broker-b-s)
### 前置判断
# 函数，判断变量是否为指定值
function checkVars(){srcInStr=$1srcAcStr=$2brokerArryLength=${#brokerArry[@]}# 默认为0，匹配到值为1tagOne=0tagTwo=0# 校验服务名称for i in ${brokerArry[@]};doif [ ! "$srcInStr" == "$i" ];thencontinueelsetagOne=1fidone# 校验动作名称for j in ${actionArry[@]};doif [ ! "$srcAcStr" == "$j" ];thencontinueelsetagTwo=1fidone# 判断,如果action为ps则手动赋值为1，即不检查以下项if [ "$action" == "ps" ];thentagOne=1tagTwo=1fi# 统一判断传参匹配if [ $tagOne -eq 0 -a $tagTwo -eq 1 ];thenecho "警告：服务名称非法，请按照下面提示输入"echo "提示：namesrv broker-a broker-a-s broker-b broker-b-s  broker-c  broker-c-s broker"exit 1elif [ $tagOne -eq 1 -a $tagTwo -eq 0 ];thenecho "警告：动作名称非法，请按照下面提示输入"echo "提示：status stop start"echo "提示：如只有1个参数，请输入 ps"exit 1elif [ $tagOne -eq 0 -a $tagTwo -eq 0 ];thenecho "警告：服务及动作名称非法，请按照下面提示输入"echo "提示：namesrv broker-a broker-a-s broker-b broker-b-s  broker-c  broker-c-s broker"echo "提示：status stop start"echo "提示：如只有1个参数，请输入 ps"exit 1fi
}
# 调用函数，验证传参
checkVars $inStr $action
# 函数，判断命令是否执行成功
function checkCmdStatus(){srvStr=$1cmdStr=$2if [ $? -ne 0 ];thenecho "${srvStr}操作${cmdStr}失败"exit 1fi
}
# 函数，按操作执行指令
function runAction(){srvStr=$1# 区别出brokerbrokerNum=`echo $inStr | grep broker | wc -l`case $action in"start")if [ "$srvStr" == "namesrv" -a $brokerNum -eq 0 ];thennohup ${mqPath}/bin/mqnamesrv -c ${mqPath}/conf/namesrv.properties > ${mqPath}/logs/${srvStr}.log 2>&1 &checkCmdStatus $srvStr $actionelif [ $brokerNum -gt 0 ];then# 指定配置文件启动方式nohup ${mqPath}/bin/mqbroker -c ${mqPath}/conf/3m-3s-async/${srvStr}.properties  > ${mqPath}/logs/${srvStr}.log 2>&1 &checkCmdStatus $srvStr $actionelseecho "$srvStr 启动异常,请核查"exit 1fiecho "start success";;"stop")pidNum=`ps -ef | grep $srvStr | grep -v grep | grep java | awk '{print $2}'`kill -9 $pidNumcheckCmdStatus $srvStr $actionecho "stop success";;"status")pidNum=`ps -ef | grep $srvStr | grep -v grep | grep java | awk '{print $2}'`if [ -z $pidNum ];thenecho "${srvStr} 未运行"elseecho "${srvStr} 运行中 $pidNum"fi;;"ps")for s in ${localSrvArry[@]};doecho "sh manager.sh  $s start|stop|status"done;;        *)echo "指令异常"exit 1;;esac
}### 主逻辑
# 执行启停操作
runAction $inStr
    • 启停操作
      # 启动sh manager namesrv startsh manager broker start# 停止sh manager broker stopsh manager namesrv stop# 请按需配置开机自启动

4 测试

  • 操作如下
# 新增topic  --> topicWarning
mqadmin updateTopic -n localhost:9876 -c DefaultCluster -t topicWarning
# 查看某个topic状态
mqadmin topicStatus -n localhost:9876 -t topicWarning
# 查看所有消费组
mqadmin consumerProgress -n localhost:9876
# 查看所有topic
mqadmin topicList -n localhost:9876
# 删除topic
mqadmin deleteTopic -n localhost:9876 -c DefaultCluster -t topicWarning

这篇关于Rocketmq专题-01 v5版单机部署篇的文章就介绍到这儿，希望我们推荐的文章对编程师们有所帮助！


http://www.chinasem.cn/article/797600。

相关文章

UnrealScriptIDE调试环境部署

UnrealScriptIDE调试环境部署

先安装vs2010   再安装VSIsoShell.exe， 下载地址 https://pan.baidu.com/s/10kPNUuDGTbWXbz7Nos-1WA       fd3t   最后安装unside，下载地址 https://archive.codeplex.com/?p=uside  安装中间有一步选择Binary文件夹要选对路径。   安装好以后，启动 UDKDe
阅读更多...
C++入门01

C++入门01

1、.h和.cpp 源文件 (.cpp)源文件是C++程序的实际实现代码文件，其中包含了具体的函数和类的定义、实现以及其他相关的代码。主要特点如下：实现代码: 源文件中包含了函数、类的具体实现代码，用于实现程序的功能。编译单元: 源文件通常是一个编译单元，即单独编译的基本单位。每个源文件都会经过编译器的处理，生成对应的目标文件。包含头文件: 源文件可以通过#include指令引入头文件，以使
阅读更多...
青龙面板部署通用教程，含服务器、路由器、X86等部署方法

青龙面板部署通用教程，含服务器、路由器、X86等部署方法

1. 拉取镜像/更新镜像 docker pull whyour/qinglong:latest 2. 删除镜像 docker rmi whyour/qinglong:latest 3. 启动容器 普通服务器 docker run -dit \-v $PWD/ql/config:/ql/config \-v $PWD/ql/log:/ql/log \-v $PWD/ql/db:
阅读更多...
宝塔面板部署青龙面板教程【简单易上手】

宝塔面板部署青龙面板教程【简单易上手】

首先，你得有一台部署了宝塔面板的服务器（自己用本地电脑也可以）。 宝塔面板部署自行百度一下，很简单，这里就不走流程了，官网版本就可以，无需开心版。 首先，打开宝塔面板的软件商店，找到下图这个软件（Docker管理器）安装，青龙面板还是安装在docker里，这里依赖宝塔面板安装和管理docker。 安装完成后，进入SSH终端管理，输入代码安装青龙面板。ssh可以直接宝塔里操作，也可以安装ssh连接
阅读更多...
手把手教你入门vue+springboot开发（五）--docker部署

手把手教你入门vue+springboot开发（五）--docker部署

文章目录 前言一、前端打包二、后端打包三、docker运行总结 前言 前面我们重点介绍了vue+springboot前后端分离开发的过程，本篇我们结合docker容器来研究一下打包部署过程。 一、前端打包 在VSCode的命令行中输入npm run build可以打包前端代码，出现下图提示表示打包完成。 打包成功后会在前端工程目录生成dist目录，如下图所示： 把
阅读更多...
[Centos7] 部署Zabbix5.0

[Centos7] 部署Zabbix5.0

目录 0 卸载 Zabbix1 准备工作1.1 关闭防火墙1.2 关闭SELinux1.3 重启服务器1.4 安装MySQL 2 配置 Zabbix yum 源2.1 安装zabbix的软件仓库配置包2.2 安装 Software Collections 仓库2.3 修改 Zabbix 仓库配置文件 3 安装 Zabbix3.1 遇到报错Requires: libmysqlclient.so
阅读更多...
407串口01发送

407串口01发送

实验一： 工程。 链接：https://pan.baidu.com/s/1g8DV4yZWOix0BbcZ08LYDQ?pwd=2176 提取码：2176 串口1的使用。发送功能。 单片机发送信息到电脑。 通过串口进行通信。 首先单片机这边。 单片机这边，需要对单片机的串口模块进行使能初始化，设置串口的格式。 单片机和电脑的串口收发格式要配置一致。不然A和B肯定通信不成功，鸡和鸭讲，
阅读更多...
[分布式网络通讯框架]----ZooKeeper下载以及Linux环境下安装与单机模式部署（附带每一步截图）

[分布式网络通讯框架]----ZooKeeper下载以及Linux环境下安装与单机模式部署（附带每一步截图）

首先进入apache官网 点击中间的see all Projects->Project List菜单项进入页面 找到zookeeper，进入 在Zookeeper主页的顶部点击菜单Project->Releases，进入Zookeeper发布版本信息页面，如下图： 找到需要下载的版本 进行下载既可，这里我已经下载过3.4.10，所以以下使用3.4.10进行演示其他的步骤。
阅读更多...
springboot学习02-[热部署和日志]

springboot学习02-[热部署和日志]

热部署和日志 热部署 热部署
阅读更多...
solr单机环境的搭架（1）

solr单机环境的搭架（1）

一配置solr环境 1.下载solr 2.配置solr(最好单独分离出一个tomcat，一台机器启动多个tomcat参见：http://www.cnblogs.com/lxlwellaccessful/p/6746341.html) 　　a.在下载的solr文件夹下的\example\solr\下将文件全部考到一个文件夹中（本人是放在E:\MySoft\solr\home中的）
阅读更多...

Copyright China编程 23002807@qq.com

沪ICP备2023033072号-2