RocketMQ-六大场景实操指南

news2024/9/28 20:39:03

RocketMQ-六大场景实操指南

  • 普通消息
    • 创建Topic
    • 创建Group
    • 测试消息收发
  • 定时消息
    • 创建Topic
    • 创建Group
    • 消息发送
  • 事务消息
    • 创建Topic
    • 创建Group
    • 消息收发
  • 顺序消息
    • 创建Topic
    • 创建Group
    • 消息收发
  • 另外两大场景
  • 消息异常运维
  • 体验感受
    • 初次体验
    • 给小白新手的建议
    • 进阶体验
    • 应用场景

关于云消息队列 RocketMQ 版的基本概念及相关基本概念我们可以直接查阅官方文档即可,概念比较容易理解,这里就不再多说了,官方文档地址:产品概述,下面我们就直接开始上手操作吧。

普通消息

打开云消息队列RocketMQ控制台:https://ons.console.aliyun.com/overview ,开通免费试用及创建实例的操作比较简单,这里不作为重点展示,下面我们开始创建普通消息。

创建Topic

点击控制台【实例列表】-【实例名称】进入实例详情页
在这里插入图片描述
点击【Topic管理】-【创建Topic】,输入 名称、描述,选择【普通消息】
在这里插入图片描述
点击【确定】完成Topic的创建。

创建Group

点击【Group管理】-【创建Group】打开创建Group页面,输入 Group ID、描述,选择【并发投递】
在这里插入图片描述
点击【确定】完成Group的创建。

测试消息收发

实例代码可以参考官方文档:
编写消息生产者和消费者demo代码,这里我是在实验室环境下操作demo代码,消费者命令

java -cp demo.jar -Dendpoints=rmq-cn-wwo3b8d7m0u-vpc.cn-hangzhou.rmq.aliyuncs.com:8080 -Dtopic=topic01 -Dgroup=group01  workshop.ConsumeMessageDemo

生产者命令

java -cp demo.jar -Dendpoints=rmq-cn-wwo3b8d7m0u-vpc.cn-hangzhou.rmq.aliyuncs.com:8080 -Dtopic=topic01 -Dnum=10  workshop.ProduceMessageDemo

收发消息的截图
在这里插入图片描述
在这里插入图片描述
到这里,云消息队列RocketMQ的普通消息的操作就完成了,是不是很简单很容易理解呢?

定时消息

打开RocketMQ控制台:https://ons.console.aliyun.com/overview 开始定时消息的操作

创建Topic

点击【实例名称】进入实例详情,点击【Topic管理】-【创建Topic】
在这里插入图片描述
输入 名称、描述,选择【定时/延时消息】的消息类型,点击【确定】完成Topic创建。

创建Group

输入Group ID、描述,选择【并发投递】
在这里插入图片描述
点击【确定】完成Group的创建。

消息发送

输入已经准备好的定时消息发送demo代码的命令

java -cp demo.jar -Dendpoints=rmq-cn-lbj3b8e5y0n-vpc.cn-hangzhou.rmq.aliyuncs.com:8080  -Dtopic=Topic02 -Dgroup=Group02 -DdelaySecond=10 -Dnum=10 workshop.DelayMessageDemo

消息发送截图
在这里插入图片描述
可以看到消息延时了10秒发送。

事务消息

事务消息的发送操作和上面普通消息、定时消息发送的操作流程基本一致,

创建Topic

点击【实例名称】-【Topic管理】-【创建Topic】打开创建Topic页面
在这里插入图片描述
输入 名称、描述,选择【事务消息】,点击【确定】完成Topic的创建。

创建Group

如图输入Group ID、描述,创建Group
在这里插入图片描述

消息收发

回到【Topic管理】,选择topic03列表右边的【更多】
在这里插入图片描述
点击【消息一键收发体验】
在这里插入图片描述
点击【发送事务消息】
在这里插入图片描述
输入消息内容,点击【运行】,可以通过点击右侧tab 【运行结果】来查看消息收发情况。

顺序消息

点击实例列表 RocketMQ实例名称进入实例详情页,

创建Topic

