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

简介: 中间件产品门槛高?短时间无法深入了解?免费试用+30秒一键体验,低代码,无部署环境,带你了解“历经万亿级数据洪峰考验”的云消息队列RocketMQ。


本次体验有一定函数计算费用消耗,新用户可领取函数免费资源,已经领取过函数计算免费资源的用户可继续使用。

注意:活动中专有网络VPC和RocketMQ免费均开通地域必须在杭州,否则活动无法完成!!!

1. 普通消息


简介:在多种消息类型中,普通消息是最简单也最为重要。普通消息是 RocketMQ 的基本消息类型,提供高吞吐、扩展、低延迟、异步的通信能力。

整体流程:创建Topic--创建Group--开始“消息收发一键体验”--点击“PushConsumer 方式消费”--输入“Group ID”--点击“运行”--点击“发送普通消息”--输入“消息内容”--点击运行--查看“运行结果”--查看消息详情--查看指标大盘


1.1 步骤一:创建普通消息Topic

Topic名称:rmqfctopic_nomal(直接复制这个名称,不按照名称复制无法确认是否参与活动)

1.jpg


1.2 步骤二:创建Group

Group ID:rmqfcgroup_nomal(直接复制这个名称,不按照名称复制无法确认是否参与活动)

2.jpg


1.3 步骤三:PushConsumer 方式消费


1.点击“PushConsumer 方式消费


3.jpg


2.输入“Group ID”--点击“运行”


4.jpg


1.4 步骤四:开始“普通消息体验”


1.开始“消息收发一键体验”


Dingtalk_20230628175141.jpg


2.点击“发送普通消息”模版


6.jpg


3.输入“消息内容”-点击“运行”--查看“运行结果”


7.jpg


8.jpg


4.消息详情


9.jpg


5.消息轨迹


10.jpg


6.查看指标大盘


普通12.png


普通13.png


2. 定时消息


简介:定时消息是生产者将一条消息发送到消息队列后并不期望这条消息马上会被消费者消费到,而是期望到了指定的时间,消费者才可以消费到。

整体流程:创建Topic--创建Group--开始“消息收发一键体验”--点击“PushConsumer 方式消费”--输入“Group ID”--点击“运行”--点击“定时消息”模版--指定延时时间--设定延时时长--点击“运行”--20s内点击消息详情,没有收到消息--20s后点击消息详情,收到消息--查看消息轨迹--查看指标大盘


2.1 步骤一:创建定时/延时消息Topic

Topic名称:rmqfctopic_delay(直接复制这个名称,不按照名称复制无法确认是否参与活动)


1.jpg


2.2 步骤二:创建Group

Group ID:rmqfcgroup_delay(直接复制这个名称,不按照名称复制无法确认是否参与活动)


2.jpg


2.3 步骤三:PushConsumer 方式消费


1.点击“PushConsumer 方式消费


3.jpg


2.输入“Group ID”--点击“运行”


4.jpg


2.4 步骤四:开始“定时/延时消息场景”体验


1.选择消息类型定时/延时消息--点击更多“消息一键收发”


Dingtalk_20230628175315.jpg


