现代IM系统中的消息系统—架构
消息服务器：一组无状态的服务器，可水平扩展，处理消息的发送和接收请求，连接后端消息系统。消息队列：新写入消息的缓冲队列，消息系统的前置消息存储，用于削峰填谷以及异步消费。消息处理：一组无状态的消费处理服务器，用于异步消费...
产品架构
集群级别的高可用，是 云消息队列 RocketMQ 版 跟其他的消息服务器的主要区别，消息生产者发送一条消息到消息服务器，消息服务器会随机的选择一个消费者，只要这个消费者消费成功就认为是成功了。重要 文中所提及的 云消息队列 RocketMQ 版...
产品架构
集群级别的高可用，是消息队列跟其他的消息服务器的主要区别，消息生产者发送一条消息到消息服务器，消息服务器会随机的选择一个消费者，只要这个消费者消费成功就认为是成功了。说明 文中所提及的消息队列的服务端或者服务器包含 Name ...
签名鉴权模式
签名计算方式 按照 鉴权概述 的描述，如果选择签名校验模式，MQTT客户端实际连接MQTT消息服务器时，connect 报文中的Username和Password需要按照本文约定的规范设置，具体设置和计算方法如下：Username 由鉴权模式名称、AccessKeyId和...
签名鉴权模式
签名计算方式 按照 鉴权概述 的描述，如果选择签名校验模式，MQTT客户端实际连接MQTT消息服务器时，connect 报文中的Username和Password需要按照本文约定的规范设置，具体设置和计算方法如下。Username 由鉴权模式名称、AccessKey ID和...
通信消息相关问题
云产品流转：使用消息转发的云产品流转功能，通过数据流转规则将指定设备数据流转到消息服务（MNS）的主题或消息队列（RocketMQ）的队列中。服务器通过MNS或RocketMQ SDK接收消息。详细内容，请参见 云产品流转概述。已配置MNS服务端订阅，...
漏洞公告|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，...
什么是Topic
代理者（Broker）是设备和业务服务器消息通信的中介，解耦了设备和业务服务器，实现了设备和业务服务器之间的异步通信。MQTT协议消息的组成部分 主题（Topic）：使用正斜杠（/）作为分隔符构造字符串，例如/${productKey}/${deviceName}/...
应用总览
应用服务被调用-service 应用总量、LDC 总量、IDC 总量、接口方法明细、来源应用、服务器、应用实例 SQL 耗时检测-sql 应用 Top Flow Limit-flowlimit 应用总量、LDC 总量、IDC 总量、服务器 消息发布-msgpub 应用总量、LDC 总量、IDC 总量...
应用总览
Top Flow Limit-flowlimit 应用总量、LDC 总量、IDC 总量、服务器 消息发布-msgpub 应用总量、LDC 总量、IDC 总量、Topic Eventcode 总量、服务器、应用实例 消息订阅-msgsub 应用总量、LDC 总量、IDC 总量、Topic Eventcode 总量、服务器...
一机一密概述
计算方式 按照 鉴权概述 的描述，如果选择一机一密鉴权模式，MQTT客户端实际连接MQTT消息服务器时，connect 报文中的Username和Password需要按照本文约定的规范设置，具体设置和计算方法如下：Username 由鉴权模式名称、DeviceAccessKeyId...
产品架构
本文介绍 云消息队列 Kafka 版 的系统架构和发布/订阅模型。云消息队列 Kafka 版 系统架构 如 云消息队列 Kafka 版的系统架构 所示，一个 云消息队列 Kafka 版 集群包括Producer、Kafka Broker、Group、ZooKeeper。图 1.云消息队列 Kafka ...
Token鉴权概述
MQTT服务器 云消息队列 MQTT 版 权限认证和消息收发服务器，用来处理应用服务器发起的Token相关的请求以及消息收发业务。使用流程 Token鉴权模式相比签名模式更加复杂，您需要按照下图所示的流程，部署您的应用服务器。而且在初始化时，...
Token鉴权概述
MQTT服务器 云消息队列 MQTT 版 权限认证和消息收发服务器，用来处理应用服务器发起的Token相关的请求以及消息收发业务。使用流程 Token鉴权模式相比签名模式更加复杂，您需要按照下图所示的流程，部署您的应用服务器。而且在初始化时，...
产品简介
平台提供通讯录管理、即时通讯、音视频、消息触达、应用接入能力，支持专有云部署。助力解决三融五跨组织数字化协同、沟通和统一工作门户的问题。客户群体 金融行业：助力监管机构、银行、证券、保险行业企业构建专有的移动数字化协同体系...
OnsMessageDetail-查询消息详细信息
1E0578FE110F18B4AAC235C05F2*StoreHost string 存储该消息的服务器实例。11.220.*.*:10911 Topic string 消息所属的 Topic。test-mq_topic PropertyList object[]消息属性列表。Value string 消息属性的取值。MSG_REGION Name string 消息...
OnsMessageGetByMsgId-通过MsgId查询消息
通过传入 Message ID 查询指定消息的信息以及判断该指定的消息是否曾被消费过。接口说明 注意 阿里云提供的 OpenAPI 属于管控类 API，用于管理和查询阿里云服务的相关资源。仅推荐在管控链路集成，消息收发的核心数据链路中严禁依赖 Open...
自定义鉴权模式
MQTT服务器 云消息队列 MQTT 版 权限认证和消息收发服务器，用来处理应用服务器发起的鉴权相关的请求以及消息收发业务。使用说明 无论使用何种鉴权模式，本质上可以归结为身份认证和资源权限两个基本功能。身份认证，即客户端的身份标识，...
OnsDLQMessageGetById-根据Message ID查询死信消息
0BC16699165C03B925DB8A404E2D*StoreHost string 存储该消息的服务器实例。11.220.*.*:10911 Topic string 消息的 Topic。test-mq_topic PropertyList object[]消息属性列表。Value string 消息属性的取值。TagA Name string 消息属性。...
OnsMessageGetByKey-根据Message Key查询消息
1E0578FE110F18B4AAC235C05F2*StoreHost string 存储该消息的服务器实例。11.193.*.*:10911 Topic string 消息的 Topic。test-mq_topic PropertyList object[]消息属性列表。Value string 消息属性的取值。TagA Name string 消息属性。取值...
物联网平台通信方式概述
云产品流转：使用规则引擎的云产品流转功能，通过数据流转规则将指定设备数据流转到消息服务（MNS）、云数据库RDS、表格存储、函数计算、时间序列数据库TSDB、云原生多模数据库Lindorm、DataHub、消息队列RocketMQ等云产品中。具体操作，请...
OnsMessagePageQueryByTopic-查询Topic内所有消息
1E0578FE110F18B4AAC235C05F2*StoreHost string 存储该消息的服务器实例。11.193.*.*:10911 Topic string 消息的 Topic。test-mq_topic PropertyList object[]消息属性列表。Value string 消息属性的取值。TagA Name string 消息属性。取值...
查询Group ID内所有死信消息
1E0578FE110F18B4AAC235C05F2*StoreHost string 存储该消息的服务器实例。11.193.*.*:10911 Topic string 消息的 Topic。test-mq_topic PropertyList object[]消息属性列表。Value string 消息属性的取值。TagA Name string 消息属性。取值...
新零售电子价签解决方案（MQTT）
MQTT服务器 云消息队列 MQTT 版 提供的MQTT协议交互的服务端节点，用于接收消息并转发消息。MQTT客户端 用于和MQTT服务器交互的节点，本方案中特指发送或接收价格变更消息的智能AP。P2P消息 云消息队列 MQTT 版 在标准的MQTT协议基础上提供...
消息加密传输
本文介绍如何进一步提高您与 消息服务MNS 服务之间的网络链路上的安全性。背景信息 消息服务MNS 提供在公网HTTPS上进行消息加密传输的服务。对于包含敏感信息的消息，进一步提高您与阿里云服务之间的网络链路上的安全性，目前有以下两种...
使用自定义Topic进行通信
背景信息 本示例中，电子温度计通过订阅自定义Topic接收指令，通过向自定义Topic发布消息从而上报温度，物联网平台将收到的温度信息通过AMQP服务端转发到用户服务器，用户服务器调用Pub接口向自定义Topic发布消息从而实现对设备的远程精度...
名词解释
MQTT服务器 云消息队列 MQTT 版 提供的MQTT协议交互的服务端节点，用于完成与MQTT客户端和 云消息队列 RocketMQ 版 各自的消息收发。MQTT客户端 用于和MQTT服务器交互的移动端节点，全称为 云消息队列 MQTT 版 客户端。P2P消息 云消息队列 ...
云消息队列 Kafka 版何时删除旧消息？
当往Kafka Topic中写入数据提示磁盘空间已满或 Queue full 时，为避免因磁盘容量不足而导致机器宕机，进而影响服务可用性，云消息队列 Kafka 版 会根据磁盘使用率的多少，执行不同的消息清理策略。清理策略 磁盘使用率每天凌晨4:00集中删除...
收发事务消息
当步骤1半事务消息发送完成，但本地事务返回状态为 TransactionStatus.Unknow 时，亦或是应用退出导致本地事务未提交任何状态时，从Broker的角度看，这条半状态的消息的状态是未知的，因此Broker会定期向消息发送方即消息生产者集群中的...
音视频通信解决方案（MQTT）
MQTT服务器 云消息队列 MQTT 版 提供的MQTT协议交互的服务端节点，用于完成与MQTT客户端和 云消息队列 RocketMQ 版 各自的消息收发。MQTT客户端 用于和MQTT服务器交互的移动端节点，本方案中特指发送或接收音视频通话请求的音视频移动端...
收发事务消息
本文提供使用TCP协议下的社区版Java SDK收发事务消息的示例代码供您参考。交互流程 事务消息交互流程如下图所示。更多信息，请参见 事务消息。前提条件 您已完成以下操作：下载4.5.2或以上版本的社区版 Java SDK。准备工作。获取阿里云访问...
直播互动解决方案
MQTT服务器 云消息队列 MQTT 版 提供的MQTT协议交互的服务端节点，用于完成与MQTT客户端和 云消息队列 RocketMQ 版 各自的消息收发。MQTT客户端 用于和MQTT服务器交互的移动端节点，全称为 云消息队列 MQTT 版 客户端。父级Topic（Parent ...
迁移数据上云
bin/kafka-consumer-groups.sh-new-consumer-describe-bootstrap-server自建集群接入点-group test-consumer-group 往自建集群中发送消息，在 云消息队列 Kafka 版 控制台中查看Topic的分区状态，确认当前服务器上消息总量是否正确。...
云存储网关利用MQTT服务实现统一管控
MQTT服务器 云消息队列 MQTT 版 提供的MQTT协议交互的服务端节点，用于接收消息并转发消息。MQTT客户端 用于和MQTT服务器交互的节点，本方案中特指CSG实例侧的客户端。RDS 阿里云推出的一种稳定可靠、可弹性伸缩的在线数据库服务。SLS 阿里...
如何处理不活跃的Topic
当前服务器上消息总量（TotalCount）消息最后更新时间（LastTimeStamp）一般情况下，如果消息总量为0，说明Topic不活跃。一般情况下，如果消息最后更新时间是很久之前的有效时间戳，说明Topic不活跃。说明 如果消息最后更新时间为0或者负值...
使用Topic通信
将指定设备数据流转到消息服务（MNS）、云数据库RDS、表格存储、函数计算、时间序列数据库TSDB、云原生多模数据库Lindorm、DataHub、消息队列RocketMQ等云产品中。云产品流转的概念、流程请参见 云产品流转概述。可选步骤 查看云端日志 ...
如何配置客户端参数？
达到设置的数值时，就会触发一次网络请求，然后Producer客户端把消息批量发往服务器。如果 batch.size 设置过小，有可能影响发送性能和稳定性。建议保持默认值16384。单位：字节。linger.ms 每条消息在缓存中的最长时间。若超过这个时间，...
设备状态相关问题
超过最大超时时间未收到设备消息，服务器会自动断开连接，设备状态变为离线。综上所述，设备异常离线后，判断设备离线需要时间，设备状态的变更通知消息就会延迟。设备状态变更通知的状态与设备实际状态不一致，为什么？因设备状态变更通知...
消息存储和清理机制
背景信息 参考 云消息队列 RocketMQ 版 中 队列 的定义，消息按照达到服务器的先后顺序被存储到队列中，理论上每个队列都支持无限存储。但是在实际部署场景中，服务端节点的物理存储空间有限，消息无法做到永久存储。因此，在实际使用中...
发布者最佳实践
本文介绍 云消息队列 Kafka 版 发布者的最佳实践，帮助您降低发送消息的错误率。本文最佳实践基于Java客户端。对于其他语言的客户端，其基本概念与思想是相通的，但实现细节可能存在差异。发送消息 发送消息的示例代码如下：Future...
- 产品推荐
- 这些文档可能帮助您