AliyunMQPubOnlyAccess 云消息队列 MQTT 版 的发布权限，被授予该权限的RAM用户具有使用阿里云账号所有资源通过SDK发送消息的权限。AliyunMQSubOnlyAccess 云消息队列 MQTT 版 的订阅权限，被授予该权限的RAM用户具有使用阿里云账号所有...
更新云消息队列 RocketMQ 版实例的基本信息和规格配置。接口说明 注意 阿里云提供的 OpenAPI 属于管控类 API，用于管理和查询阿里云服务的相关资源。仅推荐在管控链路集成，消息收发的核心数据链路中严禁依赖 OpenAPI 实现，否则可能会导致...
云上网络安全，往往是用户将核心业务部署上云时优先考虑的因素。您可使用VPC的流量镜像功能对云上网络流量的安全性进行实时检测与分析。场景示例 某公司将核心业务部署上云，需要保证云上业务的正常运行的同时，高效且无侵入地监控阿里云...
MQTT客户端收发消息权限 消息收发权限涉及Topic和Group ID的Resource命名格式：Topic：acs:mq:*:*:topic/{mqttInstanceId}/{topic} Group ID：acs:mq:*:*:groupId/{mqttInstanceId}/{gid} Action名称 Action描述 备注 mq:PUB 消息发布 授予...
功能介绍 保留消息（Retained Message）是指客户端在某个主题上发布一条消息时，指定该消息被服务器保留，后续订阅该主题的新客户端都将立即接收到这条保留消息，而无需等待新的消息发布。使用限制 目前仅专业版和铂金版支持该功能，且需要...
说明 如果本地网络通过 智能接入网关、高速通道（专线）或 VPN 网关 接入云上网络，则 办公网络 需要加入同一个 云企业网 实例。为保障 办公网络 内云电脑正常使用，选择 云企业网 实例ID之后，请单击 校验，以校验所选 云企业网 实例的...
图中箭头线条上的标号代表顺序，发布方会把第一条消息发送至 Queue 0，然后第二条消息发送至 Queue 1，以此类推，第八条消息发送至 Queue 7，第九条消息又发送至 Queue 0，循环往复。订阅方消息负载均衡策略 消息队列包含 Broker 和 Name ...
在 消息中心 页签的 客户端消息位 页签上单击发布客户端消息。（条件）在首次发布客户端消息前，在提示对话框中单击 立即开通。重要 由于您上传的图片要存储在您当前地域的指定OSS Bucket中，因此会产生OSS费用。详细信息，请参见 产品计费...
轻量消息队列（原 MNS）支持把发布到主题的消息推送到队列。本文介绍如何将消息推送到队列。步骤一：创建主题 登录 轻量消息队列（原 MNS）控制台。在左侧导航栏，选择 主题模型 主题列表。在顶部菜单栏，选择地域。在 主题列表 页面，单击...
轻量消息队列（原 MNS）支持把发布到主题的消息推送到移动终端。本文介绍如何将消息推送到移动终端。前提条件 开通移动推送 创建应用 集成SDK 步骤一：创建主题 登录 轻量消息队列（原 MNS）控制台。在左侧导航栏，选择 主题模型 主题列表...
发布者（Publisher）消息发布者，往主题发布消息的客户端。订阅者（Subscriber）消息订阅者，从主题接收消息的客户端，主题所有者默认拥有该主题的订阅权限。订阅（Subscription）订阅关系，只有和主题建立订阅关系后，消息订阅者才可以...
BatchDeleteMessage 批量删除消息 API调用 PeekMessage 查看消息 API调用 BatchPeekMessage 批量查看消息 API调用 ChangeMessageVisibility 修改消息下次可消费时间 API调用 主题消息收发 API 说明 PublishMessage 发布消息
订阅选项能够指定消息的最大服务质量（QoS）以及设备是否接收自己发布的消息，这些选项使得客户端可以更精细地管理自己的消息流和接收行为。MQTT 5.0支持的订阅选项如下：特性 说明 QoS level MQTT消息服务质量等级。No Local 设备是否接收...
本文介绍如何使用Java SDK向 SMQ 的指定主题中发布消息。前提条件 已安装SDK。已配置访问域名及凭证。消息体编码选择 当消息体无特殊字符时，建议您不使用Base64编码。发送消息时使用 message.setMessageBodyAsRawString 方法设置消息体。...
保留消息用于确保新订阅Topic的设备能及时收到最新状态的消息，即使消息在设备订阅之前发布。服务端向Topic发布消息时，如果消息携带保留标记（Retain），物联网平台将会保存这个消息并实时发布给订阅者，后续订阅该Topic的设备都会收到 ...
信息发布中心主要用于向平台发布运营公告、展示运营公告和系统通知。在 小程序开放平台 的 运营管理后台 单击左侧导航栏的 信息发布中心，进入 信息发布...删除信息 在 信息发布中心 页面单击信息列表操作列的 删除，二次确认后删除发布信息。
本文介绍 轻量消息队列（原 MNS）提供了哪些可用的操作。轻量消息队列（原 MNS）队列模型支持的操作...Unsubscribe 删除订阅 ListSubscriptionByTopic 获取主题的订阅列表 接口 功能描述 支持方式 PublishMessage 发布消息 控制台、API调用
生产者负载均衡策略 无序消息（普通消息、事务消息、定时和延时消息）：Producer将消息以轮询的方式发送至Queue，如下图所示：图中Msg1、Msg2代表第一条消息、第二条消息，生产者会把第一条消息发送至Queue 1，然后第二条消息发送至Queue 2...
在右侧窗口中，根据提示，选择或输入相应的模板发布信息，包括工作空间、命名空间、所属应用以及具体的发布参数。说明 请确保发布参数正确，发布时所使用的参数以设置的发布参数为准。单击 创建发布，模板进入创建发布状态。创建成功后会...
发布消息 运行 publish_message.py 发布多条消息到主题中，命令如下：python publish_message.py MyTopic1 返回结果如下：=Publish Message To Topic=TopicName:MyTopic1 MessageCount:3 Publish Raw Message Succeed.MessageBody:I am ...
针对初次接触 云消息队列 MQTT 版 的工程师，本文以Java语言为例，提供操作示例帮助您从零开始搭建 云消息队列 MQTT 版 的云端测试工程。Demo工程包含发送消息、接收消息以及接收客户端上下线消息的示例代码及相关配置。前提条件 安装IDEA...
MQTT 5.0的用户属性功能，使得接收方能够获取关于消息更丰富的上下文信息，让数据处理变得更加高效，操作更加有针对性，从而满足多样化的应用场景需求。消息示例 例如，现在需要发送一个温度读数的消息，同时附带设备所在位置和读数取得的...
本文介绍如何创建使用Tablestore Sink Connector，您可通过Tablestore Sink Connector将数据从 云消息队列 Kafka 版 实例的数据源Topic导出至Tablestore的表中。前提条件 已开通表格存储服务并创建实例。具体操作，请参见 开通服务和创建...
业务应用一般部署在阿里云的服务器上，业务应用通过向后端云产品订阅这条消息来获取所有客户端的上下线动作。流程说明 规则限制 限制项 限制值 说明 单实例规则数量 100 如果默认限制不满足，请联系 云消息队列 MQTT 版 技术支持，钉钉群号...
本文介绍如何在 云消息队列 RabbitMQ 版 控制台创建消息流入任务，将 云消息队列 Kafka 版 中的数据快速导入 云消息队列 RabbitMQ 版。前提条件 您已购买 云消息队列 RabbitMQ 版 实例，且实例处于 服务中 状态。具体步骤，请参见 步骤二：...
本文介绍如何在 云消息队列 Kafka 版 控制台创建消息流出任务，将指定 云消息队列 Kafka 版 实例中的数据导出至其他的 云消息队列 Kafka 版。前提条件 您已购买并部署 云消息队列 Kafka 版 实例，且实例处于 服务中 状态。具体步骤，请参见...
本文介绍如何在 云消息队列 Kafka 版 控制台创建流入任务，将指定 云消息队列 Kafka 版 实例中的数据快速导入至另外的 云消息队列 Kafka 版 实例中。前提条件 您已购买 云消息队列 Kafka 版 实例，且实例处于 服务中 状态。具体步骤，请...
消息轨迹 在分布式应用中，云消息队列 RocketMQ 版 作为全链路中异步解耦的关键服务，提供的Tracing数据可有效将业务上下游信息串联起来，帮助您更好地排查异常，定位问题。和4.x版本相比，云消息队列 RocketMQ 版 服务端5.x版本支持...
本文介绍如何在 云消息队列 RocketMQ 版 控制台创建消息流入任务，以实现将 云消息队列 Kafka 版 的数据快速导入至 云消息队列 RocketMQ 版。前提条件 您已购买 云消息队列 RocketMQ 版 实例，且实例处于 服务中 状态。具体步骤，请参见 ...
本文介绍如何在 云消息队列 Kafka 版 控制台创建消息流出任务，将 云消息队列 Kafka 版 的数据导出至 轻量消息队列（原 MNS）。前提条件 您已购买并部署 云消息队列 Kafka 版 实例，且实例处于 服务中 状态。具体步骤，请参见 步骤二：购买...
本文介绍如何创建使用SLS Sink Connector，您可通过SLS Sink Connector将数据从 云消息队列 Kafka 版 实例的数据源Topic导出至日志服务SLS。前提条件 详细步骤，请参见 创建前提。步骤一：创建目标服务资源 创建日志项目（Project）。详细...
本文介绍如何在 云消息队列 Kafka 版 控制台创建消息流出任务，将 云消息队列 Kafka 版 的数据导出至 云消息队列 RabbitMQ 版。前提条件 您已购买并部署 云消息队列 Kafka 版 实例，且实例处于服务中状态。具体步骤，请参见 步骤二：购买和...
本文介绍如何在 云消息队列 RocketMQ 版 控制台创建流出目标为函数计算的消息流出任务。前提条件 您已购买并部署 云消息队列 Kafka 版 实例，且实例处于 服务中 状态。具体步骤，请参见 步骤二：购买和部署实例。您已开通函数计算服务，...
本文介绍如何在 云消息队列 Kafka 版 控制台创建消息流出任务，将 云消息队列 Kafka 版 的数据导出至 云消息队列 RocketMQ 版。前提条件 您已购买 云消息队列 RocketMQ 版 实例，且实例处于 服务中 状态。具体步骤，请参见 创建资源。您已...
创建和管理交换机 流日志 新增 专有网络VPC提供流日志功能，可以记录VPC网络中弹性网卡ENI（Elastic Network Interface）传入和传出的流量信息，帮助您检查访问控制规则、监控网络流量和排查网络故障。流日志 流日志计费说明 创建和管理流...
本文以 云消息队列 Kafka 版 作为事件源为例，介绍如何在 事件总线EventBridge 控制台添加 云原生大数据计算服务 MaxCompute 作为事件流中的事件目标以实现将 云消息队列 Kafka 版 中的消息写入到 云原生大数据计算服务 MaxCompute 中进行...
取值：SIMPLIFIED：消息体即用户发布的消息，不包含任何属性信息。消息体示例：{1:"a",2:"b"} JSON：消息体为JSON格式，包含消息正文和消息属性。消息体示例：{"TopicOwner":"TopicOwner","TopicName":"TopicName","Subscriber":...
背景信息 云消息队列 Kafka 版 是阿里云提供的分布式、高吞吐、可扩展的消息队列。云消息队列 Kafka 版 广泛用于日志收集、监控数据聚合、流式数据处理、在线和离线分析等大数据领域，已成为大数据生态中不可或缺的部分。更多信息，请参见 ...
取值如下：成功 失败 消息基础信息 消息类型 普通消息 顺序消息 定时/延时消息 事务消息 消息ID 消息的全局唯一标识，由 云消息队列 RocketMQ 版 系统自动生成。Topic 消息所属的主题名称。消息Keys MessageKey，消息的业务标识，由消息...
因此，以VPC（Virtual Private Cloud）为核心的云上数据中心网络方案设计是用户用云的基础底座。本文围绕VPC阐述相关的网络方案。1 背景和概念 1.1 什么是数据中心网络？数据中心（Data Center）是指集中存放计算资源（如服务器）、存储...