点击【Topic管理】-【创建Topic】输入Topic名称、描述,选择消息类型为【顺序消息】
在这里插入图片描述

创建Group

点击【Group管理】-【创建Group】,输入Group ID、描述,选择消息类型为【顺序消息】
在这里插入图片描述
创建完成后回到Topic管理

消息收发

回到Topic管理,选择刚才创建的topic04,点击【更多】-【消息一键收发体验】
在这里插入图片描述
选择【发送顺序消息】
在这里插入图片描述
在打开的页面输入消息组group04,消息内容 hello,点击【运行】,通过【运行结果】查看消息发送情况
在这里插入图片描述

另外两大场景

另外两大场景,消息堆积场景和消息失败重投场景的Topic和Group相关操作和普通消息的操作是一样的,只是在【Topic管理】-【更多】-【消息一键收发体验】后的选择不同
在这里插入图片描述
下面我们来体验一下消息异常运维排查场景

消息异常运维

消息异常运维,创建Topic和Group的方法参考普通消息的创建流程即可,创建完成之后在体验场景下云服务器ECS输入

java -cp demo.jar -Dendpoints=rmq-cn-lbj3b9ujx0s-vpc.cn-hangzhou.rmq.aliyuncs.com:8080  -Dtopic=topic05 -Dgroup=group05   workshop.ConsumeLagDemo

我们可以看到模板代码输出结果图
在这里插入图片描述
回到RocketMQ实例详情页面,点击【消息轨迹】,输入Message Key 查询消息发送记录
在这里插入图片描述
点击【消息轨迹】进入消息轨迹页面
在这里插入图片描述
可以看到【生产者】、【消费者】的信息以及消费的消息数据,点击【消费者】的group05可以看到消息的轨迹记录
在这里插入图片描述
到这里关于云消息队列 RocketMQ 版 的6大场景以及消息异常运维的操作的相关内容就全部操作完成了。

体验感受

初次体验

初次体验云消息队列RocketMQ版的6大场景,对于小白新手来说在操作上可以说也没有太大的难度,6大场景在创建Topic和Group的操作上基本一致,这就可以省去很多新手学习的成本,很不错。另外官方文档也提供了新手
,方便小白新手快速掌握RocketMQ的基础操作。

给小白新手的建议

通过对云消息队列RocketMQ 6 大场景的体验,对于小白新手我想说的是,不要因为RocketMQ对于你们来说是一款新产品就觉得会投入较多的学习成本,耽误时间;同样也不要因为你在日常工作中可能用到消息队列的地方不多而放弃这次体验RocketMQ的机会;可以说云消息队列RocketMQ对于6大场景的体验,不但提供了官方的视频操作步骤:
,也同样提供了实验室场景来供你体验,最重要的是这款产品本身设计的很容易上手,操作难度可以说是儿童级,完全没有浪费时间的可能,欢迎大家一起来学习交流吧。

进阶体验

在场景体验中,用到了相关发送消息的demo代码,根据个人接入阿里系钉钉API SDKdemo代码的经验,阿里系产品的SDK往往都封装好并且提供了demo代码,代码的注释往往也很详尽,正如官方文档提供的生产消息代码一样
在这里插入图片描述
只要你需要,接入本地项目可以直接将demo代码复制到你的项目中去,引入对应的maven配置就可以了。如果想要参考更多示例代码,也可以参考官方文档:

应用场景

云消息队列RocketMQ不同场景消息类型有不同的应用场景,结合公司业务来看,随着公司业务的不断庞大,系统的不断细化,系统之间数据一致性的要求就变得难以实现,那么如何保证跨系统数据一致性呢?云消息队列RocketMQ的事务消息就可以支持在分布式场景下保障消息生产和本地事务的最终一致性,那么对于这一点,无疑为保证公司业务系统数据一致性,或者说保证分布式系统数据一致性提供了保障,这就是可以为公司带来的价值,更多的RocketMQ事务消息内容的介绍及功能原理可以参考文档:事务消息。
对于RocketMQ事务消息,解决了传统XA事务方案的性能不足问题,同时也解决了另外一种分布式事务保障方案-基于普通消息方案的一致性保障困难问题。通过云消息队列 RocketMQ 版实现的分布式事务消息功能,在普通消息基础上,支持二阶段的提交能,将二阶段提交和本地事务绑定,实现全局提交结果的一致性,实现事务的最终一致性,在性能上优于传统事务保障方案,同时具备可拓展,业务开发简单的优势。目前个人使用过程中还未有待改进的地方,后续如果有的话会再提出的。

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

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

