RocketMQ体验测评

简介: 【8月更文挑战第15天】RocketMQ体验测评

RocketMQ入门

一键体验RocketMQ六大环境

「一键体验RocketMQ六大环境」活动操作手册

消息队列社区

快速使用云上RocketMQ进行消息收发

RocketMQ小助手

RocketMQ试用

在活动首页点击立即试用,选择好地域、创建好专有网络VPC和交换机VSwitch信息,可参考创建专有网络和交换机,勾选同意协议,点击立即试用。如下图:



完成产品试用领取后,就可以进入控制台了,如下图:

 

本次产品体验活动提供了六个场景,普通消息、定时消息、事务消息、顺序消息、堆积消息、失败重投。接下来逐个开启体验。

RocketMQ体验

开始体验前,得先创建Topic和Group资源,用于发送消息和订阅消息。可在实例列表页面单击试用实例的名称,在左侧导航栏选择Topic 管理,然后在页面左上角单击创建 Topic。如下图:

 

普通消息场景

普通消息是RocketMQ的基本消息类型,是最简单也最重要的一种消息。创建Topic,如下图:

 

接着需要创建一个Group,点击Group管理,创建Group,如下图:

 

接下来就可以进行消息收发体验了,在Topic列表中,选择更多,点击消息一键收发体验。如下图:

 

用户也可以点击topic名称,进入详情页,点击消息一键收发体验。如下图:

 

在基础功能这里,点击发送普通消息,如下图:

 

输入需要发送的消息内容,点击运行,如下图:

 

稍等片刻,既可以看到运行结果,用户可查看消息详情、消息轨迹、指标大盘。如下图:

 

 

 

 

实验中提到了两种消费方式,一种是发送普通消息,一种是PushConsumer 方式消费,两者的差异在于是否需要指定消费组Group,发送普通消息无需指定即可完成消息的收发,而PushConsumer 方式则需要指定Group。

定时消息场景

定时消息顾名思义就是用户不希望发送消息后立马进行消费,而是等待片刻后进行订阅消费的场景。相较于普通消息场景,定时消息场景创建Topic时需要选择消息类型为”定时/延时消息“。如下图:

 

接着创建一个group,用来订阅消息,完成后点击消息一键收发体验,基础功能这里选择发送定时消息。如下图:

 

在定时消息设置页,选择延时方式为”指定延时时间“并设置延时时间为”10“,输入消息内容”hi,this is a message“,点击运行,如下图:

 

运行后消息并没有立刻消费,如下图:

 

待延时时间一到,再次点击查看消息详情,可看到已经被消费的消息内容,如下图:

 

事务消息场景

理解事务消息前,需要先了解什么是事务,比如一个电商交易,用户支付订单这一核心操作的同时会涉及到下游物流发货、积分变更、购物车状态清空等多个子系统的变更,也就是说一个核心业务逻辑的执行,同时需要调用多个下游业务进行处理。那如何保证核心业务和多个下游业务的执行结果完全一致呢?这就是”事务“存在的必要性,也是分布式需要解决的主要问题。体验事务消息场景,首先需要创建一个事务消息类型的Topic,如下图:

 

完成group创建后,点击消息一键发送体验,选择发送事务消息,如下图:

 

 

顺序消息场景

所谓顺序消息,就是先发送的先消费,后发送的后消费,严格按照FIFO(先进先出)原则的一种消息类型。创建Topic时,选择消息类型为顺序消息,如下图:

 

相较于其他消息类型,顺序消息创建Group时,投递的顺序性需要选择顺序投递,如下图:

 

 

 

消息堆积场景

实际业务场景中,经常会遇到由于主机性能不足导致消息非及时发送或消费的问题,这就是消息堆积,也叫消息积压。

 

完成Group创建后,点击消息一键收发体验,选择复杂场景中的”消息堆积场景“,如下图:

 

 

运行后,可以从运行结果看到,实际发送了530条消息,可仅接收消费了10条,消息堆积严重,如下图:

 

消息失败重投场景

消息失败重投其实可以理解为是一种故障恢复的机制,也就是说遇到消息失败时可以根据事先设定的重试次数进行重试直至故障恢复,重试次数未恢复则直接丢弃该消息。

 

体验消息失败重投需要在复杂场景中选择”消息失败重投场景“,如下图:

 

 

 

运行后,我们可以在消费轨迹中看到消息失败次数以及重试次数,如下图:

 

