活动
天翼云最新优惠活动，涵盖免费试用，产品折扣等，助您降本增效！
- 消息重试消息重试 消费者出现异常,分布式消息服务RocketMQ会根据消费重试策略重新投递该消息进行故障恢复。本文主要介绍分布式消息服务RocketMQ中消息重试与使用方法。功能介绍 当消息第一次被消费者消费后,没有得到正常的回应,或者用户要求服务端重投,分布式消息服务RocketMQ会通过消费重试机制自动重新投递该消息,直到该消息被成功消费,当重试达到一定次数后,消息仍未被成功消费,则会停止重试,将消息投递到死信队列中。
- 计费类如何为购买的消息队列RocketMQ实例续费? 为防止资源到期或者浪费,已经购买包月实例的用户,可执行续费操作,延长 RocketMQ实例的有效期,也可以设置到期自动续费的相关操作。 开通的RocketMQ实例资源包何时生效? 天翼云分布式消息服务RocketMQ资源包在客户支付成功之后,系统经过初始化完成后即可生效使用。
- 产品定义顺序消息:指消费消息的顺序要同发送消息的顺序一致,在RocketMQ中,主要有两种有序消息:全局有序消息和局部有序消息(又叫普通有序消息、分区有序消息)。 事务消息:提供类似X/Open XA的分布式事务功能来确保业务发送方和MQ消息的最终一致性,其本质是通过半消息(prepare消息和commit消息)的方式把分布式事务放在MQ端来处理。 延时消息:生产者将消息发送到消息队列RocketMQ服务端,设计消费时延,在预设的时间后才可以被消费者消费。 更多信息请参见功能特性。
- 路由到分布式消息服务RocketMQ在消息查询页面,按时间查询即可查看消息内容,如图2所示。图2 在分布式消息服务RocketMQ管理控制台中查看消息详情
- 分布式消息服务RocketMQ事件目标空结果验证使用事件总线发布消息功能,发送一个自定义事件。您可以在分布式消息服务RocketMQ控制台确认是否接收到事件。登录分布式消息服务RocketMQ控制台,然后在左侧导航栏选择实例列表。在实例列表页面单击目标实例名称。在消息查询页面,按时间查询即可查看消息内容,如图2所示。图2 在分布式消息服务RocketMQ管理控制台中查看消息详情
- 业务消息设计：Topic与TagTopic与Tag释义 1)Topic:消息主题,通过 Topic 对不同的业务消息进行分类。 2)Tag:消息标签,用来进一步区分某个Topic下的消息分类,消息队列 RocketMQ允许消费者按照Tag对消息进行过滤,确保消费者最终只消费到他关注的消息类型。 Topic与Tag都是业务上用来归类的标识,区分在于Topic是一级分类,而Tag 可以说是二级分类。
- 入门指引2.创建RocketMQ实例 在订购分布式消息RocketMQ填写和确认实例名称、引擎类型、计费模式等信息,确认费用后点击下一步,等待开通流程结果通知成功后完成创建实例。 3.创建主题和订阅组 开通实例后,在控制台相关页面按照指引创建主题和订阅组,用于发送和接收消息。 4.创建应用用户和分配权限 创建应用用户并分配主题和订阅组权限,实现各应用共享或者独占消息队列的效果。
- 自定义分布式消息服务RocketMQ事件源在添加自定义事件源面板,输入名称和描述,事件提供方选择分布式消息服务RocketMQ,选择实例、主题等配置然后单击确认,如图1所示。图1 创建事件源时事件提供方选择分布式消息服务RocketMQ参数说明参数说明示例 名称 事件源名。source1实例名称选择前提条件中已创建的分布式消息服务RocketMQ版实例。xxx Topic选择当前实例中的Topic。topic1Group快速创建:自动创建以GID_EVENTBRIDGE_xxx命名的Group ID。
- 触发器事件消息格式properties.MIN_OFFSETstring0消息队列中的最小偏移量。properties.TAGSstring1747987204605_0消息标签。properties.UNIQ_KEYstring2100077510A605EF04B574BAE2080001消息唯一键。datastringWebTestTools_17v6fg0J消息体内容。 RabbitMQ触发器有两种消息格式:RawData和CloudEvent格式,可在触发器配置里选择。
- 用户权限管理场景描述 RocketMQ提供了用户管理和权限管理机制,用于确保消息队列的安全性和访问控制。另外RocketMQ还支持角色的概念,可以将多个权限组合成一个角色,并将角色分配给用户。通过角色管理,可以简化权限管理的复杂性,提高管理效率。 通过用户管理和权限管理机制,RocketMQ可以实现对消息队列的细粒度访问控制,确保只有授权的用户能够读取、写入和订阅消息,并提供了灵活的角色管理功能,方便管理员进行权限分配和管理。这些机制可以帮助用户保护消息队列的安全性,防止未经授权的访问和操作。
- Kafka触发器当开启死信队列时且异常发生并超过重试策略配置时,消息会被投递到指定的消息队列里,当前只支持投递到kafka和rocketmq -
- 产品优势本章节介绍了分布式消息服务RocketMQ的产品优势、以及上云的好处。 分布式消息服务RocketMQ具有如下产品优势,旨在打造一个即开即用、全托管、低延迟、弹性高可靠、动态扩展、便捷管理和多样功能的消息队列。 即开即用 简单几步即可在云上构建自己专属的消息服务,RocketMQ实例创建完成后,使用实例提供的访问地址即可快速接入。兼容开源RocketMQ,业务代码无需改造,即可上云。
- RocketMQ性能白皮书测试场景 本章节主要测试RocketMQ不同产品规格在发送1KB大小的消息,实例的网络入流量、网络出流量、消息生产速率、消息消费速率、CPU核均负载和内存使用率。
- 生产消费验证本文介绍分布式消息服务RocketMQ入门指引的生产消费验证内容。 背景信息 RocketMQ的生产消费验证是指在使用RocketMQ进行消息生产和消费时的验证过程。具体而言,验证包括以下几个方面: 生产者验证:RocketMQ提供了丰富的生产者API,开发人员可以使用这些API将消息发送到RocketMQ的消息队列中。在验证阶段,可以通过发送消息并检查返回结果来确保消息成功发送到Broker节点。此外,生产者还应该验证消息的顺序性、事务性以及可靠性等方面。
- 重置消费位置场景描述 在RocketMQ中,重置消费位置是一个常见的场景,用于重新设置消费者对消息队列的消费位置。以下是一些常见的RocketMQ重置消费位置的场景描述: 消费者异常停止后的重启:当消费者由于某种原因异常停止后,重新启动时可能需要重置消费位置。例如,消费者在处理消息时发生故障导致停止,重新启动后可以选择从上次消费的位置继续消费,或者从最早的消息开始重新消费。 消费者消费进度错误或需要重新处理:在某些情况下,消费者的消费进度可能出现错误,或者需要重新处理之前未正确处理的消息。
- 消息查询综上所述,通过查询RocketMQ中的消息信息,可以实现消息的监控、故障排查、统计分析以及数据同步与恢复等功能,为系统的稳定运行和数据管理提供了重要的支持。 操作步骤 1、 进入管理控制台消息查询菜单。 2、 下拉选择集群名称和broker名称。 3、 提供五种查询消息的方式:按key,按ID,按偏移量,基于Topic查询,死信队列查询。 根据Key查询 根据消息的key查询消息列表,key要求尽可能全局唯一。 点击“查看”,可以查询该消息的包体内容。
- RabbitMQ触发器当开启死信队列时且异常发生并超过重试策略配置时,消息会被投递到指定的消息队列里,当前只支持投递到kafka和rocketmq- 注意请确保使用的用户名已经对选择的虚拟主机授权。
- 收发定时/延时消息分布式消息服务RocketMQ版支持任意时间的定时消息,最大推迟时间可达到40天。 定时消息即生产者生产消息到分布式消息服务RocketMQ版后,消息不会立即被消费,而是延迟到设定的时间点后才会发送给消费者进行消费。 发送定时消息前,请参考收集连接信息收集RocketMQ所需的连接信息。 适用场景 定时消息适用于以下场景: 消息对应的业务逻辑有时间窗口要求,如电商交易中超时未支付关闭订单的场景。
- RocketMQ PHP SDK说明分布式消息服务RocketMQ兼容了社区版 HTTP SDK,您可以使用社区版 HTTP SDK接入分布式消息服务RocketMQ。 前提条件: 在PHP安装目录下的composer.json文件中加入社区PHP SDK 依赖。 使用Composer安装依赖。 composer install 发送普通消息收发事务消息收发事务消息前,请参考收集连接信息收集RocketMQ所需的连接信息。 准备环境 开源的Java客户端支持连接分布式消息服务RocketMQ版,推荐使用的客户端版本为4.9.7。Topic导入/导出登录分布式消息队列RocketMQ控制台,在左侧导航栏单击 实例列表 。 在顶部菜单栏选择地域,如 华东1 ,然后在实例列表中,单击目标实例名称。 在左侧导航栏单击 Topic 管理 。 在Topic 管理页面右上角单击导入Topic。 选择在本地保存的Topic资源列表文件,然后单击打开,点击确认 。 导入完成后,导入的Topic会出现在Topic列表中。分布式消息服务RocketMQ服务等级协议本章节介绍了分布式消息服务RocketMQ服务等级协议。 分布式消息服务RocketMQ服务等级协议使用限制128位首尾不包含空格20云原生分布式消息队列RocketMQ是是128位首尾不包含空格20云原生分布式消息队列RabbitMQ是是128位首尾不包含空格20云原生分布式消息队列Kafka是是128位首尾不包含空格20云原生分布式消息队列MQTT是是128位首尾不包含空格20云原生事件总线是是128位首尾不包含空格20云原生弹性容器实例ECI是是128位首尾不包含空格20云原生分布式容器云平台CCE ONE是是128位首尾不包含空格20云原生函数计算否是128位首尾不包含空格20安全及管理Web应用防火墙收发定时/延时消息分布式消息服务RocketMQ版支持任意时间的定时消息,最大推迟时间可达到40天。 定时消息即生产者生产消息到分布式消息服务RocketMQ版后,消息不会立即被消费,而是延迟到设定的时间点后才会发送给消费者进行消费。 收发消息前,请参考收集连接信息收集RocketMQ所需的连接信息。 准备环境 在命令行输入python,检查是否已安装Python。得到如下回显,说明Python已安装。消费组导入/导出登录分布式消息队列RocketMQ控制台,在左侧导航栏单击 实例列表。 在顶部菜单栏选择地域,如华东1,然后在实例列表中,单击目标实例名称。 在左侧导航栏单击消费组管理。 在消费组管理页面右上角单击导入消费组。 选择在本地保存的消费组资源列表文件,然后单击打开,点击确认。 导入完成后,导入的消费组会出现在消费组列表中。概览RocketMQ TPS监控可以帮助用户了解消息中间件的处理能力和性能状况,在系统运行期间,通过监控数据可以及时发现潜在的性能问题或瓶颈,以便进行调优或扩展。一般来说,吞吐量越高,表示系统的处理能力越强。 分布式消息服务RocketMQ标识该集群所有broker下,所有topic的生产、消费tps(2min)的时间变化曲线。 全局堆积 在使用RocketMQ时,可能会遇到消息堆积的情况,即未能及时处理和消费的消息大量积压在消息队列中。消息监控通过消息队列接收消息显示topic列表,表头如下。topic:是指消息队列中接收到的特定主题(topic)的消息。主题用于将相关的消息进行归类和分组。调用次数:是指在一段时间内,通过消息队列接收消息的总调用次数。每次调用消息队列的接收操作(例如KafkaConsumer的poll()方法)并成功获取一条消息都会被计算为一次调用。平均响应时间(ms):是指从发起接收请求到接收到消息的平均时间。它表示了接收消息的速度和效率。错误数:表示在接收消息的过程中发生的错误次数。仲裁队列介绍分布式消息服务RabbitMQ仲裁队列功能。 使用场景 仲裁队列(Quorum Queue)是基于Raft一致性协议实现的一种新型的分布式消息队列,针对RabbitMQ的镜像模式设计。仲裁队列中的消息需要有集群中过半节点同意确认后,才会写入到队列中。 仲裁队列与镜像队列的差异 使用镜像队列,当生产者发送一条消息,主队列会将消息同步给镜像队列,所有的镜像队列都保存消息后,主队列才会向生产者发送确认。 仲裁队列的算法是基于Raft共识算法的一个实现。查询订阅组详细状态信息CLUSTERINGallocateMessageQueueStrategyString消息队列分配策略org.apache.rocketmq.client.consumer.rebalance.AllocateMessageQueueAveragely@14978a04pullThresholdSizeForTopicString主题拉取大小阈值-1suspendCurrentQueueTimeMillisString队列挂起时间(毫秒)1000pullThresholdSizeForQueueString收发事务消息分布式消息服务RocketMQ版的事务消息支持在业务逻辑与发送消息之间提供事务保证,通过两阶段的方式提供对事务消息的支持,事务消息交互流程如图1所示。 图1 事务消息交互流程 事务消息生产者首先发送半消息,然后执行本地事务。如果执行成功,则发送事务提交,否则发送事务回滚。服务端在一段时间后如果一直收不到提交或回滚,则发起回查,生产者在收到回查后重新发送事务提交或回滚。消息只有在提交之后才投递给消费者,消费者对回滚的消息不可见。收发普通消息准备环境 开源的Java客户端支持连接分布式消息服务RocketMQ版,推荐使用的客户端版本为4.9.7。 通过以下任意一种方式引入依赖: 使用Maven方式引入依赖。Kafka触发器当开启死信队列时且异常发生并超过重试策略配置时,消息会被投递到指定的消息队列里,当前只支持投递到kafka和rocketmq-
天翼云最新活动
售前咨询热线
400-810-9889转1
关注天翼云
©2025
天翼云科技有限公司版权所有 增值电信业务经营许可证A2.B1.B2-20090001
公司地址：北京市东城区青龙胡同甲1号、3号2幢2层205-32室
