在Linux中进行rocketmq及rocketmq控制台安装与配置

news2025/7/9 9:14:34

rocketmq下载安装的版本:rocketmq-rocketmq-all-5.0.0.tar.gz

rocketmq控制台下载安装的版本:rocketmq-externals-rocketmq-console-1.0.0.tar.gz

rocketmq安装

第一步,下载server-jre-8u202-linux-x64.tar.gz安装包。

登录网址:https://www.oracle.com/java/technologies/javase/javase8-archive-downloads.html下载server-jre-8u202-linux-x64.tar.gz安装包,然后使用WinSCP将安装包上传到/usr/local/src文件夹中。也可以使用wget命令下载。

命令:cd /usr/local/src

wget https://www.oracle.com/java/technologies/javase/javase8-archive-downloads.html/jre-8u202-linux-x64.tar.gz

第二步,解压server-jre-8u202-linux-x64.tar.gz安装包。

命令:cd /usr/local/src

tar -zxvf server-jre-8u202-linux-x64.tar.gz -C /usr/local

第三步,配置环境变量。

配置/etc/profile文件,在文件添加下面的代码:

export JAVA_HOME=/usr/local/jdk1.8.0_202

export JRE_HOME=$JAVA_HOME/jre

export CLASSPATH=.:$JAVA_HOME/lib/dt.jar:$JAVA_HOME/lib/tools.jar:$JAVA_HOME/lib:$JRE_HOME/lib/rt.jar:$JRE_HOME/lib/ext:$JRE_HOME/lib:$CLASSPATH

export PATH=$JAVA_HOME/bin:$JRE_HOME/bin:$PATH

第四步,测试server-jre是否配置成功。

# 刷新profile文件

命令:source /etc/profile

# 查看jdk版本

命令:java -version

若结果显示server-jre的版本,则说明server-jre配置成功。

第五步,下载5.0.0版本的rocketmq

登录网址:https://github.com/apache/rocketmq/releases下载rocketmq-rocketmq-all-5.0.0.tar.gz安装包,然后使用WinSCP将rocketmq安装包上传到/usr/local/src文件夹。

第六步,解压rocketmq安装包。

命令:cd /usr/local/src

tar -zxvf rocketmq-rocketmq-all-5.0.0.tar.gz -C /usr/local

# 修改目录名

命令:cd /usr/local

mv rocketmq-rocketmq-all-5.0.0 rocketmq-5.0.0

第七步,安装maven。

# 下载maven安装包

命令:cd /usr/local/src

wget https://mirrors.tuna.tsinghua.edu.cn/apache/maven/maven-3/3.6.3/binaries/apache-maven-3.6.3-bin.tar.gz

# 解压maven安装包

命令:tar -zxvf apache-maven-3.6.3-bin.tar.gz

第八步,配置maven。

配置/usr/local/src/apache-maven-3.6.3/conf/setting.xml文件,文件修改完成后显示如下:

   <mirror>

        <id>alimaven</id>

        <mirrorOf>central</mirrorOf>

        <name>aliyun maven</name>

        <url>http://maven.aliyun.com/nexus/content/groups/public</url>

   </mirror>

</mirrors>

第九步,配置环境变量。

配置文件/etc/profile,在文件最下面添加下面的代码:

export MAVEN_HOME=/usr/local/src/apache-maven-3.6.3

export PATH=${PATH}:${MAVEN_HOME}/bin

# 刷新profile文件

命令:source /etc/profile

第十步,验证maven。

命令:mvn -v

若结果显示“Apache Maven 3.6.3”,则maven配置成功。

第十一步,编译rocketmq。

命令:cd /usr/local/rocketmq-5.0.0

mvn -Prelease-all -DskipTests clean install -U

若结果最后显示“BUILD SUCCESS”,则说明rocketmq编译成功。

第十二步,将编译成功后生成的目录移动到/usr/local/rocketmq文件夹中。

命令:cd /usr/local/rocketmq-5.0.0/distribution

mv target/rocketmq-5.0.0 /usr/local/rocketmq

rocketmq配置

第一步,在rocketmq安装目录创建存放数据和日志的目录。

命令:cd /usr/local/rocketmq/rocketmq-5.0.0

mkdir -p logs store store/commitlog store/consumequeue

第二步,在rocketmq安装目录中编辑/conf/broker.conf文件。

在/conf/broker.conf文件中添加下面的代码:

listenPort=10911