相关文章

Excel第28享:如何新建一个Excel表格

一、背景需求 小姑电话说:要新建一个表格,并实现将几个单元格进行合并的需求。 二、解决方案 1、在电脑桌面上空白地方,点击鼠标右键,在下拉的功能框中选择“XLS工作表”或“XLSX工作表”都可以,如下图所示。 之后&…

持安科技CEO何艺荣获中国信通院2023-2024年度标准卓越贡献奖

近日,由中国信息通信研究院、中国通信标准化协会承办的“全球数字经济大会—云和软件安全论坛”暨“2024第二届SecGo云和软件安全大会”胜利召开,零信任办公安全技术创新企业持安科技创始人兼CEO何艺获评为2023-2024年度零信任领域标准卓越贡献者。 由中…

华盈生物获得美国Akoya认证的PhenoCycler-Fusion(原CODEX)技术服务商

华盈生物获得美国Akoya认证的PhenoCycler-Fusion(原CODEX)技术服务商 华盈生物获得美国Akoya公司认证的PhenoCycler-Fusion(原CODEX)空间单细胞蛋白组技术服务商,并进入该技术的全球CRO服务提供者网络:htt…

获超九成Gartner用户力推!FortiGate连续五年斩获“客户之选”称号

近日,Gartner Peer Insights™ 网络防火墙客户之选报告发布,Fortinet 连续第五年荣登这项权威榜单。该评选结果源于广大用户对 Fortinet 防火墙产品的真实反馈,是客户选择 Fortinet 的重要参考依据,也是FortiGate能够占据全球防火…

Spark-RDD和共享变量

概览 每个Spark应用程序都由一个driver program 组成,该驱动程序运行我们编写的main函数,并在集群上执行各种 并行 操作。Spark提供的主要抽象是一个 弹性分布式数据集(RDD),它是一个跨集群节点分区的元素集合&#x…

Win-ARM联盟的端侧AI技术分析

Win-ARM联盟,端侧AI大幕将起 微软震撼发布全球首款AI定制Windows PC——Copilot PC,搭载全新NPU与重塑的Windows 11系统,纳德拉盛赞其为史上最快、最强、最智能的Windows PC。该设备算力需求高达40TOPS,支持语音翻译、实时绘画、文…

AI网络爬虫019:搜狗图片的时间戳反爬虫应对策略

文章目录 一、介绍二、输入内容三、输出内容一、介绍 如何批量爬取下载搜狗图片搜索结果页面的图片?以孙允珠这个关键词的搜索结果为例: https://pic.sogou.com/pics? 翻页规律如下: https://pic.sogou.com/napi/pc/searchList?mode=2&start=384&xml_len=48&am…

基于Android平台开发,天气预报APP

1.项目功能思维导图 2. 项目涉及到的技术点 数据来源:和风天气API使用okhttp网络请求框架获取api数据使用gson库解析json数据使用RecyclerViewadapter实现未来7天列表展示和天气指数使用PopupMenu 实现弹出选项框使用动画定时器实现欢迎页倒计时和logo动画使用Text…

常见的过压保护芯片、过压保护的基本参数和选型

过压保护也叫过电压保护,是当电压超过预定的最大值时,使电源断开或使受控设备电压降低的一种保护方式。 过压保护芯片是为了防止输入电压的时候浪涌和波纹过大,导致烧坏后面的元器件芯片。因此过压保护芯片是很有必要的芯片。 常见的过压保护…

CentOS7配置阿里云yum源

前提:确认机器可以连接互联网,且系统已经安装了wget软件 先进入到/etc/yum.repos.d目录下查看是否有原来的yum源配置文件,如果有,就将它们备份一下 用yum repolist命令测试,当前系统已经没有可用yum源 输入命令wget -…

