通过可观测性能力进行故障处理最佳实践
消息处理成功率=消息处理成功次数/消息处理失败次数+成功次数。查询方式，请查看 仪表盘 中，消费者指标下的统计面板。根据业务逻辑或指标的变化趋势定位具体原因，例如消息处理耗时变长，则可以查看消费者服务的内存、CPU等是否过载；或...
配置生命周期挂钩
生命周期挂钩可以暂停由弹性伸缩自动触发的伸缩活动，使ECS实例或ECI实例处于挂起中的状态（即等待的状态），为您保留一段自定义操作的时间以满足特定的部署需求和业务场景，例如预装软件等。直至生命周期挂钩超时结束后，弹性伸缩的伸缩...
告警功能配置及使用
告警功能配置 以下为白屏化配置告警通道的操作：告警通道选择 进入 系统管理-消息通道 页面，目前提供钉钉机器人以及邮件两种告警方式进行配置。配置钉钉机器人/邮件告警 钉钉机器人告警 进入配置页面，您需要输入机器人名称、Webhook以及...
应用场景
前端的监控系统和大数据处理系统会利用 TSDB 的数据查询和计算分析能力进行业务监控和分析结果的实时展现。电力化工及工业制造监控分析 传统电力化工以及工业制造行业需要通过实时的监控系统进行设备状态检测，故障发现以及业务趋势分析。...
消息负载均衡策略
则每台机器会处理多个Queue上的消息，如下图所示：因为消费者负载均衡策略是以Queue为粒度维护，如果消费者集群中一台机器处理变慢，可能是机器硬件、系统、远程RPC调用或Java GC等原因导致分配至此机器上的Queue的消息不能及时处理，则...
基本概念
Sharding Key 是顺序消息中用来区分不同分区的关键字段，和普通消息的 Message Key 是完全不同的概念。详情请参见 消息类型>顺序消息。分布式事务 distributed transaction，事务的发起者、资源及资源管理器和事务协调者分别位于不同的分布...
话单错误码
99 发送此原因的设备收到了包含未识别的信息元素或参数的消息，因为该信息元素或参数名称未定义或已定义但未由设备实现。网络问题导致用户未接续成功。100 发送此原因代码的设备已经接收到它已经实现的IE而，发送此原因代码的设备没有实现...
云产品流转概述
同一条消息的消息ID相同，您可根据消息ID去重。无 使用指南 设置数据流转规则：如何设置一条数据转发规则。SQL表达式：规则中SQL表达式的写法详解。函数列表：规则中SQL表达式支持的函数列表。数据流转过程：进行数据流转的过程和各阶段的...
消息负载均衡策略
如果其中一台机器处理变慢，可能是机器硬件、系统、远程 RPC 调用或 Java GC 等原因导致分配至此机器上的 Queue 的消息不能及时处理；此外，消息队列的消息负载是按 Queue 为粒度维护，所以，整个 Queue 上的消息都会堆积。
消费端挂载NFS是否会影响消费速度？
问题现象 消费端在消费消息的主线程里同步将拉取的消息存储在NFS，导致消费端处理消息的速度变慢，阻塞消息处理。可能原因 NFS本身速度就不太理想。NFS是网络共享存储，虽然有多机器共享访问的能力优势，但多台机器访问是争抢的，消费者...
主题（Topic）
行为约束 消息类型强制校验 云消息队列 RocketMQ 版 5.x版本将消息类型拆分到主题中进行独立运维和处理，因此系统会对发送的消息类型和主题定的消息类型进行强制校验，若校验不通过，则消息发送请求会被拒绝，并返回类型不匹配异常。...
新零售电子价签解决方案（MQTT）
电子价签管控服务通过接收 云消息队列 RocketMQ 版 消息，处理分析当前系统中在线的价签节点的状态，并将数据记录到SLS。更新屏显 电子价签管控服务发送改价的 云消息队列 RocketMQ 版 消息，触发改价操作。MQTT服务端会路由该 云消息队列 ...
处理挖矿程序最佳实践
服务器被挖矿病毒入侵后，挖矿病毒会消耗服务器的资源、降低生产效率、影响系统稳定性，对受感染的个人或企业用户构成严重的威胁。被入侵后，您需要及时响应并处理挖矿病毒，加固系统安全。本文介绍如何处理挖矿病毒。背景信息 挖矿程序的...
消费者分类
建议使用SimpleConsumer消费类型，可以在消费时自定义消息的预估处理时长，若实际业务中预估的消息处理时长不符合预期，也可以通过接口提前修改。需要异步化、批量消费等高级定制场景：SimpleConsumer在SDK内部没有复杂的线程封装，完全由...
强弱依赖治理概述
强弱依赖治理的应用 强弱依赖治理主要可以被应用到以下场景：系统改造验收：对于分布式系统，至少在运行态中，不会因为依赖的系统后台出现故障，引起当前应用出现系统级可用性的故障，例如进程挂掉、频繁FullGC、负载飙高等，何时何地都应...
消费重试
由于不可见时间为预分配的，可能和实际业务中的消息处理时间差别较大，您可以通过API接口修改不可见时间。例如，您预设消息处理耗时最多20 ms，但实际业务中20 ms内消息处理不完，您可以修改消息不可见时间，延长消息处理时间，避免消息...
iOS端推送消息失败的排查步骤
推送系统只负责消息的送达，需要用户自行处理消息数据并根据需求做展示。可参考下 官网 Demo 对消息处理的方式。消息接收监听，需在通知中心注册事件名为 CCPDidReceiveMessageNotification 的广播监听，具体参考：iOS API 介绍。iOS 消息...
配额与限制
消费不可见时间指的是消息处理+失败后重试间隔的总时长，建议设置时取值比实际需要耗费的时间稍微长一些。消费者长轮询超时时间 取值范围：最小值5秒，最大值20秒。支持用户在取值范围内自定义调整。设置长轮询超时时间后，如果当前服务端...
订阅关系（Subscription）
定义 订阅关系是 云消息队列 RocketMQ 版 系统中消费者获取消息、处理消息的规则和状态配置。订阅关系由消费者分组动态注册到服务端系统，并在后续的消息传输中按照订阅关系定义的过滤规则进行消息匹配和消费进度维护。通过配置订阅关系，...
消息服务MNS中删除消息时报“message not exist”的...
message not exist 问题原因 VisibilityTimeout 到期，该消息的ReceiptHandle失效，导致消息删除失败。详细过程如下：当消息被消费端接收，消息状态从active变为inactive。inactive状态将持续 VisibilityTimeout 的时间。在这段时间里，...
查看系统消息
本文为您介绍如何查看并处理消息中心的消息。查看消息中心的消息 在Dataphin界面，按照下图操作指引，进入 消息中心。在 消息中心 页面，您可以查看所有未读消息及全部的消息。同时您可以单击某个消息 操作 列下的 图标查看消息的详细内容...
查看系统消息
本文为您介绍如何查看并处理消息中心的消息。查看消息中心的消息 在Dataphin界面，按照下图操作指引，进入 消息中心。在 消息中心 页面，您可以查看所有未读消息及全部的消息。同时您可以单击某个消息 操作 列下的 图标查看消息的详细内容...
消费幂等
处理方法 因为不同的Message ID对应的消息内容可能相同，有可能出现冲突（重复）的情况，所以真正安全的幂等处理，不建议以Message ID作为处理依据。最好的方式是以业务唯一标识作为幂等处理的关键依据，而业务的唯一标识可以通过消息Key...
订阅者最佳实践
云消息队列 Kafka 版 没有处理失败消息的设计，实践中通常会打印失败的消息或者存储到某个服务（例如创建一个Topic专门用来放失败的消息），然后定时检查失败消息的情况，分析失败原因，根据情况处理。消费延迟 云消息队列 Kafka 版 的消费...
事务消息
事务消息为 云消息队列 RocketMQ 版 中的高级特性消息，本文为您介绍事务消息的应用场景、功能原理、使用限制、使用方法和使用建议。应用场景 分布式事务的诉求 分布式系统调用的特点为一个核心业务逻辑的执行，同时需要调用多个下游业务...
通过ARMS告警大盘提高告警处理效率
背景信息 企业在处理系统告警时，经常会遇到以下痛点：如何查看过去一段时间系统发生了哪些告警，哪类告警占比较高。告警配置没有收敛，多人在多个系统配置了多个告警。如何只查看我关心的告警以及对应的处理情况。制定了值班机制，无法...
现代IM系统中的消息系统—架构
本章节主要介绍现代IM系统中的消息系统架构以及基于表格存储（Tablestore）自研的Timeline模型构建的消息系统。基于Timeline构建的现代消息系统能够同时支持消息系统的多种特性，包括多端同步、消息漫游和在线检索，在性能和规模上能够实现...
产品架构
本文介绍 SOFAStack 消息队列的系统部署架构，方便您更好地理解消息队列的高可用性。消息队列在任何一个环境都是可扩展的，生产者必须是一个集群，消息服务器必须是一个集群，消费者也同样。集群级别的高可用，是消息队列跟其他的消息...
消息收发计算规格费用
计算规格说明 计算规格能力约束 消息收发TPS 云消息队列 RocketMQ 版 计算规格的大小，实际是 云消息队列 RocketMQ 版 处理消息收发的TPS上限。不同的规格对应不同的TPS上限，具体对应关系，请参见 实例规格。其他资源配额 每个实例规格除...
收发顺序消息
顺序消息FIFO（First In First Out）是 云消息队列 RocketMQ 版 提供的一种严格按照顺序来发布和消费的消息类型。本文提供使用TCP协议下的C/C++ SDK收发顺序消息的示例代码。背景信息 顺序消息分为两类：全局顺序：对于指定的一个Topic，...
顺序消息
顺序消息为 云消息队列 RocketMQ 版 中的高级特性消息，本文为您介绍顺序消息的应用场景、功能原理、使用限制、使用方法和使用建议。应用场景 在有序事件处理、撮合交易、数据实时增量同步等场景下，异构系统间需要维持强一致的状态同步，...
消费者负载均衡
只需要基本的消息处理能力，对消息之间没有批量聚合的诉求。而对于流式处理、聚合计算场景，需要明确地对消息进行聚合、批处理时，更适合使用队列粒度的负载均衡策略。使用示例 消息粒度负载均衡策略不需要额外设置，对于PushConsumer和...
MNS可以做什么？
本文介绍 消息服务MNS 的典型使用场景。典型的使用场景如下：将 消息服务MNS 与其他阿里云...将业务流程中重要事件的通知保存在 消息服务MNS 中，每个事件在队列中都有一条对应的消息，需要知晓该事件的应用程序可以读取和处理对应的消息。
MQ订阅消息
通过MQ订阅系统消息格式说明。消息定义 消息体 字段 类型 说明 EventCatgory String 事件分类，取值范围："DEVICE"：设备事件"BIZ":业务事件 Event String 事件说明："DEVICE_OFFLINE":设备下线"DEVICE_PROPERTY"：设备属性变更"BIZ_...
实例规格
3天 SQL属性过滤 以SQL表达式的方式对消息属性内容进行精确过滤，使消息的订阅处理更加高效。SQL属性过滤，请参见 消息过滤。不支持 数据传输加密 支持SSL/TLS数据传输加密，但需要配合SDK版本为Java ons-client-2.x.x的客户端使用。SDK...
定时/延时消息
因此，如果将大量定时消息的定时时间设置为同一时刻，则到达该时刻后会有大量消息同时需要被处理，会造成系统压力过大，导致消息分发延迟，影响定时精度。定时/延时消息常见问题 定时消息在定时时间到达前可以撤回或修改定时时间吗？不支持...
消息堆积和延迟问题
背景信息 消息处理流程中，如果客户端的消费速度跟不上服务端的发送速度，未处理的消息会越来越多，这部分消息就被称为堆积消息。消息出现堆积进而会造成消息消费延迟。以下场景需要重点关注消息堆积和延迟的问题：业务系统上下游能力不...
ExchangeHasDiffFields
介绍 云消息队列 RabbitMQ 版 客户端报ExchangeHasDiffFields类型错误的原因和处理方法。问题现象 使用 云消息队列 RabbitMQ 版 客户端连接 云消息队列 RabbitMQ 版 服务端时，报ExchangeHasDiffFields类型错误。例如ExchangeHasDiffFields...
普通消息
应用场景 普通消息一般应用于微服务解耦、事件驱动、数据集成等场景，这些场景大多数要求数据传输通道具有可靠传输的能力，且对消息的处理时机、处理顺序没有特别要求。典型场景一：微服务异步解耦 如上图所示，以在线的电商交易场景为例，...
QueueHasDiffField
本文为您介绍 云消息队列 RabbitMQ 版 客户端报QueueHasDiffField类型错误的原因和处理方法。问题现象 使用 云消息队列 RabbitMQ 版 客户端连接 云消息队列 RabbitMQ 版 服务端时，报QueueHasDiffField类型错误。例如QueueHasDiffField...
- 产品推荐
- 这些文档可能帮助您