函数计算
利用函数实现业务消息的处理，通过函数计算平台开发、运行业务消息处理逻辑，订单处理，任务执行。利用函数对消息进行快速加工处理，ETL清洗。利用函数计算灵活扩展将消息转储到指定VPC中的其它下游系统。利用函数链接消息系统和其他阿里云...
函数计算
利用函数实现业务消息的处理，通过函数计算平台开发、运行业务消息处理逻辑，订单处理，任务执行。利用函数对消息进行快速加工处理，ETL清洗。利用函数计算灵活扩展将消息转储到指定VPC中的其它下游系统。利用函数链接消息系统和其他阿里云...
消息幂等
消息重复的可能原因如下：发送时消息重复 当一条消息已被成功发送到服务端并完成持久化，此时出现了网络闪断或者客户端宕机，导致服务端对客户端应答失败。如果此时Producer意识到消息发送失败并尝试再次发送消息，Consumer后续会收到两条...
Windows系统实例的宕机问题排查
定位宕机原因 您可以通过以下方式，定位ECS实例发生宕机的具体原因。方式一：（推荐）通过自助诊断工具定位 登录 ECS管理控制台，左侧导航栏单击 自助问题排查。单击 实例问题排查 页签。选择 实例无法连接或启动异常>实例出现宕机，然后...
使用限制
目标云产品的实例宕机、欠费、参数错误（如授权变更、值非法）、配置错误等异常状况会导致消息流转失败。无 消息去重 数据流转时，为确保消息送达，同一条消息可能重复发送，直到客户端返回ACK或消息过期。同一条消息的消息ID相同，您可...
实例规格族
根据系统架构以及使用场景，ECS实例规格族可以分为：企业级x86计算规格族群 推荐 其他在售（如果售罄，建议使用推荐规格族）通用型实例规格族g8a 通用型实例规格族g8i 通用平衡增强型实例规格族g8ae 存储增强通用型实例规格族g7se 通用型...
消费幂等
处理方法 因为不同的Message ID对应的消息内容可能相同，有可能出现冲突（重复）的情况，所以真正安全的幂等处理，不建议以Message ID作为处理依据。最好的方式是以业务唯一标识作为幂等处理的关键依据，而业务的唯一标识可以通过消息Key...
消费重试
由于不可见时间为预分配的，可能和实际业务中的消息处理时间差别较大，您可以通过API接口修改不可见时间。例如，您预设消息处理耗时最多20 ms，但实际业务中20 ms内消息处理不完，您可以修改消息不可见时间，延长消息处理时间，避免消息...
消息幂等
当一条消息已被成功发送到服务端并完成持久化，此时出现了网络闪断或者客户端宕机，导致服务端对客户端应答失败。如果此时生产者意识到消息发送失败并尝试再次发送消息，消费者后续会收到两条内容相同并且 Message ID 也相同的消息。投递时...
发布者最佳实践
本文介绍 云消息队列 Kafka 版 发布者的最佳实践，帮助您降低发送消息的错误率。本文最佳实践基于Java客户端。对于其他语言的客户端，其基本概念与思想是相通的，但实现细节可能存在差异。发送消息 发送消息的示例代码如下：Future...
ECS系统事件概述
说明 非预期运维事件一般指的是因底层宿主机发生了无法预测的故障，或者ECS实例的操作系统发生了内核错误等问题，导致ECS实例突然出现宕机或重启。因宿主机故障导致ECS实例宕机或重启事件（SystemFailure.Reboot）属于偶发现象，无法避免。...
驱逐及防护
当某节点因宕机或其他原因处于NotReady异常状态时，ACS将启动节点自愈流程，此时节点上的Pod将会被驱逐。节点升级：升级节点内核或其他模块时，可能需要触发节点重启操作，在节点重启前，ACS会先将节点上的所有Pod进行驱逐。资源调度运营：...
通过可观测性能力进行故障处理最佳实践
根据业务逻辑或指标的变化趋势定位具体原因，例如消息处理耗时变长，则可以查看消费者服务的内存、CPU等是否过载；或查看消费逻辑依赖的下游业务逻辑的运行状态进行进一步分析。生产异常场景实践方案 查看消息发送成功率（rocketmq_send_...
概述
发送分布式事务消息时，如果生产者中途意外宕机，Broker 会主动回调生产者集群的任意一台机器来确认事务状态。消费者集群 用来表示消费消息应用，一个消费者集群下包含多个消费者实例，可以是多台机器，也可以是多个进程，或者是一个进程的...
常见问题
本文汇总了使用 云消息队列 RocketMQ 版 时的常见问题。产品功能常见问题 消息队列...若某个消费组下的机器宕机，机器重启期间，消息会不会丢失？订阅消息时消息Tag是否可以为空？创建新的消费分组订阅旧的Topic，如何设置消费起始位置？
常见问题
本文汇总了使用 云消息队列 RocketMQ 版 时的常见问题。产品功能常见问题 云消息队列 ...若某个消费组下的机器宕机，机器重启期间，消息会不会丢失？订阅消息时消息Tag是否可以为空？创建新的消费分组订阅旧的Topic，如何设置消费起始位置？
应用场景
消息事务 GTS 与 MQ 打通，提供事务消息处理能力，可以保证业务链路完成时发送消息，任一阶段异常时回滚消息。开发简单，在客户端声明一个注解，用以界定事务边界，调用 MQ 的事务API发送消息。 高可靠：在宕机、网络故障等情况下，严格...
内存型
推荐 内存型实例规格族r8a 内存型实例规格族r8i 内存平衡增强型实例规格族r8ae 内存型实例规格族r8y 内存增强型实例规格族re7p 内存型实例规格族r7p 存储增强内存型实例规格族r7se 内存型实例规格族r7a 内存型实例规格族r7 安全增强内存型...
本地SSD型
推荐 本地SSD型实例规格族i4 本地SSD型实例规格族i4g 本地SSD型实例规格族i4r 性能增强型本地盘实例规格族i4p 本地SSD型实例规格族i3g 本地SSD型实例规格族i3 本地SSD型实例规格族i2 本地SSD型实例规格族i2g 本地SSD型实例规格族i2ne 本地...
服务协议
此外，您自行升级操作系统可能会造成宕机等不良影响，请把握风险并谨慎操作。5.5.您了解阿里云无法保证其所提供的服务毫无瑕疵（如阿里云安全产品并不能保证您的硬件或软件的绝对安全），但阿里云承诺不断提升服务质量及服务水平。所以您...
为什么选择节省计划
以下几种业务模型适用选择节省计划付费模式：共振型业务 共振型业务：指各个业务间有关联，流量增长后各业务对资源的诉求同时增长。典型业务：电商大促、热点事件等泛互联网流量高峰。适合的付费模式：节省计划+按量付费。混部型业务 混部...
云监控
实时数仓Hologres（从实例）、实时数仓Hologres（湖仓加速）、实时数仓Hologres（通用型）、实时数仓Hologres（计算组））展示对应实例的监控指标，不同的实例类型对应专属监控指标，以便更好的监控业务异常并处理，建议将 实时数仓...
附录：SOFAStack 产品目录
引入消息队列后，利用消息队列的抗堆积能力，这些业务系统作为消息的消费方，可以根据自身应用的能力进行消息的消费，不受大流量的影响。API 网关 API 网关（API Gateway）是一个 API 管理平台，帮助企业统一管理对内外开放的 API，为网络...
Exactly-Once投递语义
例如，当您的消费端完成一条消息的消费处理后出现异常宕机，而消费端重启后由于消费的位点没有同步到消息系统的服务端，该消息有可能被重复消费。业界对于Exactly-Once投递语义存在很大的争议，很多人会拿出“FLP不可能理论”或者其他一致...
消费者分类
建议使用SimpleConsumer消费类型，可以在消费时自定义消息的预估处理时长，若实际业务中预估的消息处理时长不符合预期，也可以通过接口提前修改。需要异步化、批量消费等高级定制场景：SimpleConsumer在SDK内部没有复杂的线程封装，完全由...
消息超时和重试机制
本文介绍 云消息队列 RabbitMQ 版 服务端默认的消息重试机制，帮助您理解消费失败后的消息处理逻辑，并选择合适的消息处理策略。重试机制 云消息队列 RabbitMQ 版 服务端有默认的消息重试机制，不支持您在Consumer客户端重新配置消息重试...
Topic与Tag最佳实践
消息量级是否相当：有些业务消息虽然量小但是实时性要求高，如果跟某些万亿量级的消息使用同一个Topic，则有可能会因为过长的等待时间而“饿死”，此时需要将不同量级的消息进行拆分，使用不同的Topic。总的来说，针对消息分类，您可以选择...
开源对比
无法跳过有问题消息的消费处理，无法处理新生产的消息，从而会导致消息大量堆积引起内存问题，导致消息服务宕机。用户名、密码 通过阿里云访问控制（RAM）的AccessKey和AccessKey Secret生成用户名和密码，详情请参见 静态用户名密码管理。...
应用场景
本文为您介绍 云消息队列 RocketMQ 版 的应用场景，以便您更好地判断如何在业务中使用 云消息队列 RocketMQ 版。例如，针对一家互联网电商企业，其业务涉及广泛，如注册、订单、库存、物流等；同时，也会涉及许多业务峰值时刻，如秒杀活动...
队列使用手册
并且在消息处理过程中，也可以调用changeMessageVisibility这个函数来延长消息的VisibilityTimeout时间。Console.WriteLine("DeleteMessage Failed!ErrorCode:"+me.ErrorCode);} catch(Exception ex){ Console.WriteLine("Delete message ...
消息数、活跃消息数、延迟消息数分别表示哪些消息？
本文介绍控制台上的消息数、活跃消息数、延迟消息数分别表示哪些类型的消息。各消息数的概念如下：消息数：成功发送的和没有发送的所有消息数。活跃消息数：未经处理的消息数。延迟消息数：设置了延迟时间的消息数。
云消息队列 Kafka 版何时删除旧消息？
当往Kafka Topic中写入数据提示磁盘空间已满或 Queue full 时，为避免因磁盘容量不足而导致机器宕机，进而影响服务可用性，云消息队列 Kafka 版 会根据磁盘使用率的多少，执行不同的消息清理策略。清理策略 磁盘使用率每天凌晨4:00集中删除...
使用Exactly-Once投递语义收发消息
本文主要介绍如何使用 云消息队列 RocketMQ 版 的Exactly-Once投递语义收发消息，以保证消息的最终处理结果写入到数据库有且仅有一次。背景信息 重要 目前Exactly-Once投递语义仅在Java SDK中支持。相关SDK下载，请参见 版本说明。云消息...
开源对比
磁盘写满直接宕机。线程池隔离 读冷数据仍可以保证写入基本正常。读冷数据直接导致线程堵塞，数据写入大量失败。分区规模 万级分区仍然可以保证稳定写入。千级分区就会出现大量抖动。巡检系统 针对死锁、宕机等问题进行自动发现和修复。无...
批量消费
如需提高消息的处理效率，或降低下游资源的API调用频率，您可使用批量消费功能。本文介绍批量消费的定义、优势与场景、使用限制和示例代码等信息。什么是批量消费 定义 批量消费是 云消息队列 RocketMQ 版 通过Push消费者提供的、将消息分...
订阅消息
class ExampleMessageListener:public MessageListener { public:Action consume(Message&message,ConsumeContext&context){/此处为具体的消息处理过程，确认消息被处理成功请返回CommitMessage。如果有消费异常，或者期望重新消费，可以...
Transaction Table2.0概述
随着当前数据处理业务场景日趋复杂，很多业务场景并不要求延时秒级更新可见或者行级更新，更多的需求是分钟级或者小时级的近实时数据处理叠加海量数据批处理场景，MaxCompute支持基于Transaction Table2.0实现近实时的增全量一体的数据存储...
消息（Message）
消息负载 消息负载 定义：业务消息的实际报文数据。取值：由生产者负责序列化编码，按照二进制字节传输。约束：请参见 参数限制。行为约束 消息大小不得超过其类型所对应的限制，否则消息会发送失败。系统默认的消息最大限制如下：普通和...
手机规格
规格说明 规格名称 规格标识 规格配置 说明 基础型 ecp.cs.large CPU：2核 内存：4G 系统盘：32G 一般性APP应用，计算能力需求均衡，如微信、微博等 移动办公场景：典型办公场景消息流处理、流程审批等 普通型 ecp.ce.large CPU：2核 内存...
如何配置客户端参数？
本文介绍客户端参数的配置规则，请根据实际业务场景配置适当的值。客户端参数列表及说明如下所示：表 1.生产者客户端 参数 说明 retries 消息发送失败时的重试次数。retry.backoff.ms 消息发送失败时的重试间隔，建议设置为1000。单位：...
- 产品推荐
- 这些文档可能帮助您