应用场景
秒杀处理流程如下所述：用户发起海量秒杀请求到秒杀业务处理系统。秒杀处理系统按照秒杀处理逻辑将满足秒杀条件的请求发送至 云消息队列 RocketMQ 版。下游的通知系统订阅 云消息队列 RocketMQ 版 的秒杀相关消息，再将秒杀成功的消息发送...
配置WaitingRoom等候队列
对于购物秒杀、抢票等场景，客户端往往会突发大量请求访问源站，为了防止源站面对突发的高并发流量而造成服务中断，DCDN 的WaitingRoom等待队列提供水管化功能，实现按比例释放请求至源站，同时将超过水管容纳能力范围外的请求进入等待队列...
消息发送重试和流控机制
本文为您介绍 云消息队列 RocketMQ 版 的消息发送重试机制和消息流控机制。背景信息 消息发送重试 云消息队列 RocketMQ 版 的消息发送重试机制主要为您解答如下问题：部分节点异常是否影响消息发送？请求重试是否会阻塞业务调用？请求重试...
设置回调事件
队列名称 当回调方式为 MNS队列 时，需要配置该参数。队列名称是接收消息通知的MNS队列。请使用ice-callback开头命名的队列，如果没有可用的队列，需要在MNS控制台创建。具体操作，请参见 创建队列。回调事件 根据实际需求选择回调事件。回...
发布者最佳实践
一般情况下，小Batch会导致Producer客户端产生大量请求，造成请求队列在客户端和服务端的排队，并造成相关机器的CPU升高，从而整体推高了消息发送和消费延迟。一个合适的Batch大小，可以减少发送消息时客户端向服务端发起的请求次数，在...
附录：服务状态码说明
当队列打满时（队列长度默认为64，您可以在 创建服务 的JSON文件中配置 metadata.rpc.max_queue_size 字段来调整队列长度），新来的请求会直接被拒绝，并返回状态码450，来避免队列过度堆积导致所有请求RT越来越高最终服务不可用。...
回调事件概述
您需要授权IMS访问消息服务MNS，并在MNS中创建队列或使用已有队列，然后在控制台上或调用OpenAPI时配置MNS队列名称，当事件产生时，IMS服务端会将回调内容写入该队列，您需要到MNS中查看接收消息。优缺点 对比项 HTTP请求 MNS队列 可靠性 ...
错误码
QueueAlreadyExist The queue you want to create is already exist.409 同名队列已存在，且请求属性与原有队列属性不同。InvalidQueueName The queue name you provided is invalid.QueueName should start with alpha and contain only ...
CreateQueue
调用CreateQueue接口创建一个新的队列。授权信息 默认仅限阿里云账号使用本接口，RAM用户只有在被授予了相关API操作权限后方可使用。本接口的授权信息如下表所示。更多信息，请参见 授权策略和示例。Name Value API CreateQueue RAM授权...
HTTP SDK错误码列表
详细信息，请参见对应的API文档：发送消息API 订阅消息API 确认消息API SignatureDoesNotMatch The request signature we calculated does not match the signature you provided.Check your key and signing method.403 请求签名异常。...
顺序消息
顺序消息为 云消息队列 RocketMQ 版 中的高级特性消息，本文为您介绍顺序消息的应用场景、功能原理、使用限制、使用方法和使用建议。应用场景 在有序事件处理、撮合交易、数据实时增量同步等场景下，异构系统间需要维持强一致的状态同步，...
消费重试
消费者出现异常，云消息队列 RocketMQ 版 会根据消费重试策略重新投递该消息进行故障恢复。本文介绍消费重试的应用场景、原理机制、版本兼容性和使用建议。应用场景 云消息队列 RocketMQ 版 的消费重试主要解决的是业务处理逻辑失败导致的...
签名机制
本文介绍签名的生成机制。背景信息 AccessKey ID和AccessKey Secret由阿里云官方颁发给访问者（可以通过阿里云管理控制台申请和管理），其中：AccessKey ID用于标识访问者的身份。AccessKey Secret用于加密签名字符串和服务器端验证签名...
计费说明
队列请求次数费用 计费公式 队列请求次数费用＝队列请求次数累计值（百万次）×队列请求次数单价（元/百万次）计费 单价 消息服务MNS 每个月拥有2000万次免费请求次数额度。超出此额度后，将按照实际超出的请求次数进行计费。队列请求次数...
使用Redis搭建电商秒杀系统
秒杀活动是绝大部分电商选择的低价促销、推广品牌的方式。不仅可以给平台带来用户量，还可以提高平台知名度。一个好的秒杀系统，可以提高平台系统的稳定性和公平性，获得更好的用户体验，提升平台的口碑，从而提升秒杀活动的最大价值。本文...
公共参数
公共请求头 参数 是否必选 说明 Authorization 是 验证字符串，由 MQ+空格+<AccessKeyId>+:+构成，更多信息，请参见 签名机制。Content-Length 是 HTTP请求Body的长度。Content-Type 是 请求内容的MIME类型，目前请求仅支持text/xml;...
CreateSaslUser-创建SASL用户
消息队列 Kafka 版优化了 PLAIN 机制，支持不重启实例的情况下动态增加 SASL 用户。scram：一种用户名密码校验机制，安全性比 PLAIN 更高。消息队列 Kafka 版使用 SCRAM-SHA-256。默认值为 plain。plain Mechanism string 否 加密方式。...
API概览
本产品（微消息队列 MQTT/2020-04-20）的OpenAPI采用 RPC 签名风格，签名细节参见 签名机制说明。我们已经为开发者封装了常见编程语言的SDK，开发者可通过 下载SDK 直接调用本产品OpenAPI而无需关心技术细节。如果现有SDK不能满足使用需求...
应用场景
本文为您介绍 SOFAStack 消息队列的适用场景，以便您更好地判断如何在业务中使用消息队列。在互联网金融场景里，其业务涉及广泛，如支付交易、收费计息、商户结算、业务营销、会员积分、风险核查等；同时，也会涉及许多业务峰值时刻，如双 ...
DescribeSaslUsers-查询SASL用户
消息队列 Kafka 版优化了 PLAIN 机制，支持不重启实例的情况下动态增加 SASL 用户。scram：一种用户名密码校验机制，安全性比 PLAIN 更高。消息队列 Kafka 版使用 SCRAM-SHA-256。默认值为 plain。scram Password string 密码。Username ...
开通消息队列服务并授权
在阿里云官方网站开通消息队列服务后方可开始使用 云消息队列 RocketMQ 版。如果您的账号为RAM用户，必须先为RAM用户进行授权，才能通过控制台或API访问相应的 云消息队列 RocketMQ 版 资源，并使用资源通过SDK收发消息。前提条件 您已注册...
DeleteSaslUser-删除SASL用户
消息队列 Kafka 版优化了 PLAIN 机制，支持不重启实例的情况下动态增加 SASL 用户。scram：一种用户名密码校验机制，安全性比 PLAIN 更高。消息队列 Kafka 版使用 SCRAM-SHA-256。默认值为 plain。scram Mechanism string 否 加密方式。...
开通消息队列服务并授权
在阿里云官方网站开通消息队列服务后方可开始使用 云消息队列 RocketMQ 版。如果您的账号为RAM用户，必须先为RAM用户进行授权，才能通过控制台或API访问相应的 云消息队列 RocketMQ 版 资源，并使用资源通过SDK收发消息。前提条件 您已注册...
生产者（Producer）
本文介绍 云消息队列 RocketMQ 版 中生产者（Producer）的定义、模型关系、内部属性、版本兼容性及使用建议。定义 生产者是 云消息队列 RocketMQ 版 系统中用来构建并传输消息到服务端的运行实体。生产者通常被集成在业务系统中，将业务...
队列（MessageQueue）
模型关系 在整个 云消息队列 RocketMQ 版 的领域模型中，队列所处的流程和位置如下：云消息队列 RocketMQ 版 默认提供消息可靠存储机制，所有发送成功的消息都被持久化存储到队列中，配合生产者和消费者客户端的调用可实现至少投递一次的...
开通服务并授权
在阿里云官方网站开通消息队列服务后方可开始使用 云消息队列 MQTT 版。如果您的账号为RAM用户，必须先为RAM用户进行授权，才能通过控制台或API访问相应的 云消息队列 MQTT 版 资源，并使用SDK收发消息。前提条件 您已注册阿里云账号并完成...
主题（Topic）
主题管理尽量避免自动化机制 在 云消息队列 RocketMQ 版 架构中，主题属于顶层资源和容器，拥有独立的权限管理、可观测性指标采集和监控等能力，创建和管理主题会占用一定的系统资源。因此，生产环境需要严格管理主题资源，请勿随意进行增...
消费者负载均衡
消费者从 云消息队列 RocketMQ 版 获取消息消费时，通过消费者负载均衡策略，可将主题内的消息分配给指定消费者分组中的多个消费者共同分担，提高消费并发能力和消费者的水平扩展能力。本文介绍 云消息队列 RocketMQ 版 消费者的负载均衡...
普通消息
普通消息为 云消息队列 RocketMQ 版 中最基础的消息，区别于有特性的顺序消息、定时/延时消息和事务消息。本文为您介绍普通消息的应用场景、功能原理、使用方法和使用建议。应用场景 普通消息一般应用于微服务解耦、事件驱动、数据集成等...
消息存储和清理机制
本文为您介绍 云消息队列 RocketMQ 版 中消息的存储机制，包括消息的存储粒度、判断依据及后续处理策略等。背景信息 参考 云消息队列 RocketMQ 版 中 队列 的定义，消息按照达到服务器的先后顺序被存储到队列中，理论上每个队列都支持无限...
队列模型快速入门
本文为您介绍如何在 消息服务MNS控制台 上快速上手使用队列模型。前提条件 开通消息服务MNS并授权 创建队列 登录 消息服务MNS控制台。在左侧导航栏，单击 队列...删除队列前，请停止对该队列的API请求，否则对该队列的API请求仍然会产生费用。
OnsMessageTrace-查看消息消费结果
本接口的实现基于云消息队列 RocketMQ 版的内部位点机制，在大部分场景下判断结果可信，但如果应用方进行过重置位点已经清除消息等操作，则判断结果可能有误。调试 您可以在OpenAPI Explorer中直接运行该接口，免去您计算签名的困扰。运行...
定时/延时消息
定时/延时消息为 云消息队列 RocketMQ 版 中的高级特性消息，本文为您介绍定时/延时消息的应用场景、功能原理、使用限制、使用方法和使用建议。应用场景 说明 定时消息和延时消息本质相同，都是服务端根据消息设置的定时时间在某一固定时刻...
消息超时和重试机制
重试机制 云消息队列 RabbitMQ 版 服务端有默认的消息重试机制，不支持您在Consumer客户端重新配置消息重试机制和关闭消息重试机制。云消息队列 RabbitMQ 版 服务端默认的消息重试机制如下：如果您没有开启Consumer客户端消费消息，则不会...
消费失败是否支持重试？
重试机制 云消息队列 RabbitMQ 版 服务端有默认的消息重试机制，不支持您在Consumer客户端重新配置消息重试机制和关闭消息重试机制。云消息队列 RabbitMQ 版 服务端默认的消息重试机制如下：如果您没有开启Consumer客户端消费消息，则不会...
使用Canal将MySQL的数据同步至云消息队列 Kafka 版
本教程介绍如何使用Canal将MySQL的数据同步至 云消息队列 Kafka 版。背景信息 Canal的主要用途是基于MySQL数据库增量日志解析，提供增量数据订阅和消费。Canal伪装自己为MySQL Slave，向MySQL Master发送dump请求。MySQL Master收到dump...
收发事务消息
云消息队列 RocketMQ 版 发送事务消息时需要实现 LocalTransactionChecker 接口，用来处理Broker主动发起的本地事务状态回查请求，因此在事务消息的Check方法中，需要完成两件事情：检查该半事务消息对应的本地事务的状态（committed or ...
收发事务消息
云消息队列 RocketMQ 版 提供类似XA或Open XA的分布式事务功能，通过 云消息队列 RocketMQ 版 事务消息，能达到分布式事务的最终一致。说明 对于新手用户，建议在正式收发消息前，阅读 Demo工程 来了解搭建 云消息队列 RocketMQ 版 工程的...
收发事务消息
} } 事务回查机制说明 发送事务消息为什么必须要实现回查Check机制？当步骤1中半事务消息发送完成，但本地事务返回状态为 LocalTransactionState.UNKNOW，或者应用退出导致本地事务未提交任何状态时，从Broker的角度看，这条Half状态的消息...
降低实例配置
如果您的 云消息队列 Kafka 版 实例的公网流量消耗远小于购买的公网流量配置，或者分区的使用量远小于购买的分区数量，您可以降低公网流量和分区数量配置，从而节约成本。本文介绍如何在 云消息队列 Kafka 版 控制台降低实例的公网流量、...
- 产品推荐
- 这些文档可能帮助您