RocketMQ-六大场景实操指南

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://xiahunao.cn/news/3225698.html

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

相关文章

捷配浅谈PCB基板的导热系数如何影响性能

PCB基板的导热性重要性不言而喻,有许多材料可用作 PCB 基板,除了不同的导热性外,还提供许多其他好处。PCB 基板材料也会影响高温下对导体引起的热应力和高速/高频下的损耗。在选择超出导热系数的基板时,应考虑许多设计权衡&#x…

大模型时代:人工智能与大数据平台的深度融合

在当今的大数据时代,数据已经成为驱动业务增长和创新的关键因素。与此同时,随着人工智能技术的不断进步,AI在大规模数据处理和分析方面的能力日益强大。因此,将人工智能与大数据平台相结合,可以为企业带来巨大的商业价…

《简历宝典》07 - 发布3天就有百人订阅的《简历宝典》,做个第一阶段总结

目录 1 本篇概要 2 最初输出了糟糕的简历模板 3 简历文档名的注意事项 4 “个人信息”模块必须写的内容 5 “个人信息”模块那些非必须写的内容 5.1 校招 - 本科生 - 个人信息的展现 5.2 社招 - 专科生 - 个人信息的展现 6 最后 1 本篇概要 《简历宝典》已经输出了一…

基于Unity3D的发布第一个Rokid AR眼镜应用

发布AR眼镜Demo 一、发布配置二、快速开发第一个AR Demo场景1.创建新场景2.替换Main Camera3. 创建Capsule 三、打包apk应用四、将apk安装到Rokid Master Pro 眼镜1.WiFI-ADB连接AR Studio 与PC2.USB直连Rokid眼镜安装3.运行查看应用 五、Rokid AR系列教程 一、发布配置 UXR2.…

Github Action 自动部署更新静态网页服务

本文首发于 Anyeの小站,点击跳转 获得更优质的阅读体验 前言 贴一段胡话 在用过 应用:静态网页服务 之后,事实证明: 总而言之,自动化是一个很令人着迷的东西,摆脱重复繁琐的工作,解放了双手的…

MES:连接计划与执行的桥梁

想象一下,你的企业拥有一份完美的生产计划,但如何将这份计划准确无误地转化为实际生产中的每一步操作?这就是MES大展身手的地方。MES作为ERP(企业资源计划)与车间自动化控制之间的桥梁,确保生产计划能够顺畅…

校准报告可以引用数据与加盖CNAS章吗?

在咨询校准机构在给他们出具校准报告/证书时,是否可以引用数据,引用数据部分是不是可以加盖CNAS章? 首先,了解一下报告中带CNAS的含义:CNAS-CL01:2018 文件第一章中提出“本准则规定了实验室能力、公正性以及一致运作的…

超越单兵作战:多智能体 Multi-Agent System (MAS)

超越单兵作战:多智能体 Multi-Agent System (MAS) Multi-Agent System 是指一个系统中有多个智能体同时工作的情况。在这样的系统中,每个智能体都具有一定程度的自主性,可以独立执行任务、做决定,并且能够与其他智能体进行交互&a…

为什么贷款都看大数据信用?怎么查大数据报告?

在当今数字化时代,大数据的应用已经深入到各个领域,其中金融行业尤为突出。很多朋友都有疑问,为什么贷款总会查自己的大数据信用?去哪里查?本文就为大家详细的分析一下,一起去看看吧。 一、贷款查大数据信用的几个原因&#xff…

哪些行业更需要TPM管理咨询公司?

当下,TPM(全面生产维护)作为一种旨在提高设备效率、降低维护成本的管理理念,已经被越来越多的行业所认可和采纳。然而,不同行业因其特性和需求的不同,对TPM管理咨询公司的需求也各有侧重。下面将探讨哪些行…

3年经验的B端产品经理,应该是什么水平?

