Linux系统下消息中间件RocketMQ下载、安装、搭建、配置、控制台rocketmq-dashboard的安装保姆级教程 rocketmq ui

这里给出我使用的 RocketMQ 版本(5.1.3)、RocketMQ-Dashboard 版本的百度网盘链接:
链接:https://pan.baidu.com/s/1HaKBBDGWZ0WKLGgVwIG9pw
提取码:1234

文章目录

  • 一. 官网下载安装
  • 二、启动NameServer
  • 三、启动Broker
  • 四、测试RocketMQ
  • 五、RocketMQ Dashboard控制台

一. 官网下载安装

1、注意:有两种资源下载:Source表示源码、Binary是二进制包(我们下载这个):二进制包是已经编译完成后可以直接运行的,源码包是需要编译后运行的。

官网说明文档、官网下载链接

在这里插入图片描述

2、注意:由于这里是介绍linux系统,所以如果是在 windows 上下载的,需要上传到 linux 中解压(这里linux系统使用的虚拟机):首先利用xshell、xftp软件,将压缩包传进来:

在这里插入图片描述
进入存放的目录后,然后解压:unzip rocketmq-all-5.1.3-bin-release.zip

注意:如果下载的是源码包,需要按照下面进行:
$ unzip rocketmq-all-5.1.3-source-release.zip
$ cd rocketmq-all-5.1.3-source-release/
$ mvn -Prelease-all -DskipTests -Dspotbugs.skip=true clean install -U
$ cd distribution/target/rocketmq-5.1.3/rocketmq-5.1.3

二、启动NameServer

1、安装完 RocketMQ 包后,我们启动 NameServer。进入解压后的目录,然后输入命令:nohup ./bin/mqnamesrv & 或者输入 nohup sh bin/mqnamesrv & ,然后回车,再按一次回车即可:

在这里插入图片描述

2、验证是否启动成功:输入命令测试:tail -f ~/logs/rocketmqlogs/namesrv.log 或者输入:netstat -an | grep 9876 看到端口号

在这里插入图片描述

三、启动Broker

Broker 相当于是 RocketMQ 的一个引擎,它的消息传输、消息消费都要通过 Broker

启动之前需要编辑配置文件,修改该配置文件分配给 JVM 的内存。默认给的内存 4 GB,但我们 JVM 没有这么多,超过了,所以这里修改分配给 JVM 的内存。注意:如果服务器资源足够多可以忽略这一步。

首先进入下面这个目录:

在这里插入图片描述

输入命令:vim runserver.sh

在这里插入图片描述
在这里插入图片描述

还需要修改一个,输入命令:vim runbroker.sh

在这里插入图片描述

1、再开始启动 Broker:进入解压后的 bin 目录(或者解压后的目录),输入:nohup sh bin/mqbroker -n localhost:9876 & 或者输入 nohup ./mqbroker -n localhost:9876 &

在这里插入图片描述
2、测试是否启动成功:在tail -f ~/logs/rocketmqlogs/broker.log

在这里插入图片描述

四、测试RocketMQ

官网给出了测试用例,我们只需要输入命令即可快速测试

1、消息产生者(消息发送):输入命令

cd bin
export NAMESRV_ADDR=localhost:9876
./tools.sh org.apache.rocketmq.example.quickstart.Producer  //消息发送
./tools.sh org.apache.rocketmq.example.quickstart.Consumer  //消息接收

注意:上面消息发送、消息接收命令输入之后,能正常运行、不报错,就说明测试成功。

2、关闭 RocketMQ

cd bin
./mqshutdown broker
./mqshutdown namesrv

五、RocketMQ Dashboard控制台

1、上面都是在 Xshell 中进行的,不方便管理,这里安装一个可视化界面。
2、这个控制台安装方法有新、旧版本之分。
3、新旧版本如何区分: 点击下载链接,下载文件之后,然后根据下图的方法可以查看新旧版本的区别。
在这里插入图片描述

旧版本(针对 rocketmq 5.0 以下版本):

1、下载解压,不用到 linux 中

官网文档说明、官网下载地址

在这里插入图片描述

下载解压后发现就是一个 Spring Boot 工程,我们只需要把这个工程跑起来即可(两种方式:导入IDEA中跑;打成 jar 包后跑,显然后者更方便)

2、打包成 jar 包:先修改配置文件

在这里插入图片描述

server.port=9877 
rocketmq.config.namesrvAddr=虚拟机IP:9876

再进入这个目录,输入命令:mvn clean package -Dmaven.test.skip=true

在这里插入图片描述

