什么是云消息队列 MQTT 版
如果说传统的消息队列中间件一般应用于微服务之间，那么适用于物联网的 云消息队列 MQTT 版 则实现了端与云之间的消息传递和真正意义上的万物互联。本文介绍 云消息队列 MQTT 版 的消息收发模型、产品优势和应用场景。核心概念 Topic：消息...
JMS概述
背景信息 JMS是一种消息传递标准，允许基于Java EE（Java平台企业版）的应用程序组件创建、发送、接收、读取消息。JMS使分布式应用能够以松耦合、可靠、异步的方式进行通信。云消息队列 RabbitMQ 版 JMS库支持 JMS 1.1。云消息队列 ...
功能特性
这允许系统根据消息本身的特性、现有的业务需求或其他动态因素实时调整路由决策，从而提高了消息传递的灵活性和效率。元数据导入 安全合规 功能集 功能 功能描述 参考文档 数据加密 支持SASL、SSL接入点 SASL和SSL提供了两个关键的安全特性...
使用Spring Cloud框架收发消息
Spring Cloud是用于构建消息驱动的微服务应用程序的框架，提供服务发现、配置管理、消息传递、负载均衡等微服务相关的解决方案，可以更容易地构建分布式系统和进行服务间通信。本文介绍如何使用Spring Cloud框架接入 云消息队列 Kafka 版 ...
现代IM系统中的消息系统—架构
消息同步系统最重要的衡量指标就是消息传递的实时性、完整性以及能支撑的消息规模。在功能上，至少要支持在线和离线推送，有些IM系统还支持多端同步。消息存储：指消息的持久化保存。传统消息系统通常只能支持消息在接收端的本地存储，数据...
SDK列表
云消息队列 RabbitMQ 版 SDK（RAM角色跨账号授权场景）如果您是RAM STS角色授权的使用场景，需要通过 云消息队列 RabbitMQ 版 SDK收发消息，该SDK只比开源SDK多一个加签依赖。云消息队列 RabbitMQ 版 支持的多语言或框架SDK如 云消息队列 ...
常见问题
如何传递文本消息 Linux-SDK 提供了两种文本消息的传递模式：P2P 场景：推荐 DataChannel 传递，调用 Session->SendData 方法（高频消息，能保证按顺序收发）。其他场景：使用 Room 中转的模式，调用 Session->SendText 方法（低频消息可能...
什么是RRPC
RRPC订阅Topic 设备端订阅RRPC消息时传递的Topic，含有通配符。RRPC请求消息 物联网平台下发给设备端的消息。RRPC响应消息 设备端回复给物联网平台的消息。RRPC消息ID 物联网平台为每次RRPC调用，生成的唯一消息ID，可标识不同RRPC消息。...
消息队列
更正文档 概述 消息队列是一种任务间传递数据的有效方式。消息队列使用环形缓冲池（ring buffer）来管理消息的队列缓冲区，并使用类似信号量的机制进行任务间的同步。任务通过消息队列可以发送消息，也可以通过它接收消息，从而实现数据的...
非对称密钥概述
相比对称加密，非对称密钥通常用于在信任程度不对等的系统之间，实现数字签名验签或者加密传递敏感信息。非对称密钥由一对公钥和私钥组成，他们在密码学上互相关联，其中的公钥可以被分发给任何人，而私钥必须被安全的保护起来，只有受信任...
模型介绍
消息（Timeline）模型是针对消息数据场景所设计的，能够满足消息数据场景对消息保序、海量消息存储、实时同步的业务需求，同时支持全文检索与多维度组合查询。适用于IM、Feed流等消息场景。模型结构 消息模型以简单为设计目标，核心模块...
音视频通信解决方案（MQTT）
音视频管控服务还需要根据用户A邀请的信息找到用户B信息，同样封装一条邀请入会的消息，传递流程同 步骤2。会议参与者用户B收到参数后加入会议，本次通信初始化完成。基于上述设计思路，可以使用 云消息队列 MQTT 版 消息实现其他自定义...
通用WebSocket接入指南
回执消息格式：业务消息协议：消息内容：6{"messageId":"msg_1659937198426_687"} 消息格式：Text类型的DataFrame（字符串，编码：UTF-8）回执消息会带上对应消息的messageId，发送方可以根据是否收到回执消息才判断接收方是否成功接收到...
功能特性
Viber消息服务 一种流行于菲律宾、俄罗斯、白俄罗斯等国家的国际即时通讯软件，提供商业消息触达。功能集 功能 功能描述 参考文档 通道管理 服务ID管理 帮助客户注册Viber服务号。模板管理 模板管理 帮助客户管理Viber发送内容。消息发送 ...
StepMessage
简介 引擎用于描述消息在集成流中各个节点之间传递的数据结构。坐标：com.alibaba.bwif.script.core.StepMessage。结构说明 属性 类型 说明 id String 消息的唯一标识，每个节点的输入消息和输出消息ID都不同。attribute Map 用途：保存在...
使用云消息队列 Kafka 版时客户端的报错及解决方案
DisconnectException CORRUPT_MESSAGE 所有 如果是云存储引擎：客户端版本大于等于3.0时，自动开启幂等功能，但云存储不支持幂等功能 如果是Local存储引擎：发送compact消息，但未传递key值。如果是云储存引擎：设置 enable.idempotence=...
基本概念
消息（Message）消息队列中信息传递的载体。Message ID 消息的全局唯一标识，由 云消息队列 RocketMQ 版 系统自动生成，唯一标识某条消息。Message Key 消息的业务标识，由消息生产者（Producer）设置，唯一标识某个业务逻辑。Tag 消息标签...
集成流开发说明
每个节点每次运行时会包含三个环节：收到输入消息（input message）、运行本节点的逻辑（如请求某个应用的接口）、产生输出消息（output message）并向后传递。集成应用对消息结构（message）进行了统一的约定，类型为 StepMessage，主要...
基础术语
消息 Message 消息队列中信息传递的载体。Message ID Message ID 消息的全局唯一标识，由消息队列系统自动生成，唯一标识某条消息。Message Key Message Key 消息的业务标识，由消息生产者（Producer）设置，唯一标识某个业务逻辑。消息...
基本概念
消息 云消息队列 Kafka 版 中信息传递的载体。消息可以是网站的页面访问、服务器的日志，也可以是和CPU、内存相关的系统资源信息，但对于 云消息队列 Kafka 版，消息就是一个字节数组。消息保留时长 在磁盘容量充足的情况下，消息的最长...
什么是消息服务MNS
消息服务MNS 能够帮助开发者在应用的分布式组件之间自由地传递数据、通知消息，从而构建松耦合系统。消息服务MNS 支持队列模型和主题模型。队列模型 队列模型提供高可靠、高并发的一对一消费模型，即队列中的每一条消息都只能够被某一个...
超大消息传输
当消息内容大于64 KB以至于无法直接存入MNS队列时，不做消息切片，使用 消息服务MNS 和 对象存储OSS 来传递大于64 KB的消息。背景信息 消息服务MNS 的队列的消息大小最大限制是64 KB，这个限制基本能够满足在正常情况下消息作为控制流信息...
全球消息路由
全球消息路由功能不支持传递路由，例如实例A到实例B再到实例C，实例A的消息不会经过实例B再路由到实例C，如有需要请直接创建实例A到实例C的路由。鉴于消息同步的消息量以及网络带宽瓶颈，消息同步可能会产生一定的时间延迟。前提条件 云...
全球消息路由
全球消息路由功能可用于跨地域间的消息同步，通过路由规则将消息从源实例的Topic中同步到目标实例的Topic，并支持过滤规则，按照指定的Tag将消息过滤后再进行同步。在容灾备份或异地多活场景下，您可以创建全球消息路由任务，确保跨地域间...
创建RocketMQ Sink Connector
本文介绍如何在 云消息队列 Kafka 版 控制台创建消息流出任务，将 云消息队列 Kafka 版 的数据导出至 云消息队列 RocketMQ 版。前提条件 您已购买 云消息队列 RocketMQ 版 实例，且实例处于 服务中 状态。具体步骤，请参见 创建资源。您已...
用户属性
除了心跳报文，MQTT 5.0控制报文都支持设置用户属性，设备/应用程序可以通过用户属性传递额外的自定义信息。用户属性消息示例如下。Topic：“sys/${productkey}/${devicename}/update”Payload:"hello world!UserProperty:"key1_timestamp...
身份验证模板最佳实践
说明 如果您在发送消息之前不执行“握手”，或消息未通过资格检查，则发送的消息将显示复制验证码按钮(Copy code)，而不是一键自动填写按钮(Autofill)。资格检查 在收到身份验证模板消息之后，WhatsApp应用会执行以下检查。如果任意检查...
为什么Topic有分区时间显示1970或“-”？
可能原因 出现此问题的原因可能是以下情况中的一种：该分区没有消息数据，或者消息都已过期。客户端版本过低，或者传递的时间戳为null。Local存储引擎：开源Apache Kafka接口未提供该数据，所以未显示。云存储引擎：最近更新时间存在缓存...
作为Output接入
取值：none：无 snappy：用来压缩和解压缩的C++开发包 lz4：着重于压缩和解压缩速度的无损数据压缩算法 gzip：GNU自由软件的文件压缩程序 none max_message_bytes 最大消息大小。单位为字节。默认值为1000000。该值应小于您配置的 云消息...
作为Output接入
取值：none：无 snappy：用来压缩和解压缩的C++开发包 lz4：着重于压缩和解压缩速度的无损数据压缩算法 gzip：GNU自由软件的文件压缩程序 none max_message_bytes 最大消息大小。单位为字节。默认值为1000000。该值应小于您配置的 云消息...
什么是云消息队列 Confluent 版？
本文介绍 云消息队列 Confluent 版 的定义。什么是Confluent Platform Confluent Platform是一个全面的数据流企业级平台，使您能够以连续、实时的流形式轻松访问、存储和管理数据。Confluent由Apache Kafka的原始创建者构建，通过企业级...
顺序消息
如需保证消息生产的顺序性，则必须满足以下条件：同一消息组（MessageGroup）消息生产顺序性的范围为消息组，生产者发送消息时可以为每条消息设置消息组，只有同一消息组内的消息可以保证顺序性，不同消息组或未设置消息组的消息之间不保证...
HttpEndpoint
SIMPLIFIED精简格式 Request Body即为用户的消息正文，不做任何改动，MessageId会在Request Header中传递给用户。Request Request的构造由以下几个部分组成：请求行 POST/notifications HTTP/1.1 默认是/notifications，如果订阅者在创建...
HTTP Endpoint
SIMPLIFIED精简格式 Request Body即为用户的消息正文，不做任何改动，MessageId会在Request Header中传递给用户。Request Request的构造由以下几个部分组成：请求行 POST/notifications HTTP/1.1 默认是/notifications，如果订阅者在创建...
什么是MNS？
本文介绍 消息服务MNS 的概念。MNS是Message Service的简称，是阿里云提供的一种高效、可靠、安全、便捷、可弹性扩展的分布式消息服务。消息服务MNS 能够帮助应用开发者在应用的分布式组件上自由的传递数据，构建松耦合系统。
数字人回调事件通知
事件列表 事件类型 事件说明 事件内容 PLAY_START 数字人开始播报事件 eId:xxxx eType:PLAY_START eTime:1682068188783 sessionId:调用SendMessage接口传递的SessionId字段）uniqueCode:调用SendMessage接口传递的TextRequest.Id字段 PLAY_...
SDK概述
SDK简介 SDK（Software Development Kit）即软件开发工具包，包含示例Demo、库文件、编译工具链以及编译脚本等，不需要开发者进行任何其他的配置，直接可以在SDK对应目录环境下，进行开发、编译操作，方便开发者使用。SDK列表 云消息队列 ...
HTTP SDK错误码列表
详细信息，请参见对应的API文档：发送消息API 订阅消息API 确认消息API MessageNotExist Message not exist.404 Topic中无可用的消息。The receipt handle you provided has expired.404 消费消息过慢导致消息重新回到队列生成新的 ...
迁移自建Kafka集群至新实例
本文介绍如何在 云消息队列 Kafka 版 控制台创建并启动迁移任务。前提条件 下载JDK 8 安装Tsar 为了更准确的获取执行机器的配置，推荐您提前安装Tsar软件。您也可以在运行迁移工具时通过指定-installTsar 参数自动安装Tsar软件，但自动安装...
监控数据相关问题
一般情况下，您只需关注以下指标项：实例消息生产流量 Topic消息生产流量 Group未消费消息总数 其他指标项（如实例/Topic消息生产条数、实例/Topic消息生产发送次数、实例/Topic消息消费次数等）数据在流量比较小或客户端版本比较低时，会...
- 产品推荐
- 这些文档可能帮助您