namesrvAddr=x.x.x.x:9876

storePathRootDir=/usr/local/rocketmq/rocketmq-5.0.0/store

storePathCommitLog=/usr/local/rocketmq/rocketmq-5.0.0/store/commitlog

storePathConsumerQueue=/usr/local/rocketmq/rocketmq-5.0.0/store/consumequeue

第三步,修改内存大小。

若服务器内存足够,则可以跳过这步,不用修改内存大小。

在rocketmq安装目录中编辑/bin/runbroker.sh文件,将“JAVA_OPT="${JAVA_OPT} -server -Xms8g -Xmx8g"”修改为“JAVA_OPT="${JAVA_OPT} -server -Xms1g -Xmx1g"”。

在rocketmq安装目录中编辑/bin/runserver.sh文件,将“JAVA_OPT="${JAVA_OPT} -server -Xms4g -Xmx4g -Xmn2g”修改为“JAVA_OPT="${JAVA_OPT} -server -Xms1g -Xmx1g -Xmn1g”。

在rocketmq安装目录中编辑/bin/tools.sh文件,将“JAVA_OPT="${JAVA_OPT} -server -Xms4g -Xmx4g -Xmn256m”修改为“JAVA_OPT="${JAVA_OPT} -server -Xms1g -Xmx1g -Xmn1g”。

第四步,配置/etc/profile文件。

配置/etc/profile文件,在文件添加下面的代码:

export ROCKETMQ_HOME=/usr/local/rocketmq/rocketmq-5.0.0

export PATH=$PATH:$ROCKETMQ_HOME/bin:$PATH

# 刷新profile文件

命令:source /etc/profile

第五步,开放防火墙9876和10911端口。

命令:firewall-cmd --zone=public --add-port=9876/tcp --permanent

firewall-cmd --zone=public --add-port=10911/tcp --permanent

# 更新防火墙规则

命令:firewall-cmd --reload

# 查看防火墙所有开放的端口

命令:firewall-cmd --list-port

第六步,启动rocketmq服务。

# 启动nameserver

命令:cd /usr/local/rocketmq/rocketmq-5.0.0

nohup sh bin/mqnamesrv > logs/mqnamesrv.log 2>&1 &

ps -ef | grep mqnamesrv

# 启动broker

命令:nohup sh bin/mqbroker -n x.x.x.x:9876 > logs/broker.log 2>&1 &

ps -ef | grep mqbroker

# 检查服务是否成功启动

命令:jps

第七步,测试rocketmq。

# 配置服务地址

命令:export NAMESRV_ADDR=x.x.x.x:9876

# 发送示例模板

命令:cd /usr/local/rocketmq/rocketmq-5.0.0

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

若结果最后显示两个“true”,则说明发送模板成功。

 

# 接收示例消息

命令:sh bin/tools.sh org.apache.rocketmq.example.quickstart.Consumer

若结果最后显示下图的内容,则说明接收消息成功。

 

第八步,关闭rocketmq服务。

# 关闭broker

命令:cd /usr/local/rocketmq/rocketmq-5.0.0

sh bin/mqshutdown broker

# 关闭nameserver

命令:sh bin/mqshutdown namesrv

rocketmq控制台安装

第一步,下载安装rocketmq控制台。

登录网址:

https://github.com/apache/rocketmq-externals/tags

下载rocketmq-externals-rocketmq-console-1.0.0.tar.gz安装包,然后将rocketmq控制台安装包上传到/usr/local/src文件夹。

第二步,解压rocketmq控制台安装包。

命令:cd /usr/local/src

tar -zxvf rocketmq-externals-rocketmq-console-1.0.0.tar.gz -C /usr/local/rocketmq

第三步,编译rocketmq控制台。

命令:cd /usr/local/rocketmq/rocketmq-externals-rocketmq-console-1.0.0/rocketmq-console

mvn clean package -Dmaven.test.skip=true

若结果最后显示“BUILD SUCCESS”,则说明rocketmq控制台编译成功。

 

rocketmq控制台配置

第一步,在文件夹/usr/local/rocketmq下新建console文件夹。

命令:mkdir -p /usr/local/rocketmq/console

第二步,将编译rocketmq控制台得到的jar包移动到新建的console文件夹。

命令:cd /usr/local/rocketmq/rocketmq-externals-rocketmq-console-1.0.0/rocketmq-console/target

mv rocketmq-console-ng-1.0.0.jar /usr/local/rocketmq/console

