首页 > 其他分享 >RocketMQ工具的使用方法

RocketMQ工具的使用方法

时间:2025-01-13 10:44:29浏览次数:1  
标签:broker topic rocketmq master 消息 分片 工具 方法 RocketMQ

RocketMQ简介
启动rocketmq-Dashboard项目 输入 http://localhost:8888/#/ 即可到rocketmq界面
学习网页: https://blog.csdn.net/m0_46486963/article/details/124495728

整体横向菜单分为八个部分:

  • OPS(运维):主要是设置nameserver和配置vipchannel
  • Dashboard(驾驶舱):控制台的dashboard,可以分别按broker和主题来查看消息的数量和趋势。
  • Cluster(集群):整个RocketMq的集群情况,包括分片,编号,地址,版本,消息生产和消息消费的TPS等,这个在做性能测试的时候可以作为数据指标。
  • Topic(主题):可以新增/更新topic;也看查看topic的信息,如状态,路由,消费者管理和发送消息等。
  • Consumer(消费者):可以在当前broker中查看/新建消费者group,包括消费者信息和消费进度
  • Producer(生产者):可以在当前broker中查看生产组下的生产者group,包生产者信息和生产者状态
  • Message(消息):可以按照topc,messageID,messageKey分别查询具体的消息
    其中最常用的是集群,主题,消费者和消息这四部分。

    运维这块儿就两个功能:
    1.设置Nameserver
    2.打开/关闭vipchannnel
  • 设置nameserver:可以添加多个nameserver地址到输入框内,默认读取的是DashBoard这个springboot启动配置里面的nameserver配置。如果rockermq集群里有加入新的nameserver节点,可以在这里动态配置后更新生效。
  • 打开/关闭vipchannel: 这里默认为false就好,vipchannnel针对的是topic的优先级,相当于在消息处理的时候,有些topic可以走vipchannel,可以优先被处理,这个除了电商场景用的一般不多。

    驾驶舱消息当前数量和最近的趋势,如图左侧为当前消息总数量,右侧为消息数量趋势。
    我们分别解释如下四张图。
    1)按broker实例为类目(比如说集群中有3个broker实例)展示当前的消息数
    2)按topic为类目(比如说当前所有broker中存在10个topic)展示当前的消息数
    3)指定某天和时间段,查询不同broker实例的消息数的趋势
    4)指定某天和时间段,查询某topic下消息数的趋势
  • 分片:指的是数据分片(或者broker),当前rocketmq集群的只有一个数据分片,id为RaftNode00,即所有数据都在这个分片上;rocketmq的消息数据可以分布在多个数据分片上(一般都是多broker集群),后面搭建集群化环境的时候会讲到。
  • 编号:标识了哪些是master(0是master),哪些是slave,master负责直接读写;slave相当于master的副本,定期从master同步数据,如果master挂掉,slave会自动内部选举一个master节点。
  • 地址:即broker的实际ip端口。
  • 版本:rocketmq的版本
  • 生产消息TPS:即broker中处理消息的TPS(每秒落盘的消息数)。
  • 消费消息TPS:即consumer从broker中收取消息的TPS(每秒接收的消息数) 。
  • 昨日生产总数:昨天落盘的总消息数。
  • 昨日消费总数:昨天消费的总消息数。
  • 今天生产总数:今天落盘的总消息数。
  • 今天消费总数:今天消费的总消息数。

    主题里面有三大类型
  • 普通主题:这里是rocketmq自动创建的一些系统topic,然后用户创建的topic也展示在这里。
  • 重试主题:这里是发送失败时候系统为之创建的topic。
  • 死信主题:这里的topic类似垃圾箱,无法从中生产或者消费消息。

MQ的优点:
1、异步: 提高系统的响应速度、吞吐量
2、解耦: 服务之间解耦,可以减少服务之间的影响,提高系统的稳定性和可扩展性;同时,可以实现数据分发,一个消息可以由1个或者多个消费者进行消费;
3、削峰: 以稳定的系统资源应对突发的流量冲击;
MQ的缺点:
1、降低系统可用性
2、系统复杂性提高
3、数据幂等性问题
MQ产品比较

