日志管理概述
消费端宕机了，消费失败的消息什么时候可以再次被消费？消息发布到主题，Endpoint却迟迟收不到消息？想看一个月前的消息操作日志？这些问题可以通过 消息服务MNS 的日志管理功能解决，方法如下：将日志推送到 SLS，在控制台查看完整消息...
主题模型快速入门
重试策略支持选择以下任一类型：退避重试 指数衰减重试 消息推送格式：设置推送消息到接收端的消息格式。消息推送格式可以选择以下任一类型：SIMPLIFIED JSON XML 订阅管理 页面目标订阅已创建。发布消息 您可以在控制台把向主题发布的消息...
主题控制台操作帮助
重试策略支持选择以下任一类型：退避重试 指数衰减重试 消息推送格式：设置推送消息到接收端的消息格式。消息推送格式可以选择以下任一类型：SIMPLIFIED JSON XML 订阅管理 页面目标订阅已创建。编辑订阅 登录 消息服务MNS控制台。在左侧...
主题控制台操作帮助
重试策略支持选择以下任一类型：退避重试 指数衰减重试 消息推送格式：设置推送消息到接收端的消息格式。消息推送格式可以选择以下任一类型：SIMPLIFIED JSON XML 订阅管理 页面目标订阅已创建。编辑订阅 登录 消息服务MNS控制台。在左侧...
使用示例
当设备收到消息后，您可通过消息的Topic格式，确认消息是否为广播消息。该类型消息的Topic格式为/sys/${productKey}/${deviceName}/broadcast/request/${MessageId}。如果需指定Topic的所有设备接收广播消息，需订阅该Topic。广播通信的...
通信消息相关问题
发送到MNS队列中的消息格式：{"messageid":"12345","messagetype":"status/upload","topic":"null/topic","payload":{},"timestamp":1469564576 } 您可根据 topic 字段进行判断。如何从物联网平台云端下发指令到设备端？您可调用物联网平台...
升级实例版本
由于2.x版本的消息存储格式与0.10.x版本不同，您在完成升级之后，将无法回退到0.10.x版本，请您谨慎操作。升级小版本 升级小版本是指非跨大版本的升级，主要是修复开源Bug和性能优化，不涉及兼容性问题。例如将 云消息队列 Kafka 版 实例的...
Token客户端接口
接收Topic：$SYS/tokenExpireNotice 内容：JSONString 内容信息：名称 类型 说明 expireTime Long 该Token即将于什么时候失效，格式为毫秒时间戳，一般提前5分钟通知，只通知一次，但服务端不保证一定会有通知。type String Token类型，...
Token客户端接口
接收Topic：$SYS/tokenExpireNotice 内容：JSONString 内容信息：名称 类型 说明 expireTime Long 该Token即将于什么时候失效，格式为毫秒时间戳，一般提前5分钟通知，只通知一次，但服务端不保证一定会有通知。type String Token类型，...
主题+HTTP Endpoint使用手册
服务器功能：对 消息服务MNS 推送消息请求做签名验证。如果错误，返回MNS 403。说明 示例中HTTP Endpoint的针对Authorization的校验不能完全规避掉恶意伪造的MNS请求，需要从业务层面上设计从发送端到HTTP Endpoint的安全校验机制。解析推...
设备属性、事件、服务
当您为产品定义物模型后，设备需要按照 Alink JSON 格式 上报属性 或 事件，如果使用其他格式需要通过消息解析功能转化，服务端 设置属性 或 调用服务 同样要满足 Alink JSON 格式。本文为您介绍物模型数据的 Alink JSON 格式和Topic。背景...
收发事务消息
本文提供使用TCP协议下的Java SDK收发事务消息的示例代码。云消息队列 RocketMQ 版 提供类似XA或Open XA的分布式事务功能，通过 云消息队列 RocketMQ 版 事务消息，能达到分布式事务的最终一致。说明 对于新手用户，建议在正式收发消息前，...
蓝牙BLE业务流程与体脂秤示例
Attr Type 2 0x0200 Attr Parameter 2 体重值 Attr Type 2 0x0201 Attr Parameter 2 体脂值 上报体重体脂数据（使用Vendor Message Attr Indication）上报体重体脂数据可以使用Vendor Message Attr Indication，消息格式如下。字段 字节数 ...
GetSubscriptionAttributes
取值说明如下：XML JSON SIMPLIFIED 消息格式的具体描述，请参见 NotifyContentFormat。FilterTag String important 描述了该订阅中消息过滤的标签（仅标签一致的消息才会被推送）。CreateTime Long 1449554806 Subscription的创建时间，从...
消息格式描述
本文介绍物联网平台支持的MQTT 5.0新特性的消息格式描述。功能说明 MQTT 5.0增加了两个属性描述消息的格式：有效载荷标识（Payload Format Indicator）和内容类型（Content Type）。这两属性可以应用到发布消息（Publish）或者遗嘱消息中。...
示例代码
云消息队列 RocketMQ 版 5.x版本实例可兼容Java ONS 1.x SDK客户端接入，您可以使用ONS 1.x SDK的接入5.x实例进行消息收发。本文为您介绍Java ONS 1.x SDK消息收发示例代码。重要 推荐您使用最新的RocketMQ 5.x系列SDK，5.x系列SDK作为主力...
发送普通消息（三种方式）
云消息队列 RocketMQ 版 提供三种方式来发送普通消息：同步（Sync）发送、异步（Async）发送和单向（Oneway）发送。本文介绍了每种发送方式的原理、应用场景、示例代码，以及三种发送方式的对比。前提条件 安装Java SDK。更多信息，请参见 ...
MQTT与RocketMQ的消息结构映射
本文针对使用 云消息队列 RocketMQ 版 SDK与 云消息队列 MQTT 版 交互的场景，提供交互中所涉及的消息结构和属性字段的映射关系，方便您更好的理解和组合使用这两个产品。云消息队列 MQTT 版 是一款面向移动端的网关产品，可通过数据互通...
如何配置MNS以支持更大的消息大小？
本文介绍如何配置 消息服务MNS 以支持更大的消息大小。要配置最大消息大小，请使用SetQueueAttributes方法设置MaximumMessageSize属性。此属性指定队列中的消息可以包含的字节数限值。可以设置为1024字节（1 KB）到最大65536字节（64 KB）...
设备使用物模型通信
物模型消息解析：如果设备的消息格式不是 Alink JSON，必须使用消息解析将设备上报的 自定义格式 数据解析为 Alink JSON 格式，将物联网平台下发的Alink JSON格式数据解析为设备自定义格式的数据。服务端订阅 和 云产品流转：如果需要将...
物联网平台通信方式概述
需在设备端配置发送消息的自定义Topic和消息格式。使用阿里云提供的Link SDK配置示例，请参见 设备发送消息给服务器。使用物模型功能相关Topic，发送标准化的物模型数据。物模型功能说明，请参见 什么是物模型。使用示例，请参见 使用IoT ...
顺序消息
顺序消息可以保证消息的消费顺序和发送的顺序一致，即先发送的先消费，后发送的后消费，常用于金融证券、电商业务等对消息指令顺序有严格要求的场景。本文介绍 云消息队列 RocketMQ 版 顺序消息的概念、适用场景、实现原理以及使用过程中的...
产品架构
本文介绍 云消息队列 Kafka 版 的系统架构和发布/订阅模型。云消息队列 Kafka 版 系统架构 如 云消息队列 Kafka 版的系统架构 所示，一个 云消息队列 Kafka 版 集群包括Producer、Kafka Broker、Group、ZooKeeper。图 1.云消息队列 Kafka ...
MQTT和RocketMQ进行数据互通（客户端上下线通知）
MQTT客户端的上下线事件将会触发MQTT服务端生成一条通知消息，云消息队列 MQTT 版 支持将该条消息数据导出至其他阿里云产品，并使用MQTT的Java SDK实现MQTT客户端与后端应用收发消息。本文以当前仅支持的 云消息队列 RocketMQ 版 数据互通...
使用自定义Topic通信
相关文档 物联网平台要求设备上报消息的数据格式要求为Alink JSON，如果设备的消息格式不是Alink JSON，必须使用消息解析将设备上报的自定义Topic数据解析为Alink JSON格式，通过自定义Topic下发设备的数据格式没有限制。消息解析的概念和...
使用Topic通信
自定义Topic 如果设备的消息格式不是 Alink JSON，必须使用 消息解析 将设备上报的自定义Topic数据解析为 Alink JSON 格式，通过自定义Topic下发设备的数据格式没有限制。消息解析的概念和使用步骤，请参见 什么是消息解析。物模型Topic ...
JMS概述
云消息队列 RabbitMQ 版 提供JMS库供JMS客户端接入 云消息队列 RabbitMQ 版。本文介绍 云消息队列 RabbitMQ 版 JMS库的相关概念、获取方式、使用限制和使用教程。背景信息 JMS是一种消息传递标准，允许基于Java EE（Java平台企业版）的应用...
基本概念
消息标签（MessageTag）消息标签是 云消息队列 RocketMQ 版 提供的细粒度消息分类属性，可以在主题层级之下做消息类型的细分。消费者通过订阅特定的标签来实现细粒度过滤。更多信息，请参见 消息过滤。消息位点（MessageQueueOffset）消息...
消息负载均衡策略
生产者负载均衡策略 无序消息（普通消息、事务消息、定时和延时消息）：Producer将消息以轮询的方式发送至Queue，如下图所示：图中Msg1、Msg2代表第一条消息、第二条消息，生产者会把第一条消息发送至Queue 1，然后第二条消息发送至Queue 2...
消费幂等
为了防止消息重复消费导致业务处理异常，消息队列RocketMQ版 的消费者在接收到消息后，有必要根据业务上的唯一Key对消息做幂等处理。本文介绍消息幂等的概念、适用场景以及处理方法。什么是消息幂等 当出现消费者对某条消息重复消费的情况...
事件内容转换
例如，您源端的事件来自 云消息队列 RocketMQ 版，而目标端是消息服务MNS，那么您可以使用Event Transform将来自 云消息队列 RocketMQ 版 的事件内容转换为MNS需要的事件内容。转换说明 事件被转换后，事件总线EventBridge 不会对返回的...
应用场景
同时，由于使用了 云消息队列 RocketMQ 版，只要保证消息格式不变，消息的发送方和接收方并不需要彼此联系，也不需要受对方的影响，即解耦。分布式事务的数据一致性 注册系统注册的流程中，用户入口在网页注册系统，通知系统在邮件系统，两...
在线教育视频直播
场景描述 适用于在线教育的视频直播场景，通过阿里云视频直播服务实现移动端的推拉流能力，同时移动端利用 云消息队列 MQTT 版 实现发送和接收消息，在消息转发时利用内容安全服务对消息内容进行审核。发送的消息可以存储在表格存储中。...
接入点对比
云消息队列 Kafka 版 提供默认接入点、SSL接入点和SASL接入点以适用不同的连接及安全需求。默认接入点适用于在保密性较高的VPC环境收发消息；SASL接入点适用于无需对传输链路加密但需对消息收发鉴权；需要链路加密和消息鉴权，建议使用SSL...
定时/延时消息
定时/延时消息为 云消息队列 RocketMQ 版 中的高级特性消息，本文为您介绍定时/延时消息的应用场景、功能原理、使用限制、使用方法和使用建议。应用场景 说明 定时消息和延时消息本质相同，都是服务端根据消息设置的定时时间在某一固定时刻...
QueueMessage
消息发送到队列中，MNS会生成一个MessageId，该编号一旦生成就不会变化，可以用来做数据校对。NextVisibleTime 消息下次可被消费的时间，从1970-01-01 00:00:00 000开始的毫秒数。（batch）receive message和change message visibility操作...
收发普通消息
普通消息是指 云消息队列 RocketMQ 版 中无特性的消息，区别于有特性的定时和延时消息、顺序消息和事务消息。本文提供使用HTTP协议下的PHP SDK收发普通消息的示例代码。前提条件 您已完成以下操作：安装PHP SDK。更多信息，请参见 准备环境...
收发定时消息
定时消息可以做到在指定时间戳之后才可被消费者消费，适用于对消息生产和消费有时间窗口要求，或者利用消息触发定时任务的场景。定时消息的概念介绍及使用过程中的注意事项，请参见 定时和延时消息。前提条件 下载.NET SDK。更多信息，请...
主题使用手册
步骤四：创建订阅 对已创建的主题进行订阅，在订阅时需要设置对应的推送Endpoint地址（目前支持HTTP、邮件、队列、移动推送以及短信）、错误重试策略、推送消息格式等。public class SubscribeDemo { public static void main(String[]args...
领域模型概述
消息队列RocketMQ版领域模型 如上图所示，云消息队列 RocketMQ 版 中消息的生命周期主要分为消息生产、消息存储、消息消费这三部分。生产者生产消息并发送至 云消息队列 RocketMQ 版 服务端，消息被存储在服务端的主题中，消费者通过订阅...
- 产品推荐
- 这些文档可能帮助您