通过可观测性能力进行故障处理最佳实践
消费异常场景实践方案 使用消息处理延迟时间（ConsumerLagLatencyPerGidTopic）作为监控指标项并创建报警规则。具体操作，请参见 监控报警。该指标可明确反映消费链路的健康情况，并直接关联业务影响程度，比消息堆积量更加准确且没有歧义...
什么是消息演练
定位故障根源：经过消息演练之后，积累了消息系统的处理经验，对于未来的系统诊断定位有参考和提升作用。消息的演练场景 消息服务通常是由不同的模块组成。例如，RocketMQ分为生产者Producer、消费者Consumer、服务集群Broker和注册中心...
接入 iOS
iOS 10 以下系统，通知栏消息处理方法-(void)application:(UIApplication*)application didReceiveRemoteNotification:(NSDictionary*)userInfo fetchCompletionHandler:(void(^)(UIBackgroundFetchResult result))completionHandler {/...
消费端挂载NFS是否会影响消费速度？
问题现象 消费端在消费消息的主线程里同步将拉取的消息存储在NFS，导致消费端处理消息的速度变慢，阻塞消息处理。可能原因 NFS本身速度就不太理想。NFS是网络共享存储，虽然有多机器共享访问的能力优势，但多台机器访问是争抢的，消费者...
消息轨迹
按消息处理耗时：在 按消息处理耗时 页签中，选择要查询消息的Queue，输入消息处理耗时时间（单位为秒），设置查询 时间范围，然后单击 查询。在查询的消息列表，选择要查询消息轨迹的消息，在其 操作 列，单击 轨迹详情。在消息轨迹详情...
消息超时和重试机制
本文介绍 云消息队列 RabbitMQ 版 服务端默认的消息重试机制，帮助您理解消费失败后的消息处理逻辑，并选择合适的消息处理策略。重试机制 云消息队列 RabbitMQ 版 服务端有默认的消息重试机制，不支持您在Consumer客户端重新配置消息重试...
消息处理时长自适应
本文介绍如何使消息处理时长自适应。背景信息 消息服务MNS 的规范中，每条消息都有个默认的VisibilityTimeout，Worker在接收到消息后，Timeout就开始计时了。如果Worker在Timeout时间内没能处理完消息，那么消息就有可能被其他Worker接收到...
监控报警
监控项说明 说明 消息堆积量、消息处理延迟时间、已就绪消息量、已就绪消息排队时间等消息堆积场景相关的指标的详细说明，请参见 堆积场景指标说明。指标分类 监控指标 MetricName 统计方法 单位 Instance 实例API调用TPS InstanceApi...
仪表盘
业务背景 云消息队列 RocketMQ 版 的消息收发流程中，队列的堆积情况、缓冲情况以及消息处理各关节的耗时等，会直接反映当前业务处理的性能和服务端运行的状态。因此，云消息队列 RocketMQ 版 的重点指标主要涉及以下业务场景。消息堆积...
查看消息
支持查看消息的客户端 仅 iOS客户端、Android客户端 和 卡片式云电脑终端ASC01 不支持在云电脑管理界面查看消息，其他客户端登录的云电脑可在管理界面查看全局消息，包括管控消息、系统消息和协同消息 Linux操作系统的云电脑不支持在云电脑...
队列使用手册
并且在消息处理过程中，也可以调用changeMessageVisibility这个函数来延长消息的VisibilityTimeout时间。Console.WriteLine("DeleteMessage Failed!ErrorCode:"+me.ErrorCode);} catch(Exception ex){ Console.WriteLine("Delete message ...
监控报警
监控项 单位 MetricName Dimensions Statistics 消息堆积量（Group）count ConsumerLag userId、instanceId、groupId Sum 消息处理延迟时间（GroupId）millisecond ConsumerLagLatencyPerGid userId、instanceId、groupId Maximum 消息处理...
内容分割
背景信息 数据清洗功能提供常见的消息处理模板，包括内容分割、动态路由、内容富化和内容映射等。您可以直接利用模板处理消息，也可以根据业务情况在模板基础上修改代码。消息数据清洗任务提供基本的算子能力，底层逻辑使用函数计算。支持...
内容映射
背景信息 数据清洗功能提供常见的消息处理模板，包括内容分割、动态路由、内容富化和内容映射等。您可以直接利用模板处理消息，也可以根据业务情况在模板基础上修改代码。消息数据清洗任务提供基本的算子能力，底层逻辑使用函数计算。支持...
内容富化
背景信息 数据清洗功能提供常见的消息处理模板，包括内容分割、动态路由、内容富化和内容映射等。您可以直接利用模板处理消息，也可以根据业务情况在模板基础上修改代码。消息数据清洗任务提供基本的算子能力，底层逻辑使用函数计算。支持...
动态路由
背景信息 数据清洗功能提供常见的消息处理模板，包括内容分割、动态路由、内容富化和内容映射等。您可以直接利用模板处理消息，也可以根据业务情况在模板基础上修改代码。消息数据清洗任务提供基本的算子能力，底层逻辑使用函数计算。支持...
延时消息
若延时时间超过延时消息最大延时时间，则当作普通消息处理，即消息发送后被立即投递给消费者消费。最大延时时间根据实例类型不同有所差异，具体数值，请参见 集群限制。若您为延时消息设置了消息存活时间，则 延时消息的实际存活时间＝min{...
主题使用手册
并且在消息处理过程中，也可以调用changeMessageVisibility这个函数来延长消息的VisibilityTimeout时间。Console.WriteLine("DeleteMessage Failed!ErrorCode:"+me.ErrorCode);} catch(Exception ex){ Console.WriteLine("Delete message ...
日志管理
本案例要查询某个客户端消息处理量，即输入客户端IP地址，查询语句格式为$ClientIP，例如 10.10.10.0。如果您要查询某个客户端的某类操作日志，可使用多个关键字组合方式，例如$ClientIP and(SendMessage or BatchSendMessage)。查询结果...
订阅消息
class ExampleMessageListener:public MessageListener { public:Action consume(Message&message,ConsumeContext&context){/此处为具体的消息处理过程，确认消息被处理成功请返回CommitMessage。如果有消费异常，或者期望重新消费，可以...
消息队列
任务A作为生产者循环向消息队列发送消息，任务B作为消费者循环从消息队列接收消息，一般情况下，消费者处理数据是要花费很长时间，所以会导致消息产生的速度大于消息处理的速度，使得消息队列溢出。所以可以通过调整任务B优先级大于任务A来...
概述
使用限制 使用消息集成功能时的限制项如下表所示。限制项 说明 任务数 单地域总任务数（包括消息流入和消息流出）不超过20个，如果您需要提升创建消息集成的任务数，请 提交工单 申请。任务名称 必须以字母或数字开头，剩余部分可以包含...
概述
使用限制 使用消息集成功能时的限制项如下表所示。限制项 说明 任务数 单地域总任务数（包括消息流入和消息流出）不超过20个，如果您需要提升创建消息集成的任务数，请 提交工单 申请。任务名称 必须以字母或数字开头，剩余部分可以包含...
概述
使用限制 使用消息集成功能时的限制项如下表所示。限制项 说明 任务数 单地域总任务数（包括消息流入和消息流出）不超过20个，如果您需要提升创建消息集成的任务数，请 提交工单 申请。任务名称 必须以字母或数字开头，剩余部分可以包含...
订阅者最佳实践
消费失败 云消息队列 Kafka 版 是按分区逐条消息顺序向前推进消费的，如果消费端拿到某条消息后执行消费逻辑失败，例如应用服务器出现了脏数据，导致某条消息处理失败，等待人工干预，那么有以下两种处理方式：失败后一直尝试再次执行消费...
常见问题
本文汇总了使用 云消息队列 RocketMQ 版 时的常见问题。产品功能常见问题 消息队列RocketMQ版5.x系列相比4.x系列实例有什么优势？消息队列RocketMQ版5.x系列实例兼容哪些版本客户端？消息队列RocketMQ版支持哪些语言客户端？消息队列...
查看消费者状态
应用场景 消费者状态信息包括在线状态、订阅关系、消费TPS、消息堆积量和线程堆栈信息等，经常被应用于以下故障排查场景：故障场景 现象 处理建议 订阅关系不一致 在 Group 详情 页面，看到Group ID的 订阅关系 显示 订阅关系不一致，请...
常见问题
本文汇总了使用 云消息队列 RocketMQ 版 时的常见问题。产品功能常见问题 云消息队列 RocketMQ 版5.0系列相比4.0系列实例有什么优势？云消息队列 RocketMQ 版5.0系列实例兼容哪些版本客户端？云消息队列 RocketMQ 版支持哪些语言客户端？云...
从自建MySQL同步至云消息队列 Kafka 版
通过数据传输服务DTS（Data Transmission Service），您可以将自建MySQL同步至 云消息队列 Kafka 版，扩展消息处理能力。前提条件 您已完成以下操作：自建MySQL数据库且数据库版本为5.1、5.5、5.6、5.7或8.0版本。购买并部署 云消息队列 ...
订阅消息
批量消息处理。return Action.CommitMessage;} });启动batchConsumer。batchConsumer.start();System.out.println("Consumer start success.");等待固定时间防止进程退出。try { Thread.sleep(200000);} catch(InterruptedException e){ e....
步骤三：调用SDK收发消息
业务方自行实现消息处理，并主动调用接口返回消费结果。消费并发度管理 由SDK管理消费并发度。由业务方消费逻辑自行管理消费线程。接口灵活度 高度封装，不够灵活。原子接口，可灵活自定义。适用场景 适用于无自定义流程的开发场景。适用于...
收发事务消息
go ConsumeHalfMsg(&mqTransProducer)/发送4条事务消息，1条发送完就提交，其余3条通过检查半事务消息处理。for i:=0;i;i+{ msg:=mq_http_sdk.PublishMessageRequest{ MessageBody:"I am transaction msg!Properties:map[string]string{...
接口和参数说明
本文介绍 云消息队列 MQTT 版 云端Java SDK提供的接口和相关的参数说明。使用说明 公共参数和网络参数可在 ChannelConfig.class 中设置。ChannelConfig.class 路径为 server-sdk-{SDK Version}\com\alibaba\mqtt\server\config ，其中 {SDK...
调用TCP协议的SDK收发普通消息
class MyMsgListener:public MessageListener { public:MyMsgListener(){ } virtual~MyMsgListener(){ } virtual Action consume(Message&message,ConsumeContext&context){/自定义消息处理细节。return CommitMessage;CONSUME_SUCCESS;} }...
查看系统消息
本文为您介绍如何查看并处理消息中心的消息。查看消息中心的消息 在Dataphin界面，按照下图操作指引，进入 消息中心。在 消息中心 页面，您可以查看所有未读消息及全部的消息。同时您可以单击某个消息 操作 列下的 图标查看消息的详细内容...
查看系统消息
本文为您介绍如何查看并处理消息中心的消息。查看消息中心的消息 在Dataphin界面，按照下图操作指引，进入 消息中心。在 消息中心 页面，您可以查看所有未读消息及全部的消息。同时您可以单击某个消息 操作 列下的 图标查看消息的详细内容...
广播拉取消息模型
本文介绍如何高效利用该模型实现多消费者并行拉取与处理消息。说明 本文以Java SDK为例介绍广播拉取消息流程，其他语言SDK请参见 新版SDK参考（推荐）。前提条件 安装IDEA 您可以使用IntelliJ IDEA或者Eclipse，本文以IntelliJ IDEA为例。...
消息收发计算规格费用
计算规格说明 计算规格能力约束 消息收发TPS 云消息队列 RocketMQ 版 计算规格的大小，实际是 云消息队列 RocketMQ 版 处理消息收发的TPS上限。不同的规格对应不同的TPS上限，具体对应关系，请参见 实例规格。其他资源配额 每个实例规格除...
消息收发功能
系统消息推送：消息发送端为云端业务应用，消费端为终端设备。例如，部署在云端的某游戏应用发送一条停服更新的通告，云消息队列 MQTT 版 服务端将该通告推送至所有下载该游戏的手机终端上，通过手机消息提示给所有游戏用户。消息接收：...
产品功能
消息队列分布式事务 在多次调用消息系统的场景中，通过 GTS，应用可轻松具备消息事务的处理能力。混合的分布式事务 GTS 可将各个资源加入事务范畴，实现同时跨服务、数据库、跨消息系统的事务处理能力。多种事务模式 提供了标准事务模式、...
- 产品推荐
- 这些文档可能帮助您