消息处理时长自适应
本文介绍如何使消息处理时长自适应。背景信息 消息服务MNS 的规范中，每条消息都有个默认的VisibilityTimeout，Worker在接收到消息后，Timeout就开始计时了。如果Worker在Timeout时间内没能处理完消息，那么消息就有可能被其他Worker接收到...
如何处理消息堆积
问题现象 在使用 云消息队列 RocketMQ 版 实例时收到消息堆积告警，登录 云消息队列 RocketMQ 版 控制台 后发现了下列现象：在 Group 详情 页面，看到Group ID的 实时消息堆积量 的值高于预期。导航栏中选择 消息轨迹，单击 创建查询任务，...
本地IDC通过专线使用消息队列RocketMQ版处理消息
本文为您介绍本地IDC如何通过物理专线访问云上消息队列RocketMQ版，实现本地IDC使用消息队列RocketMQ版收发并处理消息。背景信息 本文以下图场景为例，某企业在阿里云华北2（北京）地域部署了专有网络VPC（Virtual Private Cloud）和交换机...
异步任务MNS消息处理示例
本文介绍如何通过消息服务MNS获取IMM异步任务的执行状态消息。创建MNS相关资源 步骤一：创建MNS主题 登录 消息服务MNS管理控制台。在左侧导航栏选择 主题列表，并单击 创建主题。在 创建主题 面板设置主题的相关信息，并单击 确定，如下以...
在onNotification/onMessage中处理消息回调时不能创建...
问题详述 Android SDK 中继承了MessageReceiver后，为什么在onNotification/onMessage中处理消息回调时不能创建Dialog弹窗？继承MessageReceiver创建了自定义Receiver，也能成功接收到推送，onNotification（或onMessage）回调也被成功调用...
处理告警消息
本文介绍了如何处理告警消息。前提条件 监控任务配置了对应的告警级别和告警分组，具体操作，请参见 手动创建监控任务、批量创建监控任务。在告警订阅配置中创建了对应告警分组的监控订阅信息，当前时间必须在订阅的有效期内，具体操作，请...
处理告警消息
本文介绍了如何处理告警消息。前提条件 监控任务配置了对应的告警级别和告警分组，具体操作，请参见 手动创建监控任务、批量创建监控任务。在告警订阅配置中创建了对应告警分组的监控订阅信息，当前时间必须在订阅的有效期内，具体操作，请...
推送消息的时候设备离线怎么处理
问题描述 设备离线时推送消息无法送达设备。解决方案 配置离线保存参数StoreOffline：离线消息/通知是否保存。StoreOffline默认设置为 false。若保存，在推送时候用户不在线，在过期时间（ExpireTime）内用户上线时会被再次发送。配置离线...
对于较长时间没有任何消息的队列，会如何处理？
本文介绍对于较长时间没有任何消息的队列，阿里云会如何处理的问题。在您正常使用 消息服务MNS 服务期间，阿里云不会对非活跃的队列或主题进行删除操作。但是，如果您的 消息服务MNS 使用权限因为欠费或其他原因被停止了，那么阿里云将删除...
消息堆积
常见的消息堆积相关问题如下：如何处理消息堆积？除了异步解耦功能，消息队列还有挡住前端数据洪峰的重要功能，以此保证后端系统的稳定性。这要求消息队列具有一定的消息堆积能力。消息队列能支持 10 亿级别的消息堆积，不会因为消息堆积...
消息堆积和延迟问题
背景信息 消息处理流程中，如果客户端的消费速度跟不上服务端的发送速度，未处理的消息会越来越多，这部分消息就被称为堆积消息。消息出现堆积进而会造成消息消费延迟。以下场景需要重点关注消息堆积和延迟的问题：业务系统上下游能力不...
通过可观测性能力进行故障处理最佳实践
消息处理成功率=消息处理成功次数/消息处理失败次数+成功次数。查询方式，请查看 仪表盘 中，消费者指标下的统计面板。根据业务逻辑或指标的变化趋势定位具体原因，例如消息处理耗时变长，则可以查看消费者服务的内存、CPU等是否过载；或...
消息通知功能说明
激活媒体处理消息通知功能。启用媒体处理消息通知功能步骤 激活媒体处理消息通知功能。媒体处理通过MNS实现转码作业及模板分析作业结束时的消息通知功能，因此激活此功能请先 开通MNS服务。创建MNS通知主题。登录 MNS控制台（选择与媒体...
使用Canal和RocketMQ实现数据库变更订阅处理
Canal可以将变更记录可靠地投递到 云消息队列 RocketMQ 版 中，借助 云消息队列 RocketMQ 版 丰富的消息处理策略实现多样化的业务逻辑。Canal是一个开源项目，仓库地址请参见 Canal。方案介绍 基于Binlog日志实现增量订阅和消费的典型业务...
使用Canal和RocketMQ实现数据库变更订阅处理
Canal可以将变更记录可靠地投递到 云消息队列 RocketMQ 版 中，借助 云消息队列 RocketMQ 版 丰富的消息处理策略实现多样化的业务逻辑。Canal是一个开源项目，仓库地址请参见 Canal。方案介绍 基于Binlog日志实现增量订阅和消费的典型业务...
查看系统消息
本文为您介绍如何查看并处理消息中心的消息。查看消息中心的消息 在Dataphin界面，按照下图操作指引，进入 消息中心。在 消息中心 页面，您可以查看所有未读消息及全部的消息。同时您可以单击某个消息 操作 列下的 图标查看消息的详细内容...
云产品流转
在 数据流转规 则页单击 编写SQL，编写处理消息字段的SQL。SQL编写方法，可参见 SQL表达式 和 函数列表。本案例中按如下图所示编写SQL，然后单击 确认。调试SQL 编写SQL后，单击 SQL调试。在SQL调试对话框的调试参数页签下，输入用于调试...
捷旅假期
因此捷旅平台期望具备以下优势，缓解并发处理消息的压力。并发处理能力：同时处理超过10万条的峰值消息。弹缩处理能力：根据消息量的多少进行自动化毫秒级的扩缩容操作，使用成本按所需的实际资源付费。支持多种触发方式：支持对象存储服务...
设置消息通知
设置单任务消息通知 设置工作流消息通知 步骤一、开通消息服务MNS 重要 媒体处理的消息通知是绑定MNS产品推送的，媒体处理侧不产生费用，但是会产生MNS费用。计费详情请参见 价格说明。开通消息服务MNS并授权。详细操作请参见 开通消息服务...
消息幂等
消息重复的可能原因如下：发送时消息重复 当一条消息已被成功发送到服务端并完成持久化，此时出现了网络闪断或者客户端宕机，导致服务端对客户端应答失败。如果此时Producer意识到消息发送失败并尝试再次发送消息，Consumer后续会收到两条...
消费者分类
SimpleConsumer适用于以下场景：消息处理时长不可控：如果消息处理时长无法预估，经常有长时间耗时的消息处理情况。建议使用SimpleConsumer消费类型，可以在消费时自定义消息的预估处理时长，若实际业务中预估的消息处理时长不符合预期，也...
消息幂等
处理方法 因为 Message ID 有可能出现冲突（重复）的情况，所以真正安全的幂等处理，不建议以 Message ID 作为处理依据。最好的方式是以业务唯一标识作为幂等处理的关键依据，而业务的唯一标识可以通过消息 Key 设置。以支付场景为例，可以...
消费端挂载NFS是否会影响消费速度？
问题现象 消费端在消费消息的主线程里同步将拉取的消息存储在NFS，导致消费端处理消息的速度变慢，阻塞消息处理。可能原因 NFS本身速度就不太理想。NFS是网络共享存储，虽然有多机器共享访问的能力优势，但多台机器访问是争抢的，消费者...
消费重试
例如，您预设消息处理耗时最多20 ms，但实际业务中20 ms内消息处理不完，您可以修改消息不可见时间，延长消息处理时间，避免消息触发重试机制。修改消息不可见时间需要满足以下条件：消息处理未超时 消息处理未提交消费状态 如下图所示，...
消息超时和重试机制
本文介绍 云消息队列 RabbitMQ 版 服务端默认的消息重试机制，帮助您理解消费失败后的消息处理逻辑，并选择合适的消息处理策略。重试机制 云消息队列 RabbitMQ 版 服务端有默认的消息重试机制，不支持您在Consumer客户端重新配置消息重试...
消息轨迹
按消息处理耗时：在 按消息处理耗时 页签中，选择要查询消息的Queue，输入消息处理耗时时间（单位为秒），设置查询 时间范围，然后单击 查询。在查询的消息列表，选择要查询消息轨迹的消息，在其 操作 列，单击 轨迹详情。在消息轨迹详情...
监控报警
监控项说明 说明 消息堆积量、消息处理延迟时间、已就绪消息量、已就绪消息排队时间等消息堆积场景相关的指标的详细说明，请参见 堆积场景指标说明。指标分类 监控指标 MetricName 统计方法 单位 Instance 实例API调用TPS InstanceApi...
CreateUpstreamAppServer
调用CreateUpstreamAppServer创建处理上行消息的服务端应用。说明 根据名称、业务消息过滤标签、项目工程ID创建服务端应用。调试 您可以在OpenAPI Explorer中直接运行该接口，免去您计算签名的困扰。运行成功后，OpenAPI Explorer可以自动...
应用场景
其高性能的消息处理能力可以承接流量脉冲而不被击垮，在确保系统可用性的同时，通过快速有效的请求响应技术提升用户体验。其海量消息堆积能力确保下游业务在安全水位内平滑稳定地运行，避免流量高峰的冲击。分布式缓存同步 大量并发访问...
消息服务MNS中删除消息时报“message not exist”的...
本文介绍了当MNS删除消息时返回“message not exist”的问题描述、问题原因和解决方案。问题描述 消息服务MNS中删除消息时报如下错误。...如果 VisibilityTimeout 设置得太大，当消息处理失败时，将不能在短时间内再次处理该条消息。
徽标数
使用场景 徽标数 一般出现在通知图标或头像的右上角，用于显示需要处理的消息条数，通过醒目视觉形式吸引您处理。在有新消息、讯息时，或者是app、插件、功能模块可以更新、升级时使用 徽标数。使用说明 绑定变量类型需为Integer类型。徽标...
通知点击处理
自定义消息处理 如需处理消息，可以重写 MPPushMsgServiceAdapter 的 onMessageReceive 和 onChannelMessageClick 方法：public class MyPushMsgService extends MPPushMsgServiceAdapter {/*自建通道收到消息的回调（非厂商通道）*@param ...
消息重试
受消费者处理速度的影响，到第5 s时才开始拉取消息消费，6 s后消息处理异常客户端返回消费失败。此时还不能进行消费重试，需要等待重试间隔后才能开始再次消费。等到第21 s时消息再次变为已就绪状态。5 s后客户端才再次开始重新消费消息。...
队列使用手册
并且在消息处理过程中，也可以调用changeMessageVisibility这个函数来延长消息的VisibilityTimeout时间。Console.WriteLine("DeleteMessage Failed!ErrorCode:"+me.ErrorCode);} catch(Exception ex){ Console.WriteLine("Delete message ...
仪表盘
业务背景 云消息队列 RocketMQ 版 的消息收发流程中，队列的堆积情况、缓冲情况以及消息处理各关节的耗时等，会直接反映当前业务处理的性能和服务端运行的状态。因此，云消息队列 RocketMQ 版 的重点指标主要涉及以下业务场景。消息堆积...
死信消息
应用场景 典型死信消息处理场景 消息重试失败后，您可以选择将死信消息存储到指定的死信Topic中，通过另外创建一个ConsumerGroup消费这些死信消息来处理异常链路或分析死信消息。典型错误使用死信消息场景 处理死信消息时，如果将死信消息...
监控报警
监控项 单位 MetricName Dimensions Statistics 消息堆积量（Group）count ConsumerLag userId、instanceId、groupId Sum 消息处理延迟时间（GroupId）millisecond ConsumerLagLatencyPerGid userId、instanceId、groupId Maximum 消息处理...
队列使用手册
并且在消息处理过程中，也可以调用changeMessageVisibility这个函数来延长消息的VisibilityTimeout时间。echo"DeleteMessage Failed:".$e;return;} 步骤五：删除队列 Sample里最后会删除这个测试队列。try {$this->client->deleteQueue($...
内容分割
本文介绍如何使用数据清洗功能中的内容分割模板处理消息数据。背景信息 数据清洗功能提供常见的消息处理模板，包括内容分割、动态路由、内容富化和内容映射等。您可以直接利用模板处理消息，也可以根据业务情况在模板基础上修改代码。消息...
内容映射
本文介绍如何使用数据清洗功能中的内容映射模板处理消息数据。背景信息 数据清洗功能提供常见的消息处理模板，包括内容分割、动态路由、内容富化和内容映射等。您可以直接利用模板处理消息，也可以根据业务情况在模板基础上修改代码。消息...
- 产品推荐
- 这些文档可能帮助您