第三步,启动jar包。

命令:cd /usr/local/rocketmq/console

java -jar rocketmq-console-ng-1.0.0.jar --server.port=8080 --rocketmq.config.namesrvAddr=x.x.x.x:9876

第四步,访问页面。

登录网址:http://x.x.x.x.:8080/#/访问,就可以看到下图的页面,右上角可以切换中文。

 

注意:如果使用阿里云ECS服务器,那么至少需要开放9876和8888两个端口的访问。

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.coloradmin.cn/o/369464.html

如若内容造成侵权/违法违规/事实不符,请联系多彩编程网进行投诉反馈,一经查实,立即删除!

相关文章

UVa 1604 Cubic Eight-Puzzle 立体八数码问题 双向BFS 状态设定

题目链接&#xff1a;Cubic Eight-Puzzle 题目描述&#xff1a; 给定一个初始状态和一个终止状态的3∗33*33∗3网格&#xff0c;网格中含有888个立方体和一个空白&#xff0c;每个立方体的颜色如下&#xff1a; 需要注意的是&#xff1a;只会给出终止状态的立方体的顶面朝向&a…

Android init 进程流程分析 一

init 进程流程分析 一1.1引入init进程1.2 init 进程入口函数参考博客预告下一章 FirstStageMain()分析1.1引入init进程 1.启动电源以及系统启动&#xff1a; 上电引导芯片从预定义的地放&#xff08;固化在ROM)开始执行&#xff0c;加载引导程序Bootloader 到RAM中&#xff0c…

格雷码的实现

格雷码&#xff1a;任意两个相邻的二进制数之间只有一位不同 想必通信专业的学生应该都接触过格雷码&#xff0c;它出现在数电、通信原理等课程里。 如下图所示一个四位格雷码是什么样子的&#xff1a; 格雷码的特点&#xff1a; 其最大的特点是任意上下相邻的两个码值间&am…

css学习-----web

引入方式 内嵌式 css写在style标签中 外链式 css写在一个单独的.css文件中 <link rel"stylesheet" href"./文件名.css">stylesheet关系为样式表&#xff1b; href地址 行內式 css写在标签的style属性中 可以配合js使用 选择器 标签选择器是选…

CTFer成长之路之XSS的魔力

XSS的魔力CTF XSS闯关 题目描述: 你能否过关斩将解决所有XSS问题最终获得flag呢&#xff1f; docker-compose.yml version: "3.2"services:xss:image: registry.cn-hangzhou.aliyuncs.com/n1book/web-xss:latestports:- 3000:3000启动方式 docker-compose up -…

Spring依赖注入(四):Bean的循环依赖是如何产生和解决的?

前言其实这篇文章才是正主&#xff0c;前面几篇文章&#xff1a;Spring依赖注入&#xff08;一&#xff09;&#xff1a;字段注入的方式是如何工作的&#xff1f;Sprng依赖注入&#xff08;二&#xff09;&#xff1a;setter注入是如何工作的&#xff1f;Sprng依赖注入&#xf…

easyExcel与poi版本不兼容导致的后台报错问题

1、背景&#xff1a;最新接手公司系统excel导入解析模块&#xff0c;点击批量导入&#xff0c;后台报错如下 com.alibaba.excel.exception.ExcelAnalysisException: java.lang.NoClassDefFoundError: org/apache/poi/poifs/filesystem/FileMagicat com.alibaba.excel.analysis.…

CycleGAN代码使用入门

以下内容为本人亲测使用过程&#xff0c;完成了橘子到苹果的AI转化效果&#xff0c;先上效果&#xff1a; 1、下载数据集 Index of /cyclegan/datasets 本次做的是苹果和橘子相互转化的实验&#xff0c;所以下载apple2orange.zip数据集 2、下载代码 github地址为&#xff1a;…

ChatGPT从下游应用“火”到了上游芯片厂,国内谁将受益?

因库存陷入低迷周期的半导体市场近日因ChatGPT的火热而重新受到外界关注。 原文链接&#xff1a;ChatGPT从下游应用“火”到了上游芯片厂&#xff0c;国内谁将受益&#xff1f; 由于ChatGPT属于生成式AI&#xff0c;被誉为“AI芯片”第一股的英伟达应声而涨。2月13日收盘&#…

Go高质量编程与性能调优-学习笔记