护佑未来!引领儿童安全新时代的AI大模型

引领儿童安全新时代的AI大模型 一. 前言1.1 AI在儿童安全方面的潜在作用1.2 实时监控与预警1.3 个性化安全教育与引导1.4 家长监护与安全意识提升 二. AI大模型的优势2.1. 保护儿童隐私和安全的重要性2.2. AI大模型如何应用于儿童安全领域2.1 儿童内容过滤2.2.1 儿童行为监测 2…

案例分享:Qt modbusTcp调试工具(读写Byte、Int、DInt、Real、DReal)(当前v1.0.0)

若该文为原创文章,转载请注明原文出处 本文章博客地址:https://blog.csdn.net/qq21497936/article/details/140313789 红胖子(红模仿)的博文大全:开发技术集合(包含Qt实用技术、树莓派、三维、OpenCV、OpenGL、ffmpeg、OSG、单片…

【Python】已解决:ModuleNotFoundError: No module named ‘pip‘(重新安装pip的两种方式)

文章目录 一、分析问题背景二、可能出错的原因三、错误代码示例 四、重新安装pip的两种方式方式一:使用get-pip.py脚本方式二:使用ensurepip模块五、注意事项 已解决:ModuleNotFoundError: No module named ‘pip’(重新安装pip的…

无线领夹麦克风哪个牌子好,揭秘降噪领夹麦排行榜内幕!

在当今这个短视频如潮水般涌动的时代,人们的日常生活中掀起了一股新的潮流——用Vlog来捕捉生活的点点滴滴,许多博主在各种短视频和直播平台上开启了他们的副业之旅。这一现象催生了麦克风技术的飞速进步,使其从单一的录音工具转变为拥有多种…

这是什么神仙词典 | 保姆级提示词教学指南,直击内容型提示词撰写精髓!

AI文生图时代,提示词是画面的灵魂,用自然语言把想要展现的内容表述出来,加入不同的描述性词汇,从而使画面更丰富。 内容型提示词: 一般具备较强的叙事性,达到以图叙事,以图传情的效果 01 提…

使用昇腾芯片进行多卡训推时使用hccl_tools.py为npu分配ip报错问题解决办法

目录 问题描述问题产生原因解决办法最终执行并验证参考网站命令扩展 问题描述 昇腾芯片(910b/310p等)进行多卡训练或者推理时需要先获取并配置每张npu的ip信息,因此需要执行类似下面问题: python mindformers/tools/hccl_tools.…

暑假学习计划怎么做 用待办计划软件安排更科学

暑期来临,无论是学生还是老师,做好暑期计划都至关重要。记得去年暑假,我给自己定下了阅读十本书的目标,却因为缺乏明确的计划,最后只草草读完了两本。而今年,我决定尝试一种新的方式——使用待办计划软件来…

Linux 防火墙配置指南:firewalld不同服务管理的应用案例(十个)

🏡作者主页:点击! 🐧Linux基础知识(初学):点击! 🐧Linux高级管理专栏:点击! 🔐Linux中firewalld防火墙:点击! ⏰️创作时间&…

科技创新引领水利行业升级:深入分析智慧水利解决方案的核心价值,展望其在未来水资源管理中的重要地位与作用

目录 引言 一、智慧水利的概念与内涵 二、智慧水利解决方案的核心价值 1. 精准监测与预警 2. 优化资源配置 3. 智能运维管理 4. 公众参与与决策支持 三、智慧水利在未来水资源管理中的重要地位与作用 1. 推动水利行业转型升级 2. 保障国家水安全 3. 促进生态文明建设…

Drools开源业务规则引擎(六)- Drools Flow中RuleFlow文件即*.rf文件介绍

文章目录 Drools开源业务规则引擎&#xff08;六&#xff09;- RuleFlow文件即*.rf文件介绍1.\<header>1.1.\<imports>a.标签格式b.属性说明c.示例代码 1.2.\<globals>a.标签格式b.属性说明c.示例代码 1.3.\<functionImports>a.标签格式b.属性说明c.示…