六大场景体验下来,非常流畅,传统方式需要命令交互方式来实现消息的发送、查看、订阅、排障等,RocketMQ只需要简单的点点鼠标即可实现消息从发送到消费及后期监控的全套功能,用户无需去弄明白实现的方式,只需要看到实现的效果即可,真正做到了开箱即用。

RocketMQ AI助手体验

用户可以直接通过点击开始对话来体验AI助手,RocketMQ AI助手是基于当下正热的AIGC进行研发的,用户可以通过与小助手对话的方式快速了解RocketMQ。当前小助手还存在初期体验测试阶段,训练营群提供了如下20个代表性的问题进行针对训练,大家不妨都来试试,共同提升小助手的解答能力,从而更好地为用户服务。

1、RocketMQ支持哪些开发语言和SDK?

2、订阅关系不一致是什么原因?

3、发送消息报错怎么处理?

4、消息没消费一直堆积怎么排查?

5、RocketMQ报Topic找不到错误怎么处理?

6、RocketMQ支持广播消费吗?

7、RocketMQ怎么发送定时消息?

8、提供一下收发消息示例?

9、RocketMQ 消费失败怎么处理?

10、RocketMQ 消息是否可靠,不会丢?

11、RocketMQ 怎么部署?

12、RocketMQ和Kafka有什么区别?

13、RocketMQ 怎么创建Topic?

14、RocketMQ 怎么删除消息?

15、RocketMQ 怎么发送事务消息?

16、RocketMQ 可以保证消息顺序吗?

17、RocketMQ 服务端报错如何解决?

18、RocketMQ 怎么自动创建Topic?

19、RocketMQ 支持最大消息有多大?

20、RocketMQ 消息可以保存多久?

体验完这20个问题的对话后,想基此提点建议,如下:

1、相关类知识重复度很高,比如下图,虽然内容有微小的差异,但主体内容是一致的。可能出现的原因碍于当下文档的缺乏,建议后期优化调整。

 

2、在解答问题类的回答中,当前版本的助手均会在相关中出现介绍类的文档,诸如消息队列RocketMQ、为什么选择RocketMQ等,建议不要出现介绍类的文档,这类文档可出现产品对比、功能优势等问答中,因为用户需要的是解疑答惑类的文案,出现介绍类不但不会去点击,反而会影响整体的体验。

 

3、在示例回答中,格式不统一,有时候是文本,如下图,有时候又是代码段形式,建议统一为代码段形式。

 

 

4、相关类的链接有时会出现如下图所示的明文,这应该是调试导致的,建议修复。

 

RocketMQ作为一款基于Apache RocketMQ构建的分布式消息队列中间件,对于新手用户来说,建议从以下几个方面进行学习掌握(点击链接均可直达哟)。

1、参加官方开办的消息队列RocketMQ 5.0 云原生架构升级训练营0基础掌握RocketMQ5.0训练营学习,对产品有个初步的了解;

2、认真完成训练营中涉及的在线实验一在线实验二在线实验三实现从理论到实践的转变;

3、认真学习官网的在线帮助文档,先对产品有个整体的了解;

4、勤逛消息队列的开发者社区,了解真实的业务应用场景和有关答疑解惑;

5、勤阅读在线电子书,可以实现从入门到实战;