2.指定延时时间:20s(定时时间要小于Group中设置的消息运行时长


7.jpg

8.jpg



3.查看消息详情


  • 20s内点击消息详情,没有收到消息


9.jpg


  • 20s后点击消息详情,收到消息


10.jpg


4.点击消息轨迹


定时9.png


5.查看指标大盘


定时10.png


定时11.png


3. 事务消息


简介:在分布式系统调用场景中存在这样一个通用问题,即在执行一个核心业务逻辑的同时,还需要调用多个下游做业务处理,而且要求多个下游业务和当前核心业务必须同时成功或者同时失败,进而避免部分成功和失败的不一致情况出现。简单来说,消息队列中的“事务”,主要解决的是消息生产者和消费者的数据一致性问题。

整体流程:创建Topic--创建Group--开始“消息收发一键体验”--点击“PushConsumer 方式消费”--输入“Group ID”--点击“运行”--点击“事务消息模版”--输入消息内容--点击“运行”--查看运行结果--点击消息详情--查看消息轨迹--查看指标大盘


3.1 步骤一:创建事务消息Topic

Topic名称:rmqfctopic_tx(直接复制这个名称,不按照名称复制无法确认是否参与活动)


1.jpg


3.2 步骤二:创建Group

Group ID:rmqfcgroup_tx(直接复制这个名称,不按照名称复制无法确认是否参与活动)


2.jpg


3.3 步骤三:PushConsumer 方式消费


1.点击“PushConsumer 方式消费


5.jpg


2.输入“Group ID”--点击“运行”


6.jpg


3.4 步骤四:开始“事务消息场景”体验


1.选择消息类型事务--点击更多“消息一键收发”


Dingtalk_20230628175438.jpg


2.运行


6.jpg

9.jpg


3.消息详情


事务7.png


4.消息轨迹


事务8.png


5.查看指标大盘


事务9.png


事务10.png


4. 顺序消息


简介:对于一个指定的 Topic,同一 MessageGroup 的消息按照严格的先进先出(FIFO)原则进行发布和消费,即先发布的消息先消费,后发布的消息后消费,服务端严格按照发送顺序进行存储、消费。


整体流程:创建Topic--创建Group--开始“消息收发一键体验”--点击“PushConsumer 方式消费”--输入“Group ID”--点击“运行”--点击“顺序消息模版”--输入消息组--输入消息内容--点击“运行”--查看消息详情--查看消息轨迹--查看指标大盘


4.1 步骤一:创建顺序消息Topic

Topic名称:rmqfctopic_fifo(直接复制这个名称,不按照名称复制无法确认是否参与活动)


1.jpg


4.2 步骤二:创建Group

Group ID:rmqfcgroup_fifo(直接复制这个名称,不按照名称复制无法确认是否参与活动)


2.jpg


4.3 步骤三:PushConsumer 方式消费


1.点击“PushConsumer 方式消费


3.jpg


2.输入“Group ID”--点击“运行”


4.jpg


4.4 步骤四:开始“顺序消息场景”体验


1.选择消息类型事务--点击更多“消息一键收发”


5.jpg


2.运行:输入消息组--输入消息内容--点击“运行”


7.jpg

8.jpg


3.查看消息详情


顺序7.png


4.查看消息轨迹


顺序8.png


5.查看指标大盘


顺序9.png


顺序10.png



5. 消息堆积场景


消息堆积:消息堆积是指由于消费者的消费能力有限,未能在短时间内将所有消息正确消费掉,此时在服务端保存着未被消费的消息的状态。在 RocketMQ 中,消息堆积可以通过 Metrics 指标来衡量,这些指标可直接反映队列中消息的处理速率和堆积情况。

整体流程:创建Topic--创建Group--开始“消息收发一键体验”--点击“消息堆积场景”--输入“Group ID”--点击“运行”--查看“运行结果”--查看Topic发送相关仪表盘--ConsumerGroup 消费相关仪表盘


5.1 步骤一:创建普通消息Topic

Topic名称:rmqfctopic_nomal_stacking直接复制这个名称,不按照名称复制无法确认是否参与活动)


1.jpg


5.2 步骤二:创建Group

Group IDrmqfcgroup_nomal_stacking(直接复制这个名称,不按照名称复制无法确认是否参与活动)

2.jpg


5.3 步骤三:开始“消息堆积场景”体验


1.选择“消息堆积场景”体验


4.jpg


2.运行


7.jpg


3.查看 Topic 发送相关仪表盘


堆积5.png


4.查看 ConsumerGroup 消费相关仪表盘


堆积6.png


6. 消息失败重投场景


简介:当消费者消费消息失败时, RocketMQ 会按照最大重试次数重新投递该消息进行故障恢复。在集群模式下,消费的业务逻辑代码会返回消费失败状态,或者抛出异常,如果一条消息消费失败,则会按照设置的最大重试次数重试,之后该消息会被丢弃。

整体流程:创建Topic--创建Group--开始“消息收发一键体验”--点击“消息失败重投景”--输入“Group ID”和“运行时长”--点击“运行”--第一次点击发送的消息后没有收到消息--第三次点击发送的消息重试后收到消息--查看消息详情--查看消息轨迹--查看指标大盘


6.1 步骤一:创建普通消息Topic

Topic名称:rmqfctopic_nomal_retry(直接复制这个名称,不按照名称复制无法确认是否参与活动)


1.jpg


6.2 步骤二:创建Group

Group ID:rmqfcgroup_nomal_retry(直接复制这个名称,不按照名称复制无法确认是否参与活动)


2.jpg


6.3 步骤三:开始“消息失败重投场景”体验


1.点击“消息失败重投场景


3.jpg


2.运行


  • 第一次点击发送的消息-没有收到消息


4.png


  • 第三次点击发送的消息重试-收到消息


