RocketMQ工具的使用方法

news/2025/1/13 10:39:05/文章来源:https://www.cnblogs.com/tingtinga/p/18668155

RocketMQ简介
启动rocketmq-Dashboard项目 输入 http://localhost:8888/#/ 即可到rocketmq界面

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

  • 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类似垃圾箱,无法从中生产或者消费消息。

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

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

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

相关文章

【docker】docker desktop换国内源时 apply按钮为灰色or换源失败 解决方法

配docker环境时复制进去国内镜像源后,发现apply按钮为灰色,点不了,如下图解决方法:往下滑,找到下图圈住的选项打勾再回到Docker Engine界面,发现可以点apply按钮了在文本框中添加"registry-mirrors": ["http://mirrors.ustc.edu.cn","http://mi…

ElasticSearch在Windows环境搭建测试

引子 也持续关注大数据相关内容一段时间,大数据内容很多。想了下还是从目前项目需求侧出发,进行相关学习。Elasticsearch(ES)是位于 Elastic Stack(ELK stack) 核心的分布式搜索和分析引擎。Logstash 和 Beats 有助于收集、聚合和丰富您的数据并将其存储在 Elasticsearch…

科研绘图系列:python语言绘制SCI图合集

介绍 科研绘图系列:python语言绘制SCI图合集 加载python import numpy as np import pandas as pd import matplotlib.pyplot as plt import matplotlib.patches as mpatches import seaborn as snsfrom statsmodels.stats.multitest import multipletests# Setup for local r…

Postman相关

postman打开控制台的快捷键alt+ctrl+c1、工具栏 New: 新建,可以新建Request请求,Collection请求集,环境等等 Import: 导入,可以导入别人导出的请求集 Runner: 运行一个请求集(批量执行) Invite: 邀请(需要注册,邀请进行协作) 同步图标: (需要注册,同步你的项目到云…

TorchOptimizer:基于贝叶斯优化的PyTorch Lightning超参数调优框架

超参数优化是深度学习模型开发过程中的一个核心技术难点。合适的超参数组合能够显著提升模型性能,但优化过程往往需要消耗大量计算资源和时间。本文介绍TorchOptimizer,这是一个基于贝叶斯优化方法的超参数优化框架,专门用于优化PyTorch Lightning模型的超参数配置。TorchOp…

深入理解ASP.NET Core 管道的工作原理

在 .NET Core 中,管道(Pipeline)是处理 HTTP 请求和响应的中间件组件的有序集合。每个中间件组件都可以对请求进行处理,并将其传递给下一个中间件组件,直到请求到达最终的处理程序。管道的概念类似于流水线,每个中间件组件都是流水线中的一个步骤。1. 管道的基本概念 在 …

svn检出has encountered a problem cannot checkout

报错信息:"svn检出has encountered a problem Cannot checkout" 表示 Subversion(SVN)在尝试检出(即下载)版本控制仓库的时候遇到了问题。 解释: 这个错误通常意味着 SVN 客户端无法完成检出操作,可能的原因有多种,包括网络问题、权限问题、URL错误、服务器不…

ABC388

好像已经很久没有写过题解了 C link对于每一个糕点,二分查找大于等于它大小的二倍的糕点的位置(可以用\(lower_{}bound\)函数),从这个位置到\(n\)就是可以和这个糕点配对的糕点。猜猜我是啥 #include<bits/stdc++.h>#define int long longusing namespace std;int n;…

零知识证明二(椭圆曲线配对)

本文章将V神关于椭圆曲线配对的文章进行了翻译。原文在此: https://medium.com/@VitalikButerin/exploring-elliptic-curve-pairings-c73c1864e627 1 简介 椭圆曲线配对是各种构造背后的关键密码原型之一,包括确定性阈值签名、zk-SNARKs和其他更简单形式的零知识证明。椭圆曲…

数字化工具助力外贸客户粘性提升

在全球化市场竞争日益激烈的背景下,外贸企业要想在红海中脱颖而出,必须深耕客户体验,提供精细化服务,增强客户粘性。只有以客户为中心,创新服务模式,才能在长期合作中实现双赢。 第一部分:客户粘性的价值与挑战 1. 客户粘性的核心价值 客户粘性是企业持续盈利和长期发展…

测试项目管理系统 - TPA

面对当今汽车行业高速迭代的研发节奏,测试业务的复杂性和高标准使得传统的手动管理方式面临巨大挑战。汽车测试涵盖多种类型,经纬恒润基于多年测试管理经验,推出了测试项目管理系统INTEWORK-TPA产品,TPA是INTEWORK系列产品中用于汽车电子系统测试项目管理的一整套软件解决方…

k8s volcano + deepspeed多机训练 + RDMA ROCE+ 用户权限安全方案

前提:nvidia、cuda、nvidia-fabricmanager等相关的组件已经在宿主机正确安装,如果没有安装可以参考我之前发的文章GPU A800 A100系列NVIDIA环境和PyTorch2.0基础环境配置【建议收藏】_a800多卡运行环境配置-CSDN博客文章浏览阅读1.1k次,点赞8次,收藏16次。Ant系列GPU支持 N…