标签:broker,topic,rocketmq,master,消息,分片,工具,方法,RocketMQ
From: https://www.cnblogs.com/tingtinga/p/18668155

相关文章

  • 【docker】docker desktop换国内源时 apply按钮为灰色or换源失败 解决方法
    配docker环境时复制进去国内镜像源后,发现apply按钮为灰色,点不了,如下图解决方法:往下滑,找到下图圈住的选项打勾再回到DockerEngine界面,发现可以点apply按钮了在文本框中添加"registry-mirrors":["http://mirrors.ustc.edu.cn", "http://mirror.azure.cn"]......
  • Mounriver Studio编译器在当前工程中添加文件夹后编译报错问题的解决方法
    在开发一些例程时,往往需要将自己现有的封装好的函数接口文件夹移植进来,但工程编译后往往会出现报未包含的错误,可按以下步骤处理解决:一、这边做示例,随便打开一个工程,假设在该工程目录下添加了一个MOUSE文件夹, 此时这个MOUSE文件夹并没有包含在这个工程的编译路径中,如果在mai......
  • 数字化工具助力外贸客户粘性提升
    在全球化市场竞争日益激烈的背景下,外贸企业要想在红海中脱颖而出,必须深耕客户体验,提供精细化服务,增强客户粘性。只有以客户为中心,创新服务模式,才能在长期合作中实现双赢。第一部分:客户粘性的价值与挑战1.客户粘性的核心价值客户粘性是企业持续盈利和长期发展的重要保障。粘性......
  • 写一个获取数组的最大值、最小值的方法
    在前端开发中,获取数组的最大值和最小值是一个常见的需求。你可以使用JavaScript的Math.max()和Math.min()函数结合扩展运算符(...)来实现这个功能。以下是一个简单的示例:functiongetMaxAndMin(arr){if(!Array.isArray(arr)||arr.length===0){return{max:null,m......
  • 写一个方法判断字符串是否为回文字符串
    在前端开发中,你可以使用JavaScript来编写一个方法,用于判断字符串是否为回文字符串。回文字符串是指正序和倒序读都一样的字符串。以下是一个简单的JavaScript函数,用于实现这个功能:functionisPalindrome(str){//去除字符串中的空格,并转换为小写,以便不区分大小写和空格......
  • Typora的基本使用方法(快捷键和基础设置)
    (一)基础语法标题使用#号表示不同级别的标题,最多支持六级标题。```一级标题二级标题三级标题四级标题五级标题六级标题段落与换行段落之间需要空行分隔,换行使用两个空格加回车。这是一个段落。这是另一个段落。这是一行这是另一行分割线使用三个或以上的......
  • 说说bind、call、apply的区别?并手写实现一个bind的方法
    bind、call、apply都是JavaScript中改变函数执行上下文的方法,他们的主要区别体现在调用函数时所传递的参数形式上。call:call方法接收一个参数列表,第一个参数将用作函数中的this对象,其余参数将直接作为函数调用时的参数。functiongreet(greeting,name){console.l......
  • AccessData FTK Imager 是一款由 AccessData 公司开发的数字取证工具,用于创建计算机系
    AccessDataFTKImager是一款由AccessData公司开发的数字取证工具,用于创建计算机系统和存储设备的完整数据镜像,并且支持从中提取和分析数据。它是一款非常流行的取证软件,尤其在计算机取证、数据恢复和法律领域应用广泛。FTKImager的主要功能:创建数据镜像:FTKImager可以......
  • 【C++】字符串中的 insert 方法深层分析
    博客主页:[小ᶻ☡꙳ᵃⁱᵍᶜ꙳]本文专栏:C++文章目录......
  • MySQL备份工具mydumper下载(RPM方式)安装以及详细使用教程
    1、mydumper工具介绍        mydumper是一款社区开源的,用于MySQL数据库的高性能多线程备份工具。与传统的mysqldump相比,mydumper提供了更快的备份和恢复速度,特别是在处理大型数据库时。它包含两个主要工具:•mydumper:负责导出一致的MySQL数据库备份。•myl......