什么是消息演练
定位故障根源：经过消息演练之后，积累了消息系统的处理经验，对于未来的系统诊断定位有参考和提升作用。消息的演练场景 消息服务通常是由不同的模块组成。例如，RocketMQ分为生产者Producer、消费者Consumer、服务集群Broker和注册中心...
ECS系统事件汇总
您可以通过系统事件获取ECS资源的风险和异常信息，例如 某一实例到期、实例因底层升级需迁移或因系统维护重启了某一实例等，然后及时响应和处理系统事件，避免因ECS资源可用性或性能受损而影响业务。本文汇总了云服务器ECS支持的系统事件...
产品功能
消息队列分布式事务 在多次调用消息系统的场景中，通过 GTS，应用可轻松具备消息事务的处理能力。混合的分布式事务 GTS 可将各个资源加入事务范畴，实现同时跨服务、数据库、跨消息系统的事务处理能力。多种事务模式 提供了标准事务模式、...
消息处理时长自适应
本文介绍如何使消息处理时长自适应。背景信息 消息服务MNS 的规范中，每条消息都有个默认的VisibilityTimeout，Worker在接收到消息后，Timeout就开始计时了。如果Worker在Timeout时间内没能处理完消息，那么消息就有可能被其他Worker接收到...
Exactly-Once投递语义
例如，当您的消费端完成一条消息的消费处理后出现异常宕机，而消费端重启后由于消费的位点没有同步到消息系统的服务端，该消息有可能被重复消费。业界对于Exactly-Once投递语义存在很大的争议，很多人会拿出“FLP不可能理论”或者其他一致...
产品优势
核心消息处理系统采用无状态架构，无单点依赖，消息发送失败可自动重试。架构上难以支持万级的消息规模，消息上下行并发会给系统带来巨大的冲击。无法做到削峰填谷，影响高峰时正常业务运行。安全性 等保2.0版（三级等保），提供多重防护，...
配额与限制
消费不可见时间指的是消息处理+失败后重试间隔的总时长，建议设置时取值比实际需要耗费的时间稍微长一些。消费者长轮询超时时间 取值范围：最小值5秒，最大值20秒。支持用户在取值范围内自定义调整。设置长轮询超时时间后，如果当前服务端...
查询和响应ECS系统事件
本文介绍如何通过ECS控制台、阿里云CLI查询和响应ECS系统事件。背景信息 除了通过ECS控制台等方式查询和响应ECS系统事件外，您还可以通过云监控查询包括ECS在内的多款产品的系统事件，并为关注的系统事件设置事件通知。具体操作，请参见 ...
消息幂等
负载均衡时消息重复（包括但不限于网络抖动、服务端重启以及Consumer应用重启）当 云消息队列 RabbitMQ 版 的服务端或客户端重启、扩容或缩容时，会触发Rebalance，此时Consumer可能会收到重复消息。处理方法 以Message ID为幂等键对消息...
集群消费和广播消费
集群消费和广播消费是 云消息队列 RocketMQ 版 的基本消费模式，您可以在消费者客户端将消费模式设置为集群消费或者广播消费，用于控制同一条消息只能被集群内一个消费者消费到，还是会被集群内每个消费者都消费到。背景信息 云消息队列 ...
消费幂等
负载均衡时消息重复（包括但不限于网络抖动、Broker重启以及消费者应用重启）当 消息队列RocketMQ版 的Broker或客户端重启、扩容或缩容时，会触发Rebalance，此时消费者可能会收到少量重复消息。处理方法 因为不同的Message ID对应的消息...
ECS系统事件概述
应用场景 通知风险和异常 针对未在ECS控制台展示的系统事件（包括影响ECS资源可用性和造成性能受损的系统事件），例如因系统维护重启实例等运维事件、实例到期等费用预警事件，阿里云会将系统事件推送至ECS控制台展示，部分高危事件还会...
事务消息
事务消息处理流程 事务消息交互流程如下图所示。生产者将消息发送至 云消息队列 RocketMQ 版 服务端。云消息队列 RocketMQ 版 服务端将消息持久化成功之后，向生产者返回Ack确认消息已经发送成功，此时消息被标记为“暂不能投递”，这种...
事务消息
消息回查：由于网络闪断、生产者应用重启等原因，导致某条事务消息的二次确认丢失，云消息队列 RocketMQ 版 服务端通过扫描发现某条消息长期处于“半事务消息”时，需要主动向消息生产者询问该消息的最终状态（Commit或是Rollback），该...
消息幂等
当消息队列的 Broker 或客户端重启、扩容或缩容时，会触发 Rebalance，此时消费者可能会收到重复消息。处理方法 因为 Message ID 有可能出现冲突（重复）的情况，所以真正安全的幂等处理，不建议以 Message ID 作为处理依据。最好的方式是...
迁移上云概述
消息收发无大量重复 保证迁移过程中不会出现大量的消息重复，业务方无需为迁移方案单独处理系统性重复消息。消息收发无明显延迟 保证迁移过程中消息收发端到端延迟不会有明显变化，不会因迁移导致大量消息接收不到。方案设计原理 为满足...
名词解释
即如果消息重试多次，消费端对该重复消息消费多次与消费一次的结果是相同的，并且多次消费没有对系统产生副作用，在为每条消息设置唯一Message ID的基础上，您还需要在 云消息队列 RabbitMQ 版 的Consumer客户端对消息进行幂等处理，具体...
防勒索日常操作指引
为了应对不断演变的安全威胁和不确定的攻击行为，您需要持续关注勒索防护备份策略的执行状态，及时处理系统中存在的安全告警和漏洞，加固系统安全防线。本文介绍防御勒索病毒的实用操作指南，帮助您有效防范勒索病毒侵害，降低潜在的勒索...
Multi-Master关键技术介绍
本文对Multi-Master架构的关键技术点进行介绍，包括分布式事务处理、全局死锁处理、DDL支持、分布式表锁支持、集群容错和高可用能力。分布式事务管理 AnalyticDB PostgreSQL版 分布式事务 AnalyticDB PostgreSQL版 通过二阶段提交协议（2PC...
消息类型
消息回查：由于网络闪断、生产者应用重启等原因，导致某条事务消息的二次确认丢失，消息队列服务端通过扫描发现某条消息长期处于“半事务消息”时，需要主动向消息生产者询问该消息的最终状态（Commit 或 Rollback），该询问过程即消息回查...
消息发送重试和流控机制
消息重复问题：因远程调用的不确定性，当 云消息队列 RocketMQ 版 客户端因请求超时触发消息发送重试流程，此时客户端无法感知服务端的处理结果，客户端进行的消息发送重试可能会产生消息重复问题，业务逻辑需要自行处理消息重复问题。...
ECS主机状态变化事件的自动化运维
操作步骤 云监控将ECS主机所有的状态变化事件投递到消息服务MNS，消息服务MNS获取消息并进行消息处理。实践一：对所有ECS主机的创建和释放事件进行记录。目前ECS控制台无法查询已经释放的实例。如果您有查询需求，可以通过ECS主机状态变化...
日志管理
本案例要查询某个客户端消息处理量，即输入客户端IP地址，查询语句格式为$ClientIP，例如 10.10.10.0。如果您要查询某个客户端的某类操作日志，可使用多个关键字组合方式，例如$ClientIP and(SendMessage or BatchSendMessage)。查询结果...
自定义配置
信息脱敏设置 在 信息脱敏设置 区域，通过设置脱敏规则，探针将对JVM系统参数、K8s Yaml、方法入参、Arthas环境变量和系统变量等内容在采集时就进行脱敏处理。脱敏规则中各元素通过英文半角逗号分隔，每一个元素代表一个不区分大小写的正则...
Windows客户端和macOS客户端
无 新增 新增消息中心 云电脑内新增 消息中心，您可接收到 管控消息、系统消息 和 协同消息 三类消息；其中包含可交互式消息，如您可预约镜像更新时间，可跳过执行当天的管理员定时任务。此外还可查询和管理历史消息。查看消息 新增 悬浮球...
测试指标
简称 Virtual User：VU 标准 一般情况下，性能测试是将系统处理能力容量测出来，而不是测试并发用户数，除了服务器长连接可能影响并发用户数外，系统处理能力不受并发用户数影响，可以用最小的用户数将系统处理能力容量测试出来，也可以用...
管理事件订阅（推荐）
您可以通过事件订阅，对报警通知进行定制化处理，例如：订阅系统事件或阈值事件、对报警进行合并降噪、升级报警联系组、自定义报警通知方式、将报警按照数据模板（JSON格式）推送至目标渠道。背景信息 通过事件订阅您可以实现以下功能：...
基本概念
Apache Kafka 一款开源的分布式数据流处理平台，可以实时发布、订阅、存储和处理数据流。更多信息，请参见 Apache Kafka。云消息队列 Kafka 版 一款由阿里云提供的Apache Kafka全托管服务，具备免部署、免运维、低成本、高弹性、高可靠、高...
将云消息队列 Kafka 版接入阿里云Elasticsearch
随着时间的积累，云消息队列 Kafka 版 中的日志数据会越来越多。当您需要查看并分析庞杂的日志数据时，可通过阿里云Logstash将 云消息队列 Kafka 版 中的日志数据导入阿里云Elasticsearch，然后通过Kibana进行可视化展示与分析。本文介绍将...
Android 客户端诊断
使用消息推送通道 排查步骤如下：进入 mPaaS 控制台>消息推送 页面，根据 userId 推送一条普通的消息到您的 App，确认消息推送通道畅通。在消息推送通道畅通的情况下，先清空 logcat 日志，切换到 push 进程，然后在控制台诊断任务中再次...
配置自动调优
说明 VVR 8.0.1及以上版本，Flink系统会先尝试使用动态参数更新重启作业，再尝试使用作业整体重启。动态参数更新下业务中断时间较之作业整体重启缩小30%-98%，具体依赖于作业状态和逻辑，目前仅支持并发的修改。详情请参见 动态更新作业...
获取MQTT客户端在线状态
您可通过调用同步查询接口或使用异步上下线通知的方式获取 云消息队列 MQTT 版 客户端（下文简称为客户端）当前在线情况。应用场景 云消息队列 MQTT 版 需结合后端存储消息队列产品，如 云消息队列 RocketMQ 版 等使用，来和部署在云端...
阿里云Elasticsearch实例FAQ
本文列举了阿里云Elasticsearch（ES）相关的常见问题，包括购买、退订、配置、访问、查询、写入、插件、分词、日志、重启、负载或状态异常、备份与恢复、监控报警等相关问题。常见问题概览 购买或退订实例问题 购买ES实例时选错配置，如何...
使用Exactly-Once投递语义收发消息
云消息队列 RocketMQ 版 的Exactly-Once投递语义适用于接收消息>处理消息>结果持久化到数据库的流程，能够保证您的每一条消息消费的最终处理结果写入到您的数据库有且仅有一次，保证消息消费的幂等。更多Exactly-Once投递语义的概念和典型...
常见问题
本文汇总了接入及使用消息推送组件的过程中经常出现的一些问题及其解决方法。通用问题 关于权限的说明 Android 6.0 后，需要用户手动授予手机权限，如读写 SD 卡。为了更加精准的发送推送，建议开发者引导获取消息推送所需权限。日志无法...
消息推送常见问题
本文汇总了接入及使用消息推送组件的过程中经常出现的一些问题及其解决方法。通用问题 关于权限的说明 Android 6.0 后，需要用户手动授予手机权限，如读写 SD 卡。为了更加精准的发送推送，建议开发者引导获取消息推送所需权限。日志无法...
常见错误码及排查方法
DTS-30005 内部处理中保存元数据信息失败 DTS-30005:save changed job progress info failed cause:SQLException:result content unexpected.expect 3 time 1,actually[2,1,1]可能原因：源库存在表名相同，但是大小写不同的表（如，TABLE和...
EMR Kafka磁盘故障运维
业务场景 Kafka将日志数据存储到磁盘中，当磁盘出现故障时，会导致磁盘IO能力下降、集群吞吐下降、消息读写延时或日志目录offline等问题。这些情况有可能影响到线上业务平稳运行、数据丢失、Kafka集群容错能力下降，单块盘故障甚至有可能...
常见问题索引
应用没有订阅服务，但是框架重启后显示有消费服务信息，如何处理？SAE访问请求响应不稳定，Spring Cloud应用第一次访问慢，第二次访问时很快，为什么？服务类型是Spring Cloud，Eureka和Consul在原来的ECS上，若要使用SAE，是否需要维护...
自定义配置
信息脱敏 在 信息脱敏 区域，通过设置脱敏规则，探针将对JVM系统参数、K8s Yaml、方法入参、Arthas环境变量和系统变量等内容在采集时就进行脱敏处理。脱敏规则中各元素通过英文半角逗号分隔，每一个元素代表一个不区分大小写的正则表达式，...
- 产品推荐
- 这些文档可能帮助您