1 高质量编程 1.1 简介 1.1.1 高质量代码 高质量代码即正确可靠、简洁清晰的代码 1.1.2 编程原则 简单性可读性生产力1.2 编码规范 1.2.1 代码格式 推荐gofmt自动格式化代码&#xff01; 推荐goimports实现gofmt依赖包管理&#xff01; 1.2.2 注释 注释要解释代码作用、…

5个设计师常用素材库

推荐5个设计素材网站&#xff0c;免费下载&#xff01; 1、菜鸟图库 菜鸟图库-免费设计素材下载 菜鸟图库是一个素材量非常丰富的网站&#xff0c;该网站聚合了平面、UI、淘宝电商、高清背景图、图片、插画等高质量素材。平面设计模板非常多&#xff0c;很多都能免费下载&…

springmvc实现controller接口

springmvc实现controller接口 前置配置 基础环境 springmvc 环境 jdk1.8 tomcat8.5 集成环境 ideasmart-tomcat (idea 中 tomcat插件) 实现controller接口 import org.springframework.web.servlet.ModelAndView; import org.springframework.web.servlet.mvc.Control…

UNIAPP实战项目笔记59 NodeJS后端生成token 和 修复一些bug

UNIAPP实战项目笔记59 NodeJS后端生成token 和 修复一些bug 后端保持数据时往数据库写入token 修复一些前面遗留的问题bug 实际案例图片 后端接口文件 index.js var express require(express); var router express.Router(); var connection require(../db/sql.js); var us…

11、STM32通用定时器输出PWM

目录 1.通用定时器输出PWM 2.PWM的工作原理 3.PWM的内部运作机制 4.PWM的模式 41.边沿对齐模式 5.自动加载的预加载寄存器 6.定时器输出PWM结构体讲解 7.定时器输出PWM库函数讲解 8.定时器输出PWM----实战驱动SG90舵机 1.通用定时器输出PWM 以TIM3为例&#xff0c;STM…

makdown模版参考

这里写自定义目录标题欢迎使用Markdown编辑器新的改变功能快捷键合理的创建标题&#xff0c;有助于目录的生成如何改变文本的样式插入链接与图片如何插入一段漂亮的代码片生成一个适合你的列表创建一个表格设定内容居中、居左、居右SmartyPants创建一个自定义列表如何创建一个注…

一次性打包学透 Spring

不知从何时开始&#xff0c;Spring 这个词开始频繁地出现在 Java 服务端开发者的日常工作中&#xff0c;很多 Java 开发者从工作的第一天开始就在使用 Spring Framework&#xff0c;甚至有人调侃“不会 Spring 都不好意思自称是个 Java 开发者”。 之所以出现这种局面&#xf…

危害肠道健康的两大敌人:诺如病毒和轮状病毒

谷禾健康 // 近日&#xff0c;多地发生诺如病毒感染事件&#xff0c;诺如病毒引起的急性感染性腹泻进入发病高峰期。那么什么是诺如病毒&#xff1f;我们又该如何预防&#xff1f; 诺如病毒和轮状病毒都是传染性很强的肠道病毒&#xff0c;是导致急性胃肠炎的最重要原因之一。会…

如何自己搭建一个ai画图系统? 从0开始云服务器部署novelai

如何自己搭建一个ai画图系统&#xff1f; 从0开始云服务器部署novelai ​ 上面两张图都是通过ai生成的&#xff0c;是不是有以假乱真的感觉。 本教程提供的是自己搭建一个可以外网访问的ai系统的方法&#xff0c;需要采购gpu服务器&#xff08;后续会出白嫖的方式&#xff09;&…

Java俄罗斯方块游戏

技术&#xff1a;Java等摘要&#xff1a;俄罗斯方块是一款十分经典的游戏&#xff0c;它的主要运行规律为对系统随机产生的图形进行上下左右移动、旋转等操纵&#xff0c;使之排列成完整的一行或多行并且消除得分。它上手容易&#xff0c;难度循序渐进&#xff0c;老少皆宜&…

Android 架构 MVC MVP MVVM,这一波你应该了然于心

MVC&#xff0c;MVP和MVVM是软件比较常用的三种软件架构&#xff0c;这三种架构的目的都是分离&#xff0c;避免将过多的逻辑全部堆积在一个类中。在Android中&#xff0c;Activity中既有UI的相关处理逻辑&#xff0c;又有数据获取逻辑&#xff0c;从而导致Activity逻辑复杂不单…