image.png


3.消息详情


image.png


4.消息轨迹


image.png


5.指标大盘


重投9.png


7. 【重要】删除相关资源


  1. 体验结束后,记得删除应用。在控制台,进入消息队列 RocketMQ 版实例列表,按照图示删除。

1.png

  1. 依次点击更多,释放应用,并确认。

2.png

3.png

  1. 点击刷新,若应用消失,则说明删除成功

4.png


相关实践学习
RocketMQ一站式入门使用
从源码编译、部署broker、部署namesrv,使用java客户端首发消息等一站式入门RocketMQ。
消息队列 MNS 入门课程
1、消息队列MNS简介 本节课介绍消息队列的MNS的基础概念 2、消息队列MNS特性 本节课介绍消息队列的MNS的主要特性 3、MNS的最佳实践及场景应用 本节课介绍消息队列的MNS的最佳实践及场景应用案例 4、手把手系列:消息队列MNS实操讲 本节课介绍消息队列的MNS的实际操作演示 5、动手实验:基于MNS,0基础轻松构建 Web Client 本节课带您一起基于MNS,0基础轻松构建 Web Client
相关文章
|
6月前
|
存储 传感器 物联网
如何在Docker中配置Mosquitto MQTT代理,以便在容器化环境中运行和管理MQTT通信
如何在Docker中配置Mosquitto MQTT代理,以便在容器化环境中运行和管理MQTT通信
330 0
如何在Docker中配置Mosquitto MQTT代理,以便在容器化环境中运行和管理MQTT通信
|
监控 物联网 API
【.NET+MQTT】.NET6 环境下实现MQTT通信,以及服务端、客户端的双边消息订阅与发布的代码演示
MQTT广泛应用于工业物联网、智能家居、各类智能制造或各类自动化场景等。MQTT是一个基于客户端-服务器的消息发布/订阅传输协议,在很多受限的环境下,比如说机器与机器通信、机器与物联网通信等。好了,科普的废话不多说,下面直接通过.NET环境来实现一套MQTT通信demo,实现服务端与客户端的双边消息发布与订阅的功能和演示。
1011 0
【.NET+MQTT】.NET6 环境下实现MQTT通信,以及服务端、客户端的双边消息订阅与发布的代码演示
|
3天前
|
消息中间件 Shell
rabbitmq安装erlang环境后没生效
rabbitmq安装erlang环境后没生效
323 7
|
3天前
|
消息中间件 Windows
RabbitMQ安装教程(Windows环境下)
RabbitMQ安装教程(Windows环境下)
55 0
|
3天前
|
Linux 智能硬件
Linux MQTT智能家居(温度,湿度,环境监测,摄像头等界面布局设置)
Linux MQTT智能家居(温度,湿度,环境监测,摄像头等界面布局设置)
61 0
|
9月前
|
消息中间件 Linux
Linux搭建RabbitMQ集群环境
Linux搭建RabbitMQ集群环境
253 0
|
10月前
|
传感器 消息中间件 运维
统信UOS系统开发笔记(八):在统信UOS上编译搭建mqtt基础环境(版本使用QMQTT::Clinet)
统信uos使用到mqtt开发,需要重新编译mqtt,本篇描述统信uos20上的mqtt源码编译和环境搭建。这里mqtt版本是使用QMQTT::CLIENT来操作的,这里笔者已知Qt的版本分为两个:一个是QMQTT::QMQTTCLIENT,一个是QTMQTT:CLIENT,对应不同的类和方式,请根据需求选择)
|
11月前
|
消息中间件 Linux Docker
linux环境下用docker安装rabbitmq
linux环境下用docker安装rabbitmq
121 0
|
消息中间件 存储 运维
线上环境大规模RocketMQ集群不停机优雅升级实践
线上环境大规模RocketMQ集群不停机优雅升级实践
线上环境大规模RocketMQ集群不停机优雅升级实践
|
消息中间件 数据安全/隐私保护 Windows
番外篇:搭建Windows环境下的RabbitMQ环境
搭建Windows环境下的Rabbitmq环境 下载erlang语言包OTP。 官网地址:https://www.erlang.org/downloads如果下载不了,可以选择百度网盘下载,里面的版本是21.2:链接:https://pan.baidu.com/s/11catQGzkw1EpFoyQBICJJQ 提取码:optt
97 0
番外篇:搭建Windows环境下的RabbitMQ环境

相关产品

  • 云消息队列 MQ