相关实践学习
5分钟轻松打造应对流量洪峰的稳定商城交易系统
本实验通过SAE极速部署一个微服务电商商城,同时结合RocketMQ异步解耦、削峰填谷的能力,带大家体验面对流量洪峰仍旧稳定可靠的商城交易系统!
消息队列 MNS 入门课程
1、消息队列MNS简介 本节课介绍消息队列的MNS的基础概念 2、消息队列MNS特性 本节课介绍消息队列的MNS的主要特性 3、MNS的最佳实践及场景应用 本节课介绍消息队列的MNS的最佳实践及场景应用案例 4、手把手系列:消息队列MNS实操讲 本节课介绍消息队列的MNS的实际操作演示 5、动手实验:基于MNS,0基础轻松构建 Web Client 本节课带您一起基于MNS,0基础轻松构建 Web Client
目录
打赏
0
1
1
0
1701
分享
相关文章
秒懂消息队列MQ,万字总结带你全面了解消息队列MQ
消息队列是大型分布式系统不可缺少的中间件,也是高并发系统的基石中间件,所以掌握好消息队列MQ就变得极其重要。接下来我就将从零开始介绍什么是消息队列?消息队列的应用场景?如何进行选型?如何在Spring Boot项目中整合集成消息队列。
22479 10
秒懂消息队列MQ,万字总结带你全面了解消息队列MQ
乐言科技:云原生加速电商行业赋能,云消息队列助力降本 37%
乐言科技依托云原生架构及阿里云云原生产品体系,实现基础设施与业务解耦以及弹性调度,在提升业务稳定性的同时,显著增加研发效能并降低运维成本,加速电商客户定制化需求交付,推动云计算与 AI 技术在电商领域的深度融合。
317 101
10倍降本、10倍无损弹性!Kafka Serverless 基础版与专业版重磅发布!
云消息队列 Kafka 版基于 Apache Kafka 构建,提供高吞吐量与高可扩展性的分布式消息队列服务,广泛应用于日志收集、监控数据聚合、流式数据处理及在离线分析等场景,是 AI 与大数据时代企业数据处理体系的核心组件。
云消息队列 RabbitMQ 版实践解决方案评测
随着企业业务的增长,对消息队列的需求日益提升。阿里云的云消息队列 RabbitMQ 版通过架构优化,解决了消息积压、内存泄漏等问题,并支持弹性伸缩和按量计费,大幅降低资源和运维成本。本文从使用者角度详细评测这一解决方案,涵盖实践原理、部署体验、实际优势及应用场景。
RocketMQ Controller 模式 始终更新成本机ip
ontrollerAddr=192.168.24.241:8878 但是日志输出Update controller leader address to 127.0.0.1:8878。导致访问失败
139 4
ApsaraMQ x Confluent 云原生 Kafka 线上沙龙
云消息队列 Kafka 版是基于 Apache Kafka 构建的全托管服务,依托于阿里云强大的基础设施,对 Apache Kafka 进行了深度重构,通过存算分离架构、高弹性扩展、云服务深度集成等优化,致力于打造更经济、更稳定、更弹性的云原生 Kafka 产品,助力企业在数字化与智能化转型中,实现业务的稳定增长与创新突破。同时,阿里云作为全球消息流领域领导者 Confluent 在中国大陆地区唯一的合作商,推出云消息队列 Confluent 版,为企业提供集成消息流式处理与大数据系统的一站式解决方案。
高弹性、低成本的云消息队列RabbitMQ 版
本次课程由阿里云消息队列产品专家杨文婷分享,主题为高弹性、低成本的云消息队列RabbitMQ。内容涵盖四个方面:1) 产品优势,包括兼容开源客户端、解决稳定性痛点和高弹性低成本;2) 架构实现原理,如分布式架构和弹性调度系统;3) Serverless系列带来的按量付费模式和资源池优势;4) Serverless适用场景,如开发测试环境、峰谷流量业务等。最后解答了关于顺序消费、与普通MQ对比、自动扩容及API支持等常见问题。
312 46
|
10月前
|
docker export
【9月更文挑战第09天】
187 3
消息队列 MQ使用问题之遇到消费速度是固定的并且导致了堆积,该怎么办
消息队列(MQ)是一种用于异步通信和解耦的应用程序间消息传递的服务,广泛应用于分布式系统中。针对不同的MQ产品,如阿里云的RocketMQ、RabbitMQ等,它们在实现上述场景时可能会有不同的特性和优势,比如RocketMQ强调高吞吐量、低延迟和高可用性,适合大规模分布式系统;而RabbitMQ则以其灵活的路由规则和丰富的协议支持受到青睐。下面是一些常见的消息队列MQ产品的使用场景合集,这些场景涵盖了多种行业和业务需求。
消息队列 MQ使用问题之如何使用DefaultMQPushConsumer来消费消息
消息队列(MQ)是一种用于异步通信和解耦的应用程序间消息传递的服务,广泛应用于分布式系统中。针对不同的MQ产品,如阿里云的RocketMQ、RabbitMQ等,它们在实现上述场景时可能会有不同的特性和优势,比如RocketMQ强调高吞吐量、低延迟和高可用性,适合大规模分布式系统;而RabbitMQ则以其灵活的路由规则和丰富的协议支持受到青睐。下面是一些常见的消息队列MQ产品的使用场景合集,这些场景涵盖了多种行业和业务需求。
AI助理

你好,我是AI助理

可以解答问题、推荐解决方案等