本次体验有一定函数计算费用消耗,新用户可领取函数免费资源,已经领取过函数计算免费资源的用户可继续使用。
注意:活动中专有网络VPC和RocketMQ免费均开通地域必须在杭州,否则活动无法完成!!!
1. 普通消息
简介:在多种消息类型中,普通消息是最简单也最为重要。普通消息是 RocketMQ 的基本消息类型,提供高吞吐、扩展、低延迟、异步的通信能力。
整体流程:创建Topic--创建Group--开始“消息收发一键体验”--点击“PushConsumer 方式消费”--输入“Group ID”--点击“运行”--点击“发送普通消息”--输入“消息内容”--点击运行--查看“运行结果”--查看消息详情--查看指标大盘
1.1 步骤一:创建普通消息Topic
Topic名称:rmqfctopic_nomal(直接复制这个名称,不按照名称复制无法确认是否参与活动)
1.2 步骤二:创建Group
Group ID:rmqfcgroup_nomal(直接复制这个名称,不按照名称复制无法确认是否参与活动)
1.3 步骤三:PushConsumer 方式消费
1.点击“PushConsumer 方式消费”
2.输入“Group ID”--点击“运行”
1.4 步骤四:开始“普通消息体验”
1.开始“消息收发一键体验”
2.点击“发送普通消息”模版
3.输入“消息内容”-点击“运行”--查看“运行结果”
4.消息详情
5.消息轨迹
6.查看指标大盘
2. 定时消息
简介:定时消息是生产者将一条消息发送到消息队列后并不期望这条消息马上会被消费者消费到,而是期望到了指定的时间,消费者才可以消费到。
整体流程:创建Topic--创建Group--开始“消息收发一键体验”--点击“PushConsumer 方式消费”--输入“Group ID”--点击“运行”--点击“定时消息”模版--指定延时时间--设定延时时长--点击“运行”--20s内点击消息详情,没有收到消息--20s后点击消息详情,收到消息--查看消息轨迹--查看指标大盘
2.1 步骤一:创建定时/延时消息Topic
Topic名称:rmqfctopic_delay(直接复制这个名称,不按照名称复制无法确认是否参与活动)
2.2 步骤二:创建Group
Group ID:rmqfcgroup_delay(直接复制这个名称,不按照名称复制无法确认是否参与活动)
2.3 步骤三:PushConsumer 方式消费
1.点击“PushConsumer 方式消费”
2.输入“Group ID”--点击“运行”
2.4 步骤四:开始“定时/延时消息场景”体验
1.选择消息类型定时/延时消息--点击更多“消息一键收发”
2.指定延时时间:20s(定时时间要小于Group中设置的消息运行时长
3.查看消息详情
- 20s内点击消息详情,没有收到消息
- 20s后点击消息详情,收到消息
4.点击消息轨迹
5.查看指标大盘
3. 事务消息
简介:在分布式系统调用场景中存在这样一个通用问题,即在执行一个核心业务逻辑的同时,还需要调用多个下游做业务处理,而且要求多个下游业务和当前核心业务必须同时成功或者同时失败,进而避免部分成功和失败的不一致情况出现。简单来说,消息队列中的“事务”,主要解决的是消息生产者和消费者的数据一致性问题。
整体流程:创建Topic--创建Group--开始“消息收发一键体验”--点击“PushConsumer 方式消费”--输入“Group ID”--点击“运行”--点击“事务消息模版”--输入消息内容--点击“运行”--查看运行结果--点击消息详情--查看消息轨迹--查看指标大盘
3.1 步骤一:创建事务消息Topic
Topic名称:rmqfctopic_tx(直接复制这个名称,不按照名称复制无法确认是否参与活动)
3.2 步骤二:创建Group
Group ID:rmqfcgroup_tx(直接复制这个名称,不按照名称复制无法确认是否参与活动)
3.3 步骤三:PushConsumer 方式消费
1.点击“PushConsumer 方式消费”
2.输入“Group ID”--点击“运行”
3.4 步骤四:开始“事务消息场景”体验
1.选择消息类型事务--点击更多“消息一键收发”
2.运行
3.消息详情
4.消息轨迹
5.查看指标大盘
4. 顺序消息
简介:对于一个指定的 Topic,同一 MessageGroup 的消息按照严格的先进先出(FIFO)原则进行发布和消费,即先发布的消息先消费,后发布的消息后消费,服务端严格按照发送顺序进行存储、消费。
整体流程:创建Topic--创建Group--开始“消息收发一键体验”--点击“PushConsumer 方式消费”--输入“Group ID”--点击“运行”--点击“顺序消息模版”--输入消息组--输入消息内容--点击“运行”--查看消息详情--查看消息轨迹--查看指标大盘
4.1 步骤一:创建顺序消息Topic
Topic名称:rmqfctopic_fifo(直接复制这个名称,不按照名称复制无法确认是否参与活动)
4.2 步骤二:创建Group
Group ID:rmqfcgroup_fifo(直接复制这个名称,不按照名称复制无法确认是否参与活动)
4.3 步骤三:PushConsumer 方式消费
1.点击“PushConsumer 方式消费”
2.输入“Group ID”--点击“运行”
4.4 步骤四:开始“顺序消息场景”体验
1.选择消息类型事务--点击更多“消息一键收发”
2.运行:输入消息组--输入消息内容--点击“运行”
3.查看消息详情
4.查看消息轨迹
5.查看指标大盘
5. 消息堆积场景
消息堆积:消息堆积是指由于消费者的消费能力有限,未能在短时间内将所有消息正确消费掉,此时在服务端保存着未被消费的消息的状态。在 RocketMQ 中,消息堆积可以通过 Metrics 指标来衡量,这些指标可直接反映队列中消息的处理速率和堆积情况。
整体流程:创建Topic--创建Group--开始“消息收发一键体验”--点击“消息堆积场景”--输入“Group ID”--点击“运行”--查看“运行结果”--查看Topic发送相关仪表盘--ConsumerGroup 消费相关仪表盘
5.1 步骤一:创建普通消息Topic
Topic名称:rmqfctopic_nomal_stacking(直接复制这个名称,不按照名称复制无法确认是否参与活动)
5.2 步骤二:创建Group
Group ID:rmqfcgroup_nomal_stacking(直接复制这个名称,不按照名称复制无法确认是否参与活动)
5.3 步骤三:开始“消息堆积场景”体验
1.选择“消息堆积场景”体验
2.运行
3.查看 Topic 发送相关仪表盘
4.查看 ConsumerGroup 消费相关仪表盘
6. 消息失败重投场景
简介:当消费者消费消息失败时, RocketMQ 会按照最大重试次数重新投递该消息进行故障恢复。在集群模式下,消费的业务逻辑代码会返回消费失败状态,或者抛出异常,如果一条消息消费失败,则会按照设置的最大重试次数重试,之后该消息会被丢弃。
整体流程:创建Topic--创建Group--开始“消息收发一键体验”--点击“消息失败重投景”--输入“Group ID”和“运行时长”--点击“运行”--第一次点击发送的消息后没有收到消息--第三次点击发送的消息重试后收到消息--查看消息详情--查看消息轨迹--查看指标大盘
6.1 步骤一:创建普通消息Topic
Topic名称:rmqfctopic_nomal_retry(直接复制这个名称,不按照名称复制无法确认是否参与活动)
6.2 步骤二:创建Group
Group ID:rmqfcgroup_nomal_retry(直接复制这个名称,不按照名称复制无法确认是否参与活动)
6.3 步骤三:开始“消息失败重投场景”体验
1.点击“消息失败重投场景”
2.运行
- 第一次点击发送的消息-没有收到消息
- 第三次点击发送的消息重试-收到消息
3.消息详情
4.消息轨迹
5.指标大盘
7. 【重要】删除相关资源
- 体验结束后,记得删除应用。在控制台,进入消息队列 RocketMQ 版实例列表,按照图示删除。
- 依次点击更多,释放应用,并确认。
- 点击刷新,若应用消失,则说明删除成功