产品架构
集群级别的高可用，是 云消息队列 RocketMQ 版 跟其他的消息服务器的主要区别，消息生产者发送一条消息到消息服务器，消息服务器会随机的选择一个消费者，只要这个消费者消费成功就认为是成功了。重要 文中所提及的 云消息队列 RocketMQ 版...
一机一密概述
计算方式 按照 鉴权概述 的描述，如果选择一机一密鉴权模式，MQTT客户端实际连接MQTT消息服务器时，connect 报文中的Username和Password需要按照本文约定的规范设置，具体设置和计算方法如下：Username 由鉴权模式名称、DeviceAccessKeyId...
签名鉴权模式
签名计算方式 按照 鉴权概述 的描述，如果选择签名校验模式，MQTT客户端实际连接MQTT消息服务器时，connect 报文中的Username和Password需要按照本文约定的规范设置，具体设置和计算方法如下：Username 由鉴权模式名称、AccessKeyId和...
签名鉴权模式
签名计算方式 按照 鉴权概述 的描述，如果选择签名校验模式，MQTT客户端实际连接MQTT消息服务器时，connect 报文中的Username和Password需要按照本文约定的规范设置，具体设置和计算方法如下。Username 由鉴权模式名称、AccessKey ID和...
应用介绍
答：举几个例子 页面广告法关键词检测（适合天猫、淘宝）千牛旺旺消息批量发送（适合天猫、淘宝）智能快递分析（适合天猫、淘宝）自动实时催付和核对地址（适合天猫、淘宝）已审核订单批量退款（适合天猫）集市店铺通用批量退款（淘宝）...
漏洞公告|Windows SMBv3远程执行代码漏洞（CVE-2020-...
漏洞信息 漏洞编号：CVE-2020-0796 漏洞评级：高危，风险极大 补丁更新日期：2020年03月12日 漏洞位置：Windows 10和Windows Server的服务器消息模块3.1.1（Server Message Block 3.1.1，简称SMBv3）影响版本：Windows 10，Version 1903，...
收发事务消息
本文提供使用TCP协议下的社区版Java SDK收发事务消息的示例代码供您参考。交互流程 事务消息交互流程如下图所示。更多信息，请参见 事务消息。前提条件 您已完成以下操作：下载4.5.2或以上版本的社区版 Java SDK。准备工作。获取阿里云访问...
音视频通信解决方案（MQTT）
RTC服务器 阿里云音视频通信RTC提供的音视频相关媒体通道服务。音视频业务管控服务器 音视频通信系统中的管控节点（下文简称音视频管控服务）。音视频管控服务需要由业务方自行建设，用于控制所有音视频通信会话的生命周期。该管控节点一般...
Token鉴权概述
MQTT服务器 云消息队列 MQTT 版 权限认证和消息收发服务器，用来处理应用服务器发起的Token相关的请求以及消息收发业务。使用流程 Token鉴权模式相比签名模式更加复杂，您需要按照下图所示的流程，部署您的应用服务器。而且在初始化时，...
Token鉴权概述
MQTT服务器 云消息队列 MQTT 版 权限认证和消息收发服务器，用来处理应用服务器发起的Token相关的请求以及消息收发业务。使用流程 Token鉴权模式相比签名模式更加复杂，您需要按照下图所示的流程，部署您的应用服务器。而且在初始化时，...
产品架构
本文介绍 云消息队列 Kafka 版 的系统架构和发布/订阅模型。云消息队列 Kafka 版 系统架构 如 云消息队列 Kafka 版的系统架构 所示，一个 云消息队列 Kafka 版 集群包括Producer、Kafka Broker、Group、ZooKeeper。图 1.云消息队列 Kafka ...
新零售电子价签解决方案（MQTT）
新零售电子价签解决方案由阿里云 云消息队列 MQTT 版 推出，通过MQTT以实现商场超市、公共场所电子标签、多媒体屏幕的数据更新管理。本文将以电子价签为例详细描述该解决方案的系统架构、数据流设计以及注意事项，其他类似行业可参考该方案...
OnsMessageGetByMsgId-通过MsgId查询消息
通过传入 Message ID 查询指定消息的信息以及判断该指定的消息是否曾被消费过。接口说明 注意 阿里云提供的 OpenAPI 属于管控类 API，用于管理和查询阿里云服务的相关资源。仅推荐在管控链路集成，消息收发的核心数据链路中严禁依赖 Open...
本地邮件数据迁移Outlook+IMAP
本文旨在对某些企业原邮箱数据只保存在本地的用户，通过Outlook客户端配置IMAP模式反传本地邮件数据到阿里邮箱的操作说明。顺序：步骤：说明 大部分版本的Outlook已不支持同时配置多个相同地址的账号，即便服务器地址不一致。可以通过给...
OnsMessageDetail-查询消息详细信息
接口说明 注意 阿里云提供的 OpenAPI 属于管控类 API，用于管理和查询阿里云服务的相关资源。仅推荐在管控链路集成，消息收发的核心数据链路中严禁依赖 OpenAPI 实现，否则可能会导致链路产生风险。调试 您可以在OpenAPI Explorer中直接...
自定义鉴权模式
MQTT服务器 云消息队列 MQTT 版 权限认证和消息收发服务器，用来处理应用服务器发起的鉴权相关的请求以及消息收发业务。使用说明 无论使用何种鉴权模式，本质上可以归结为身份认证和资源权限两个基本功能。身份认证，即客户端的身份标识，...
OnsDLQMessageGetById-根据Message ID查询死信消息
通过传入Message ID查询指定的死信消息。包括存储时间、消息体、Key和Tag。接口说明 注意 阿里云提供的 OpenAPI 属于管控类 API，用于管理和查询阿里云服务的相关资源。仅推荐在管控链路集成，消息收发的核心数据链路中严禁依赖 OpenAPI ...
OnsMessageGetByKey-根据Message Key查询消息
接口说明 注意 阿里云提供的 OpenAPI 属于管控类 API，用于管理和查询阿里云服务的相关资源。仅推荐在管控链路集成，消息收发的核心数据链路中严禁依赖 OpenAPI 实现，否则可能会导致链路产生风险。使用本接口根据 Message Key 查询消息的...
名词解释
RTC服务器 阿里云音视频通信RTC提供的音视频相关媒体通道服务。音视频业务管控服务器 音视频通信系统中的管控节点，简称音视频管控服务。音视频管控服务需要由业务方自行建设，用于控制所有音视频通信会话的生命周期。该管控节点一般部署...
OnsMessagePageQueryByTopic-查询Topic内所有消息
接口说明 注意 阿里云提供的 OpenAPI 属于管控类 API，用于管理和查询阿里云服务的相关资源。仅推荐在管控链路集成，消息收发的核心数据链路中严禁依赖 OpenAPI 实现，否则可能会导致链路产生风险。按 Topic 查询消息的方式属于范围查询，...
消息加密传输
本文介绍如何进一步提高您与 消息服务MNS 服务之间的网络链路上的安全性。背景信息 消息服务MNS 提供在公网HTTPS上进行消息加密传输的服务。对于包含敏感信息的消息，进一步提高您与阿里云服务之间的网络链路上的安全性，目前有以下两种...
查询Group ID内所有死信消息
接口说明 注意 阿里云提供的 OpenAPI 属于管控类 API，用于管理和查询阿里云服务的相关资源。仅推荐在管控链路集成，消息收发的核心数据链路中严禁依赖 OpenAPI 实现，否则可能会导致链路产生风险。按 Group ID 查询死信消息的方式属于范围...
云存储网关利用MQTT服务实现统一管控
是一款可在用户的互联网数据中心IDC（Internet Data Center）和阿里云上部署的网关实例，以阿里云OSS为后端存储，通过低成本的虚拟机服务器，给云上和云下应用提供业界标准的NFS和CIFS文件存储服务，以及iSCSI的块存储服务。详细信息，请...
云消息队列 Kafka 版何时删除旧消息？
当往Kafka Topic中写入数据提示磁盘空间已满或 Queue full 时，为避免因磁盘容量不足而导致机器宕机，进而影响服务可用性，云消息队列 Kafka 版 会根据磁盘使用率的多少，执行不同的消息清理策略。清理策略 磁盘使用率每天凌晨4:00集中删除...
收发事务消息
当步骤1半事务消息发送完成，但本地事务返回状态为 TransactionStatus.Unknow 时，亦或是应用退出导致本地事务未提交任何状态时，从Broker的角度看，这条半状态的消息的状态是未知的，因此Broker会定期向消息发送方即消息生产者集群中的...
直播互动解决方案
RTC服务器 阿里云音视频通信RTC提供的音视频相关媒体通道服务。音视频通信RTC 阿里云覆盖全球的实时音视频开发平台，依托核心音视频编解码、信道传输、网络调度技术，提供高可用、高品质、超低延时的音视频通信服务，让用户快速搭建多端...
迁移数据上云
bin/kafka-consumer-groups.sh-new-consumer-describe-bootstrap-server自建集群接入点-group test-consumer-group 往自建集群中发送消息，在 云消息队列 Kafka 版 控制台中查看Topic的分区状态，确认当前服务器上消息总量是否正确。...
如何处理不活跃的Topic
当前服务器上消息总量（TotalCount）消息最后更新时间（LastTimeStamp）一般情况下，如果消息总量为0，说明Topic不活跃。一般情况下，如果消息最后更新时间是很久之前的有效时间戳，说明Topic不活跃。说明 如果消息最后更新时间为0或者负值...
物联网平台通信方式概述
云产品流转：使用规则引擎的云产品流转功能，通过数据流转规则将指定设备数据流转到消息服务（MNS）、云数据库RDS、表格存储、函数计算、时间序列数据库TSDB、云原生多模数据库Lindorm、DataHub、消息队列RocketMQ等云产品中。具体操作，请...
上下线通知规则管理
业务应用一般部署在阿里云的服务器上，业务应用通过向后端云产品订阅这条消息来获取所有客户端的上下线动作。流程说明 规则限制 限制项 限制值 说明 单实例规则数量 100 如果默认限制不满足，请联系 云消息队列 MQTT 版 技术支持，钉钉群号...
消息存储和清理机制
背景信息 参考 云消息队列 RocketMQ 版 中 队列 的定义，消息按照达到服务器的先后顺序被存储到队列中，理论上每个队列都支持无限存储。但是在实际部署场景中，服务端节点的物理存储空间有限，消息无法做到永久存储。因此，在实际使用中...
如何配置客户端参数？
达到设置的数值时，就会触发一次网络请求，然后Producer客户端把消息批量发往服务器。如果 batch.size 设置过小，有可能影响发送性能和稳定性。建议保持默认值16384。单位：字节。linger.ms 每条消息在缓存中的最长时间。若超过这个时间，...
发布者最佳实践
本文介绍 云消息队列 Kafka 版 发布者的最佳实践，帮助您降低发送消息的错误率。本文最佳实践基于Java客户端。对于其他语言的客户端，其基本概念与思想是相通的，但实现细节可能存在差异。发送消息 发送消息的示例代码如下：Future...
接口和参数说明
云消息队列 RocketMQ 版 提供Java SDK实现消息发送与订阅，订阅方可通过Push或Pull的方式从 云消息队列 RocketMQ 版 获取消息。本文介绍消息发送和订阅的接口和参数说明。背景信息 云消息队列 RocketMQ 版 支持以下两种消息获取方式：Push...
请求签名机制
如果请求时间和 消息服务MNS 服务器时间相差超过15分钟，消息服务MNS 会判定此请求不合法，返回错误码400。更多错误信息及错误码，请参见 错误响应格式。CanonicalizedMNSHeaders：HTTP中的 x-mns-开头的字段组合。该字段在签名验证前需要...
通知
消息服务MNS 不再提供Android SDK，如果您的客户端是Android操作系统，推荐您使用微消息队列MQTT。阿里云消息队列（MQ）推出 微消息队列MQTT，适用于移动互联网以及物联网应用，连接端（浏览器、Android、iOS、智能设备、互动直播、车联网...
通知
消息服务MNS 不再提供Objective-C iOS SDK，如果您的客户端是iOS操作系统，推荐您使用微消息队列MQTT。阿里云消息队列（MQ）推出 微消息队列MQTT，适用于移动互联网以及物联网应用，连接端（浏览器、Android、iOS、智能设备、互动直播、车...
获取MQTT客户端在线状态
业务应用一般部署在阿里云的服务器上，业务应用通过向后端存储消息队列订阅这条消息来获取所有客户端的上下线动作。该方式属于异步感知客户端的状态，且感知到的是上下线事件，而非在线状态，云端应用需要根据事件发生的时间序列分析出客户...
MQTT客户端上下线事件数据流出
您可通过配置 云消息队列 MQTT 版 的客户端上下线通知规则，将获取的MQTT客户端上下线事件数据导出至其他阿里云产品。该方法为异步上下线通知。本文介绍客户端上下线通知的原理、应用场景、使用限制以及 云消息队列 MQTT 版 与其他阿里云...
控制台看到的最近消费时间是什么意思？
消息发布到 云消息队列 Kafka 版 服务器的存储时间。控制台看到的 最近消费时间 是指消息发布到 云消息队列 Kafka 版 服务器的存储时间。如果消费没有堆积，那么这个时间接近发送时间。
- 产品推荐
- 这些文档可能帮助您