注意:第一次以命令行的方式打包需要下载依赖,时间比较久。

出现下面这个就代表打包成功。

在这里插入图片描述

新版本(针对 rocketmq 5.0 以下版本):本人使用的这个

1、下载解压,不用到 linux 中

官网文档说明、Github下载链接

在这里插入图片描述

2、同样修改成配置文件后,输入同样的命令打包:

在这里插入图片描述
在这里插入图片描述

打包完后:

在这里插入图片描述

1、运行 jar 包即可:java -jar rocketmq-dashboard-1.0.1-SNAPSHOT.jar

2、运行起来之后,访问localhost:9877,报错:

在这里插入图片描述

原因:因为我们的 RocketMQ 安装在 Linux 中,控制台在 windows,Linux 需要开放端口才能访问,开放 10909、10911、9876 端口:

在这里插入图片描述

firewall-cmd --zone=public --add-port=10909/tcp --permanent
firewall-cmd --zone=public --add-port=9876/tcp --permanent
firewall-cmd --zone=public --add-port=10911/tcp --permanent
systemctl restart firewalld.service
firewall-cmd --reload

在这里插入图片描述

至此,讲解完毕,记得关注、收藏哦!

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

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

相关文章

Qt项目报错:Cannot run compiler ‘clang++‘. /bin/sh: 1: clang++: not found

在一台旧电脑上装了深度系统,装了Qt,导入项目, build提示 clang找不到: Project ERROR: Cannot run compiler clang. Output: /bin/sh: 1: clang: not found Maybe you forgot to setup the environment? Error while parsing …

Jenkins+Jmeter集成自动化接口测试并通过邮件发送测试报告

一、Jenkins的配置 1、新增一个自由风格的项目 2、构建->选择Excute Windows batch command(因为我是在本地尝试的,因此选择的windows) 3、输入步骤: 1. 由于不能拥有相同的jtl文件,因此在每次构建前都需要删除jtl…

VS2022远程Linux使用cmake开发c++工程配置方法

文章目录 远程连接CMakePresets.json的配置Task.vs.json配置launch.vs.json配置最近使用别人在VS2015上使用visualgdb搭建的linux开发环境,各种不顺手,一会代码不能调转了,一会行号没了,调试的时候断不到正确的位置,取消的断点仍然会进。因此重新摸索了一套使用vs的远程开…

基于Python的高校学生成绩分析系统

随着计算机技术发展,计算机系统的应用已延伸到社会的各个领域,大量基于网络的广泛应用给生活带来了十分的便利。所以把高校成绩分析与现在网络相结合,利用计算机搭建高校成绩分析系统,实现高校成绩分析的信息化。则对于进一步提高…

深入理解 Flutter 图片加载原理 | 京东云技术团队

前言 随着Flutter稳定版本逐步迭代更新,京东APP内部的Flutter业务也日益增多,Flutter开发为我们提供了高效的开发环境、优秀的跨平台适配、丰富的功能组件及动画、接近原生的交互体验,但随之也带来了一些OOM问题,通过线上监控信息…

Dubbo之Wrapper源码解析

功能概述 为了减少反射的调用&#xff0c;Dubbo会为每个服务提供者的实现生成一个Wrapper类&#xff0c;通过Wrapper类去调用真正的接口实现类。 功能分析 核心类Wrapper分析 主要成员变量分析 private static final Map<Class<?>, Wrapper> WRAPPER_MAP ne…

Kotlin的数组

在 Kotlin 中&#xff0c;数组是一种固定大小的有序集合&#xff0c;可以存储相同类型的元素。Kotlin 提供了两种类型的数组&#xff1a;原生数组和数组类。以下是 Kotlin 中数组的详细使用方法&#xff1a; 1.创建数组 Kotlin 支持使用 arrayOf() 函数来创建数组&#xff1a;…

ubuntu 编译安装nginx及安装nginx_upstream_check_module模块

如果有帮助到你&#xff0c;麻烦点个赞呗&#xff5e; 一、下载安装包 # 下载nginx_upstream_check_module模块 wget https://codeload.github.com/yaoweibin/nginx_upstream_check_module/zip/master# 解压 unzip master# 下载nginx 1.21.6 wget https://github.com/nginx/…

【C++奇遇记】构造函数 | 初始化列表

&#x1f3ac; 博客主页&#xff1a;博主链接 &#x1f3a5; 本文由 M malloc 原创&#xff0c;首发于 CSDN&#x1f649; &#x1f384; 学习专栏推荐&#xff1a;LeetCode刷题集 数据库专栏 初阶数据结构 &#x1f3c5; 欢迎点赞 &#x1f44d; 收藏 ⭐留言 &#x1f4dd; 如…