问你一个问题:你觉得3年经验的B端产品经理,应该是什么水平?很多朋友可能也没有仔细想过,自己3年后应该达到一个什么水平?能做什么体量的业务?要能拿多少薪资? 前几天和一个B端产品经理聊天&…

二手市场遗落的上古神器:蜗牛星际NAS J1900和Think Pad X230的三代超值CPU

二手市场有几件神器,比如蜗牛星际NAS套件,从2019年到现在,价格一直稳定小幅攀升,彻底打破了电脑产品价格连年下降的常规印象。 Think Pad X230配置的三代CPU,性能吊打4代、5代CPU,一直到7代,才被…

Codeforces Round 956 F. array-value 【01Trie查询异或最小值】

题意 给定一个非负整数数组 a a a 对每个长度至少为 2 2 2 的子数组&#xff0c;定义其权值为&#xff1a;子数组内两两异或值最小值 即 b ⊂ a [ l , r ] , w ( b ) min ⁡ l ≤ i < j ≤ r { a i ⨁ a j } b \subset a[l, r], \quad w(b) \min_{l \leq i < j \le…

WPF的UI布局

WPF 的 UI 布局 XAML的优点 ui和动画更专业-好用 简单易懂&#xff0c;结构清晰-易学 使设计师直接参与软件开发&#xff0c;随时沟通无需二次转化-高效 真正实现了UI和逻辑的剥离(ui集中在ui层、逻辑代码集中在程序逻辑层&#xff0c;形成高内聚低耦合的结构) XAML是一种…

Paimon下载使用和基础操作说明

简介 Apache Paimon 是一种湖格式&#xff0c;支持使用 Flink 和 Spark 构建实时湖仓一体架构 用于流式处理和批处理操作。Paimon创新性地将湖格式与LSM&#xff08;Log-structured merge-tree&#xff09;相结合 结构&#xff0c;将实时流式更新引入 Lake 架构。 Paimon提供以…

AGE agtype 简介

AGE 使用一种名为 agtype 的自定义数据类型&#xff0c;这是 AGE 返回的唯一数据类型。agtype 是 Json 的超集&#xff0c;也是 JsonB 的自定义实现。 简单数据类型 Null 在Cypher中&#xff0c;null用于表示缺失或未定义的值。概念上&#xff0c;null表示“缺失的未知值”&…

Python数据处理之高效校验各种空值技巧详解

概要 在编程中,处理空值是一个常见且重要的任务。空值可能会导致程序异常,因此在进行数据处理时,必须确保数据的有效性。Python 提供了多种方法来处理不同数据对象的空值校验。本文将详细介绍如何对Python中的各种数据对象进行空值校验,并包含相应的示例代码,帮助全面掌握…

力扣 203反转链表

思路 用cur->next指向pre,把链表倒转 cur后移&#xff0c;cur指向原链表的下一个 注意用tmp存储原链表中cur的后一个 class Solution { public: ListNode* reverseList(ListNode* head) { ListNode *cur head; ListNode *pre nullptr; ListNode *tmp; while (cur ! nul…

【计算机网络仿真】b站湖科大教书匠思科Packet Tracer——实验18 边界网关协议BGP

一、实验目的 1.验证边界网关协议BGP的作用&#xff1b; 2.学习在思科路由器上该协议的使用方法。 二、实验要求 1.使用Cisco Packet Tracer仿真平台&#xff1b; 2.观看B站湖科大教书匠仿真实验视频&#xff0c;完成对应实验。 三、实验内容 1.构建网络拓扑&#xff1b; …

在小红书用AI做壁纸号,矩阵起号爆卖10000+(详细操作教程)

壁纸号领域一直是一个充满机遇的蓝海项目&#xff0c;由于始终有人对壁纸感兴趣&#xff0c;这种需求永不消逝。 随着AI绘画技术的出现&#xff0c;壁纸的创作更加便捷&#xff0c;不需要自己到处无版权地搬运或者自己动手画&#xff0c;更无需操心版权问题。 零成本、易操作…