超大消息传输
当消息内容大于64 KB以至于无法直接存入MNS队列时，不做消息切片，使用 消息服务MNS 和 对象存储OSS 来传递大于64 KB的消息。背景信息 消息服务MNS 的队列的...大消息网络传输时间较长，受网络波动影响的概率更大，建议在上层做必要的重试。
消息加密传输
解决方案 以下是 消息服务MNS 对消息进行加密传输的解决方案。在消息发送端先对消息进行加密，然后再发送。在消息接收端先对消息进行解密，然后再消费。示例代码：SecurityQueue.zip，其中：SeurityQueue.java 提供 putMessage、popMessage...
全球消息路由定价详情
计费项 全球消息路由的计费公式如下：消息传输费用 消息传输费用=消息传输量×消息传输单价 以进行消息路由传输的消息数量为维度计费，计费单价根据月消息传输总量阶梯变化。具体单价，请参见本文中的 计费单价。消息传输量=（普通消息+...
接入点对比
公网/VPC实例接入点对比 网络类型 端口 接入点 协议 适用场景 公网 9093 SSL接入点 SASL_SSL 消息传输过程需加密，消息收发需鉴权，支持以下两种机制验证身份：PLAIN SCRAM-SHA-256 专有网络VPC 9092 默认接入点 PLAINTEXT 消息传输过程...
如何配置MNS以支持更大的消息大小？
本文介绍如何配置 消息服务MNS 以支持更大的消息大小。要配置最大消息大小，请使用SetQueueAttributes方法设置MaximumMessageSize属性。此属性指定队列中的消息可以包含的字节数限值。可以设置为1024字节（1 KB）...详情请参见 超大消息传输。
领域模型概述
产品定位 云消息队列 RocketMQ 版 是一款典型的分布式架构下的中间件产品，使用异步通信方式和发布订阅的消息传输模型。通信方式和传输模型的具体说明，请参见下文 通信方式介绍 和 消息传输模型介绍。云消息队列 RocketMQ 版 产品具备异步...
计费常见问题
包年包月（预付费）实例的费用只限于 云消息队列 MQTT 版 所支持的协议，即 云消息队列 MQTT 版 的消息传输以及消息存储。若您使用 云消息队列 MQTT 版 的数据流入、数据流出规则和 云消息队列 RocketMQ 版 进行通信，云消息队列 RocketMQ ...
基本概念
主题（Topic）云消息队列 RocketMQ 版 中消息传输和存储的顶层容器，用于标识同一类业务逻辑的消息。主题通过TopicName来做唯一标识和区分。更多信息，请参见 主题（Topic）。消息类型（MessageType）云消息队列 RocketMQ 版 中按照消息...
设备状态查询
QoS 客户端与服务端消息传输的服务质量级别，详细信息，请参见 QoS。在查询结果页面单击 设备轨迹 和 消息轨迹 页签，您还可以查看到指定设备的轨迹信息和设备消息列表。查询结果的字段和详细说明，请参见 设备轨迹查询 和 消息轨迹查询。...
消息服务消息批量操作注意事项
如果消息超过64 KB，请参见 超大消息传输。BatchReceiveMessage一次最多获取16条消息，有时候明明有10条消息，一次BatchReceiveMessage却只能获取5条消息。例如：在一个队列里顺序发送了10条消息(m1,m2,m3,m4,m5,m6,m7,m8,m9,m10)，第一次...
订阅选项
No Local选项建议设置为1，可以减少不必要的消息传输。QoS level 消息质量分三个等级：等级 说明 常见场景 QoS 0 消息最多收到一次，消息不可靠传输，消息可能丢失。传感器数据传输使用该等级。QoS 1 消息最少收到一次，消息可靠传输，消息...
使用Spring Cloud框架收发消息
公网环境（消息传输需鉴权与加密）公网环境，消息采用SASL_SSL协议进行鉴权并加密。客户端通过SSL接入点访问 云消息队列 Kafka 版。接入点的详细信息，请参见 接入点对比。本示例将Demo包上传在/home/doc/project/aliware-kafka-demos/...
连接查询
如需了解 云消息队列 MQTT 版 客户端的连接情况，您可以指定Topic、Group ID以及Client ID查询客户端的当前在线数、在指定时间段内的在线数以及连接信息和订阅关系。...QoS：客户端与服务端消息传输的服务质量级别，详细信息，请参见 QoS。
API概览
主题是云消息队列 RocketMQ 版中消息传输和存储的顶层容器，用于标识同一类业务逻辑的消息。在消息收发模型中，生产者将消息发送至主题，消费者通过订阅指定的主题来消费其中的消息。UpdateTopic 更新主题 更新主题的备注信息。DeleteTopic...
生产者（Producer）
定义 生产者是 云消息队列 RocketMQ 版 系统中用来构建并传输消息到服务端的运行实体。生产者通常被集成在业务系统中，将业务消息按照要求封装成 云消息队列 RocketMQ 版 的 消息（Message）并发送至服务端。在消息生产者中，可以定义如下...
计费概述
全球消息路由功能的计费项如下：全球消息路由费用=消息传输费用+任务资源占用费用 详细的计费项说明和单价，请参见 全球消息路由定价详情。price-calculatorButton { width:700px;height:50px;border-radius:40px;border:1px solid#ff4a00;...
订阅关系（Subscription）
订阅关系由消费者分组动态注册到服务端系统，并在后续的消息传输中按照订阅关系定义的过滤规则进行消息匹配和消费进度维护。通过配置订阅关系，可控制如下传输行为：消息过滤规则：用于控制消费者在消费消息时，选择主题内的哪些消息进行...
CreateTopic-创建主题
主题是云消息队列 RocketMQ 版中消息传输和存储的顶层容器，用于标识同一类业务逻辑的消息。在消息收发模型中，生产者将消息发送至主题，消费者通过订阅指定的主题来消费其中的消息。调试 您可以在OpenAPI Explorer中直接运行该接口，免去...
全球消息路由
计费影响 全球消息路由为 云消息队列 RocketMQ 版 的高级功能，使用该功能会带来额外的费用，包含消息传输费用和任务资源占用费用。更多信息，请参见 全球消息路由定价详情。地域限制 目前仅公网地域不支持全球消息路由功能，其他地域均...
云存储网关利用MQTT服务实现统一管控
云消息队列 MQTT 版 消息传输能力无限扩展，CSG实例数量增加无需担心系统能力不足。云消息队列 MQTT 版 支持百万级设备毫秒级推送完成，CSG的控制指令无拥塞。云消息队列 MQTT 版 传输支持SSL/TLS加密，无需担心数据泄露。所有服务节点高...
名词解释
QoS QoS（Quality of Service）指消息传输的服务质量。分别可在消息发送端和消息消费端设置。发送端的QoS设置：影响发送端发送消息到 云消息队列 MQTT 版 的传输质量。消费端的QoS设置：影响 云消息队列 MQTT 版 服务端投递消息到消费端的...
主题（Topic）
定义 主题是 云消息队列 RocketMQ 版 中消息传输和存储的顶层容器，用于标识同一类业务逻辑的消息。主题的作用主要如下：定义数据的分类隔离 在 云消息队列 RocketMQ 版 的方案设计中，建议将不同业务类型的数据拆分到不同的主题中管理，...
新零售电子价签解决方案（MQTT）
方案优势 新零售电子价签解决方案的优势如下所述：服务能力强，可弹性伸缩 云消息队列 MQTT 版 消息传输能力无限扩展，智能终端数量增加无需担心系统能力不足。云消息队列 MQTT 版 支持百万级设备毫秒级推送完成，电子价签屏显更新延迟更小...
配额与限制
若消息大小不满足限制要求，可以尝试分割消息或使用OSS存储，用消息传输URL。消息自定义属性 字符限制：所有可见字符。数量限制：每条消息最多可设置128个属性。长度限制：属性的Key和Value总长度不超过16 KB。系统保留属性：不允许使用...
计费概述
计费项 云消息队列 MQTT 版 的计费项目如下：计费项说明如下：基础版/铂金版实例计费 专业版实例计费 Serverless版实例计费 计价倍率 在使用MQTT协议传输消息时，QoS 和 cleanSession 参数的设置会影响实际的计费。每条消息（包含客户端和...
使用实例接入点收发消息
您可以根据消息传输的安全要求级别选择PLAIN机制或SCRAM机制进行身份认证。更多信息，请参见 开启ACL。当实例类型为公网/VPC实例时，公网环境必须对消息进行鉴权与加密，SASL的PLAIN机制必须与SSL一起用作传输层，采用SASL_SSL协议，确保...
实例规格
专有网络VPC环境下使用SSL加密传输消息 不支持。支持。跨可用区 不支持。支持。下载消息 支持。支持。共享性 部分资源（如磁盘）共享。可能有抖动，主要为延迟升高。例如，可能存在偶然的突发流量，导致磁盘压力增大，从而导致请求延迟大，...
P2P消息收发模式（MQTT）
而P2P模式下，发送者无需事先约定传输消息的Topic，发送者可以直接按照规范发送消息到目标的接收者。接收消息时，Pub/Sub模式下，接收者需要按照和发送者约定好的Topic提前订阅才能收到消息；而P2P模式下接收者无需事先订阅即可接收消息，...
P2P消息收发模式（MQTT）
而P2P模式下，发送者无需事先约定传输消息的Topic，发送者可以直接按照规范发送消息到目标的接收者。接收消息时，Pub/Sub模式下，接收者需要按照和发送者约定好的Topic提前订阅才能收到消息；而P2P模式下接收者无需事先订阅即可接收消息，...
数据传输服务DTS
本文介绍如何在 云消息队列 RabbitMQ 版 控制台创建消息流入任务，将数据传输服务DTS中的数据快速导入至 云消息队列 RabbitMQ 版。前提条件 您已购买 云消息队列 RabbitMQ 版 实例，且实例处于 服务中 状态。具体步骤，请参见 创建资源。在...
莉莉丝《剑与远征》：动态加速提升用户体验
多路传输：阿里云全站加速采用多路传输技术，可以复制游戏动态指令及互动消息的数据同时多路传输，相比单数据单路传输，提高了对于网络的抗抖性。零时延切换：阿里云全站加速通过零时延的故障快速切换，确保在平台任意节点出现故障时游戏...
消息（Message）
消息中转时做好不可变设计 云消息队列 RocketMQ 版 服务端5.x版本中，消息本身不可编辑，消费端获取的消息都是只读消息视图。但在历史版本3.x和4.x版本中消息不可变性没有强约束，因此如果您需要在使用过程中对消息进行中转操作，务必将...
配置消息队列Kafka版实例的参数
本文为您介绍目标数据库实例为 专线/VPN网关/智能网关 方式接入的 阿里云消息队列Kafka版 时，部分特殊参数的配置方法和获取方式。注意事项 使用此方案将 阿里云消息队列Kafka版 接入DTS，会将数据写入到您指定的节点中。若您的源库为MySQL...
从自建MySQL同步至阿里云消息队列Kafka版
通过数据传输服务DTS（Data Transmission Service），您可以将自建MySQL同步至消息队列Kafka版，扩展消息处理能力。前提条件 自建MySQL的数据库版本为5.1、5.5、5.6、5.7或8.0版本。目标Kafka实例的版本为0.10.1.0-2.x版本。目标Kafka实例...
自建Oracle迁移至阿里云消息队列Kafka版
本文介绍如何使用数据传输服务DTS（Data Transmission Service），将自建Oracle迁移至阿里云消息队列Kafka。前提条件 已创建源数据库自建Oracle和目标实例 阿里云消息队列Kafka版。说明 源数据库和目标实例支持的版本，请参见 迁移方案概览...
自建Oracle同步至阿里云消息队列Kafka版
本文介绍如何使用数据传输服务DTS（Data Transmission Service），将自建Oracle同步至阿里云消息队列Kafka。前提条件 已创建源数据库自建Oracle和目标实例 阿里云消息队列Kafka版。说明 源数据库和目标实例支持的版本，请参见 同步方案概览...
Db2 for LUW迁移至阿里云消息队列Kafka版
数据传输服务DTS（Data Transmission Service）支持将 Db2 for LUW 数据库迁移至 阿里云消息队列Kafka版。前提条件 已创建存储空间大于源 Db2 for LUW 数据库占用存储空间的目标 阿里云消息队列Kafka版 实例。更多信息，请参见 概述。说明 ...
从自建Oracle迁移至阿里云消息队列Kafka
通过数据传输服务DTS（Data Transmission Service），您可以将自建Oracle迁移至阿里云消息队列Kafka版或自建Kafka，从而扩展消息处理能力。本文以自建Oracle数据库迁移至阿里云消息队列Kafka实例为例，介绍数据迁移任务的配置流程。前提...
PolarDB MySQL版同步至阿里云消息队列Kafka版
本文介绍如何使用数据传输服务DTS（Data Transmission Service），将 PolarDB MySQL版 集群同步至 阿里云消息队列Kafka版，扩展消息处理能力。前提条件 已创建源 PolarDB MySQL版 集群，详情请参见 购买按量付费集群 和 购买包年包月集群。...
PolarDB-X 1.0迁移至阿里云消息队列Kafka
本文介绍如何使用数据传输服务DTS（Data Transmission Service）将PolarDB-X 1.0迁移至阿里云消息队列Kafka。前提条件 已创建源PolarDB-X 1.0实例。具体操作，请参见 创建实例。说明 PolarDB-X 1.0的存储类型支持为RDS MySQL（包括私有定制...
- 产品推荐
- 这些文档可能帮助您