操作系统练习:在Linux上创建进程,及查看进程状态

说明 进程在执行过程中可以创建多个新的进程。创建进程称为“父进程”&#xff0c;新的进程称为“子进程”。每个新的进程可以再创建其他进程&#xff0c;从而形成进程树。 每个进程都有一个唯一的进程标识符&#xff08;process identifier&#xff0c;pid&#xff09;。在L…

树结构转List

使用LinkedList效率更高 1、单个顶级节点 public static List<CmsStudentOutline> getTreeList(CmsStudentOutline root) {List<CmsStudentOutline> list new ArrayList<>();Queue<CmsStudentOutline> queue new LinkedList<>();if (root nu…

【大数据】Hive 表中插入多条数据

Hive 表中插入多条数据 在 Hive 中&#xff0c;我们可以使用 INSERT INTO 语句向表中插入数据。当我们需要插入多条数据时&#xff0c;有多种方式可以实现。本文将介绍如何在 Hive 表中插入多条数据&#xff0c;并提供相应的代码示例。 1.使用单个 INSERT INTO 语句插入多条数…

Java之接口

作者简介&#xff1a; zoro-1&#xff0c;目前大一&#xff0c;正在学习Java&#xff0c;数据结构等 作者主页&#xff1a; zoro-1的主页 欢迎大家点赞 &#x1f44d; 收藏 ⭐ 加关注哦&#xff01;&#x1f496;&#x1f496; Java之接口 接口的概念语法规则接口特性接口使用案…

数据结构<树和二叉树>顺序表存储二叉树实现堆排

✨Blog&#xff1a;&#x1f970;不会敲代码的小张:)&#x1f970; &#x1f251;推荐专栏&#xff1a;C语言&#x1f92a;、Cpp&#x1f636;‍&#x1f32b;️、数据结构初阶&#x1f480; &#x1f4bd;座右铭&#xff1a;“記住&#xff0c;每一天都是一個新的開始&#x1…

Redis的数据持久化

前言 本文主要介绍Redis的三种持久化方式、AOF持久化策略等 什么是持久化 持久化是指将数据在内存中的状态保存到非易失性介质&#xff08;如硬盘、固态硬盘等&#xff09;上的过程。在计算机中&#xff0c;内存中的数据属于易失性数据&#xff0c;一旦断电或重启系统&#…

java实现视频抽帧以及获取其他视频信息

java实现视频抽帧以及获取其他视频信息 1.在pom.xml文件中导入jar包 <dependency><groupId>org.bytedeco</groupId><artifactId>javacv</artifactId><version>1.4.3</version> </dependency><dependency><groupId&…

stable diffusion基础

整合包下载&#xff1a;秋叶大佬 【AI绘画8月最新】Stable Diffusion整合包v4.2发布&#xff01; 参照&#xff1a;基础04】目前全网最贴心的Lora基础知识教程&#xff01; VAE 作用&#xff1a;滤镜微调 VAE下载地址&#xff1a;C站&#xff08;https://civitai.com/models…

漏洞指呗-VluFocus靶场专栏-番外篇

漏洞指呗-VluFocus靶场专栏-番外篇奇技淫巧 &#x1f338;struts2漏洞扫描工具&#x1f338;step1 修改ip和端口step2 验证漏洞是否存在step3 执行cmd命令&#xff0c;获取flag &#x1f338;Goby插件工具headshot&#x1f338;step1 输入ip和端口 检测step2 cmd 输入指令 &…

vactor中迭代器失效问题

目录 什么是迭代器失效导致迭代器失效的操作VS和g环境下对与迭代器失效的态度 什么是迭代器失效 迭代器的底层其实就是一个指针&#xff0c;或者对指针进行了封装 vector的迭代器就是一个指针T* 一个迭代器指向某一个空间&#xff0c;此时这块空间被释放了&#xff0c;这个迭…

【SA8295P 源码分析】35 - QNX侧 Marvell 88Q5152 Phy_Switch 导通实录(硬核)

【SA8295P 源码分析】35 - QNX侧 Marvell 88Q5152 Phy_Switch 导通实录(硬核) 一、硬件原理分析二、88Q5152 芯片读写时序分析2.1 Clause 22 读、写寄存器配置(配置 Port 5 采用C22条款)2.1.1 88Q5152 P5 端口配置2.2 Clause 45 读寄存器时序(配置 Port 1、Port 2 采用C45…