消费者分类
顺序性保障 基于 云消息队列 RocketMQ 版 顺序消息 的定义，如果消费者分组设置了顺序消费模式，则PushConsumer在触发消费监听器时，严格遵循消息的先后顺序。业务处理逻辑无感知即可保证消息的消费顺序。说明 消息消费按照顺序处理的前提...
CreateExchange
FANOUT：该类型路由规则非常简单，会把所有发送到该Exchange的消息路由到所有与它绑定的Queue中，相当于广播功能。HEADERS：该类型与DIRECT类型相似。Headers Exchange使用Headers属性代替Routing Key进行路由匹配，在绑定Headers Exchange...
名词解释
MQTT服务器 云消息队列 MQTT 版 提供的MQTT协议交互的服务端节点，用于完成与MQTT客户端和 云消息队列 RocketMQ 版 各自的消息收发。MQTT客户端 用于和MQTT服务器交互的移动端节点，全称为 云消息队列 MQTT 版 客户端。P2P消息 云消息队列 ...
快速搭建移动应用上传回调服务
本文讲解如何搭建一个基于OSS的移动应用数据直传服务并设置上传回调。背景信息 快速搭建移动应用直传服务 介绍了如何快速搭建一个基于OSS的移动应用数据直传服务。但该方案有个问题：对于Android/iOS移动应用来说，只需要申请一次STS凭证，...
什么是应用防护
支持在安装了云安全中心客户端的阿里云服务器、第三方厂商云服务器和线下IDC服务器中使用。支持的操作系统如下：作系统类型 支持的操作系统 Windows（64位）Windows Server 2022 Windows Server 2019 Windows Server 2016 Windows Server ...
主题使用手册
Endpoint 访问 消息服务MNS 的接入地址，登录 MNS控制台，单击右上角 获取Endpoint 查看。不同地域的接入地址不同，分为公网以及私网域名。步骤二：创建主题 创建主题的代码示例如下。更多信息，请参见 Topic。public class ...
搭建LAMP开发环境（通过应用镜像）
21 为FTP服务的默认端口，20000/30000 端口为LAMP服务器中FTP服务的被动模式可能占用的端口范围。添加防火墙规则的具体操作，请参见 防火墙设置。使用FileZilla工具，并通过已保存的FTP用户密码信息连接服务器，将测试文件 test.html 上传...
ExchangeHasDiffFields
取值：fanout：该类型路由规则非常简单，会把所有发送到该Exchange的消息路由到所有与它绑定的Queue中，相当于广播功能。direct：该类型路由规则会将消息路由到Binding Key与Routing Key完全匹配的Queue中。topic：该类型与direct类型相似...
云消息队列 Kafka 版何时删除旧消息？
当往Kafka Topic中写入数据提示磁盘空间已满或 Queue full 时，为避免因磁盘容量不足而导致机器宕机，进而影响服务可用性，云消息队列 Kafka 版 会根据磁盘使用率的多少，执行不同的消息清理策略。清理策略 磁盘使用率每天凌晨4:00集中删除...
服务端签名直传
应用服务器侧的签名直传服务会处理客户端发送的Get请求消息，您可以设置对应的代码让应用服务器能够给客户端返回正确的消息。以下是签名直传服务返回给客户端消息Body内容的示例：{"accessid":"LTAI*","host":...
身份验证模板最佳实践
Android通知 仅在以下情况下，表示已收到WhatsApp身份验证模板消息的Android通知才会显示在用户的Android设备上：用户使用所发送消息的接收电话号码（帐户）登录WhatsApp应用。用户登录您的应用。Android操作系统是 KitKat（Android 4.4，...
P2P消息收发模式（MQTT）
发送P2P消息的多语言代码示例的链接如下表所示。语言 链接.NET .NET示例代码 C C示例代码 Java Java示例代码 JavaScript JavaScript示例代码 Python Python示例代码 PHP PHP示例代码 说明 不支持使用Go SDK收发P2P消息。接收P2P消息 接收...
P2P消息收发模式（MQTT）
发送P2P消息的多语言代码示例的链接如下表所示。语言 链接.NET .NET示例代码 C C示例代码 Java Java示例代码 JavaScript JavaScript示例代码 Python Python示例代码 PHP PHP示例代码 说明 不支持使用Go SDK收发P2P消息。接收P2P消息 接收...
OSS事件通知概述
通过创建事件通知规则，消息服务MNS 可以将对象存储OSS指定资源上产生的事件以消息的方式主动推送到指定的接收端。本文介绍对象存储OSS事件通知的背景信息、适用场景、事件类型以及消息格式。背景信息 如下图所示，如果您创建了事件通知...
主题+HTTP Endpoint使用手册
服务器功能：对 消息服务MNS 推送消息请求做签名验证。如果错误，返回MNS 403。说明 示例中HTTP Endpoint的针对Authorization的校验不能完全规避掉恶意伪造的MNS请求，需要从业务层面上设计从发送端到HTTP Endpoint的安全校验机制。解析推...
如何提高Nginx Web服务器的安全性
本文介绍如何提高Nginx Web服务器的安全性的操作步骤。背景信息 Nginx是一个轻量级的，高性能的Web服务器以及反向代理和邮箱（IMAP或POP3）代理服务器。它运行在UNIX、GNU、linux、BSD、Mac OS X、Solaris和Windows各种版本。根据调查统计...
CreateCustomImage-创建自定义镜像
您可以通过已配置好的自定义镜像创建更多包含相同配置的轻量应用服务器，也可以将自定义镜像共享至云服务器 ECS，进而通过共享镜像创建 ECS 实例或更换操作系统。关于自定义镜像的更多消息，请参见 自定义镜像概述。创建自定义镜像之前，您...
消息检索
当 云消息队列 Kafka 版 控制台提供的按位点查询和按时间查询消息的功能无法满足您搜索消息的需求时，您可以使用 云消息队列 Kafka 版 消息检索功能。消息检索支持按Topic分区、位点范围、时间范围以及消息Key和Value关键字检索。本文介绍...
作为Output接入
Value 消息的值（已强制转化为String类型），即消息的具体内容。消息创建时间 发送消息时，客户端自带的或是您指定的 ProducerRecord 中的消息创建时间。说明 如果配置了该字段，则按配置值显示。如果未配置该字段，则默认取消息发送时的...
作为Output接入
Value 消息的值（已强制转化为String类型），即消息的具体内容。消息创建时间 发送消息时，客户端自带的或是您指定的 ProducerRecord 中的消息创建时间。说明 如果配置了该字段，则按配置值显示。如果未配置该字段，则默认取消息发送时的...
准备环境
在使用C#SDK收发消息前，您需按照本文提供的内容来准备环境。环境要求 安装.NET。更多信息，请参见 安装.NET 。安装Visual Studio 2015或以上版本，更多信息，请参见 安装Visual Studio。安装完成后，您可以执行 dotnet-version 命令查看....
调用HTTP协议的SDK收发普通消息
前提条件 创建资源 说明 本文以普通消息为例进行说明，因此您创建的普通消息的Topic不能用来收发其他类型的消息，包括定时、延时、顺序和事务消息。换言之，切勿混用不同消息类型的Topic。创建AccessKey 下载并安装HTTP协议的SDK 云消息...
鉴权概述
本文主要介绍 云消息队列 MQTT 版 客户端鉴权的原理和分类，以便您使用相应的鉴权功能。鉴权原理 使用 云消息队列 MQTT 版 的客户端收发消息时，服务端会根据MQTT客户端设置的UserName和Password参数来进行鉴权。针对不同的权限验证场景，...
ApplyToken
使用场景 申请Token的接口应该由应用服务器发起，应用服务器验证MQTT客户端的权限范围后代替客户端向MQTT服务器申请Token。详细信息，请参见 Token鉴权概述。使用限制 单用户请求频率限制为500次/秒。如有特殊需求，请提交 工单 申请。调试...
删除队列消息
本文介绍如何删除某个队列的所有消息。您可以使用Java客户端库中 queuePurge 方法删除某个队列的所有消息。示例代码如下：channel.queuePurge("queue-name");
负载均衡调度算法介绍
负载均衡会根据配置的调度算法，将来自客户端的请求按照对应的算法规则转发至相应的后端服务器。负载均衡支持轮询、加权轮询、加权最小连接数、一致性哈希等多种调度算法，用于支持不同的业务场景。本文列出所有负载均衡系列产品支持的调度...
与云服务器ECS对比
与云服务器ECS相比，轻量应用服务器使用门槛较低，配置简便，能让您快速上手并部署简单的应用或网站，更适合个人开发者、学生等用户。本文介绍轻量应用服务器与云服务器ECS的特点和区别。产品对比 轻量应用服务器与 云服务器ECS 的产品对比...
Control Center设置告警
该指标指示消费何时接近最早的可用消息，这意味着存在数据丢失的可能性。Consumption difference 给定时间段内预期消耗值与实际消耗值之间的差值。通常，预期和实际消耗之间存在非常接近实时的差距。这种差距应该会随着时间的推移而缩小。...
ChatAppStatus
您可以通过MNS消息队列接收ChatApp消息发送状态报告（ChatAppStatus）。前提条件 您已经注册阿里云账号并生成访问密钥（AccessKey），详情请参见 创建AccessKey。您已仔细阅读 回执消息简介与配置流程，了解回执消息模式、类型和配置流程。...
重置消费位点
选择从指定时间点重置时，可以选择的最早时间为Topic中最早一条消息的存储时间，而 云消息队列 RocketMQ 版 4.x系列实例的最大消息存储时长为3天，超过3天的消息会从Topic中被删除。因此，通过重置消费位点最多可重新消费到3天前的消息。...
控制台看到的最近消费时间是什么意思？
消息发布到 云消息队列 Kafka 版 服务器的存储时间。控制台看到的 最近消费时间 是指消息发布到 云消息队列 Kafka 版 服务器的存储时间。如果消费没有堆积，那么这个时间接近发送时间。
SDK FAQ
开源客户端是否可以直接访问云上服务？云消息队列 RabbitMQ 版 完全兼容开源RabbitMQ。开源RabbitMQ可以直接访问云上服务。您需要通过 云消息队列 RabbitMQ 版 控制台生成静态用户名密码之后，通过静态账户直接访问云上服务。如何创建静态...
延时消息
方案对比 云消息队列 RabbitMQ 版 无需进行代码改造，即可实现开源RabbitMQ的所有延时消息方案，详情请参见下表：项目 开源RabbitMQ 云消息队列 RabbitMQ 版 死信Exchange+Queue的消息存活时间 支持 支持 死信Exchange+消息的消息存活时间 ...
ChatAppStatus
说明 Deleted状态暂不可用，WhatsApp不会推送给ChatApp消息服务。StatusDescription String 是 状态码的描述。ErrorCode String 否 错误码。ErrorDescription String 否 错误码描述。详情请参见 API错误码。ConversationType String 否 ...
开源RabbitMQ迁移上云
迁移消息数据 使用Shovel插件迁移消息数据 Shovel迁移数据的原理是消费开源RabbitMQ集群中的消息，将消息生产到云上实例中，迁移后开源RabbitMQ集群中的消息被清空，完成迁移。在开源集群启动Shovel插件。创建Shovel任务，将Source配置为...
查看消费者状态
就绪消息量 消息在 云消息队列 RocketMQ 版 服务端已就绪，对消费者可见可被消费的消息。排队时间 最早一条就绪消息的就绪时间和当前时刻的时间差。该时间反映消费者拉取消息的及时性。订阅关系 显示该Group ID下消费者实例群组的订阅关系...
Java客户端设置回调是否会影响消息发送的速度？
取决于回调里的处理耗时以及 max.in.flight.requests.per.connection 的设置。Java客户端设置回调是否会...max.in.flight.requests.per.connection 的设置：在阻塞结束之前，最多能发的消息数由 max.in.flight.requests.per.connection 决定。
消息加密传输
本文介绍如何进一步提高您与 消息服务MNS 服务之间的网络链路上的安全性。背景信息 消息服务MNS 提供在公网HTTPS上进行消息加密传输的服务。对于包含敏感信息的消息，进一步提高您与阿里云服务之间的网络链路上的安全性，目前有以下两种...
如何处理不活跃的Topic
调用GetTopicStatus接口获取各Topic的消息收发状态。关于如何调用此接口，请参见 GetTopicStatus。记录返回结果中各Topic的 LastTimeStamp 和 TotalCount 值。参考上述内容，判断各Topic是否活跃。如果存在不活跃的Topic，请先记录Topic的...
一机一密概述
计算方式 按照 鉴权概述 的描述，如果选择一机一密鉴权模式，MQTT客户端实际连接MQTT消息服务器时，connect 报文中的Username和Password需要按照本文约定的规范设置，具体设置和计算方法如下：Username 由鉴权模式名称、DeviceAccessKeyId...
- 产品推荐
- 这些文档可能帮助您