配置消息日志
后续步骤 通过 云消息队列 RabbitMQ 版 SDK发送消息，并订阅消息。具体操作，请参见 SDK概述。查询消息。具体操作，请参见 查询消息。您可以登录 日志服务控制台 对日志进行查询与分析。具体操作，请参见 查询和分析日志。查询结果示例如下...
管理AMQP消费组
设置AMQP服务端订阅后，物联网平台会将收到的设备消息转发到相应消费组，每条被流转到消费组的消息会被其中一个消费者接收。本文介绍如何在物联网平台创建、查看和删除消费组。工作原理 AMQP服务端订阅 会将同一产品所有设备的指定类型消息...
Queue管理
Queue是指消息队列，云消息队列 RabbitMQ 版 的消息都会被投入到一个或多个Queue中。本文介绍如何在 云消息队列 RabbitMQ 版 控制台创建消息的存储资源Queue、查看Dashboard大盘、被Exchange绑定、向指定Queue发送消息、查看Consumer Tag、...
开通消息队列服务并授权
AliyunMQSubOnlyAccess 云消息队列 RocketMQ 版 的订阅权限，被授予该权限的RAM用户具有使用阿里云账号所有资源通过SDK订阅消息的权限。AliyunMQReadOnlyAccess 云消息队列 RocketMQ 版 的只读权限，被授予该权限的RAM用户仅有通过访问控制...
什么是消息解析
数据解析流程图：设备上报透传格式的属性或事件（上行数据）全流程图：调用设备服务或设置属性（下行数据）全流程图：物模型数据解析脚本编写示例，请参见：提交物模型消息解析脚本 JavaScript脚本示例 Python脚本示例 PHP脚本示例 若您的...
开通消息队列服务并授权
AliyunMQSubOnlyAccess 云消息队列 RocketMQ 版 的订阅权限，被授予该权限的RAM用户具有使用阿里云账号所有资源通过SDK订阅消息的权限。AliyunMQReadOnlyAccess 云消息队列 RocketMQ 版 的只读权限，被授予该权限的RAM用户仅有通过访问控制...
快速使用MQTT.fx模拟SDK收发消息
支持Windows、Mac和Linux操作系统，可用于验证设备是否可以连接 云消息队列 MQTT 版，并通过Topic发布和订阅消息。本文以Windows系统为例，介绍如何使用MQTT.fx模拟SDK接入 云消息队列 MQTT 版 并进行消息收发。前提条件 下载并安装 MQTT....
MQTT快速入门
步骤一：创建资源 这里所说的资源包括：云消息队列 MQTT 版 实例（用于客户端连接维持和消息转发）消息存储实例（用于消息的存储，目前只支持 云消息队列 RocketMQ 版 实例）Topic（用于消息发送和订阅的消息一级主题，即父级Topic）Group ...
JMS P2P（主账号与RAM账号场景）
前提条件 创建实例 创建Vhost 创建Exchange 创建Queue 创建绑定关系 背景信息 JMS P2P JMS P2P（点对点）消息收一条消息被一个指定的订阅者消费。某个发布者向某个Queue（队列）发送消息后，某个指定的订阅者从该Queue接收消息。发布者和...
数据转发到AMQP服务端订阅消费组
直接使用AMQP服务端订阅实时获取设备数据，只能从产品维度获取所有设备的数据，使用消息转发的云产品流转功能，可以将全部设备或指定设备发送到物联网平台的消息，先经过SQL表达式处理和过滤，再转发到AMQP服务端订阅消费组，通过AMQP客户...
在Knative上实现Kafka消息推送
根据界面提示信息，通过SDK订阅消息，或者执行Docker命令订阅消息。发送方式 选择 Docker，运行Docker容器。执行 运行 Docker 容器生产示例消息 区域的Docker命令，发送消息。执行 发送后如何消费消息？区域的Docker命令，订阅消息。发送...
JMS P2P（RAM角色跨账号授权场景）
前提条件 创建实例 创建Vhost 创建Exchange 创建Queue 创建绑定关系 背景信息 JMS P2P JMS P2P（点对点）消息收一条消息被一个指定的订阅者消费。某个发布者向某个Queue（队列）发送消息后，某个指定的订阅者从该Queue接收消息。发布者和...
快速入门概述
队列模型 队列模型消息流 队列模型特性 队列模型基本概念 主题模型：支持一对多的发布订阅模式。主题模型 主题模型消息流 主题模型特性 主题模型基本概念 队列模型快速入门 如 队列模型快速入门流程 所示，本教程以直接在控制台发送和接收...
开通服务并授权
AliyunMQSubOnlyAccess 云消息队列 MQTT 版 的订阅权限，被授予该权限的RAM用户具有使用阿里云账号所有资源通过SDK订阅消息的权限。AliyunMQReadOnlyAccess 云消息队列 MQTT 版 的只读权限，被授予该权限的RAM用户仅有通过访问控制台或调用...
如何快速测试云消息队列 Kafka 版服务端是否正常？
在创建并部署 云消息队列 Kafka 版 实例后，您可以使用 云消息队列 Kafka 版 控制台直接发送消息，快速测试服务端是否正常。前提条件 您已创建并部署 云消息队列 Kafka 版 实例，且实例处于 服务中 状态。操作流程 快速测试 云消息队列 ...
作为Input接入
根据界面提示信息，通过SDK订阅消息，或者执行Docker命令订阅消息。发送方式 选择 Docker，运行Docker容器。执行 运行 Docker 容器生产示例消息 区域的Docker命令，发送消息。执行 发送后如何消费消息？区域的Docker命令，订阅消息。发送...
步骤三：调用SDK收发消息
验证消息 消息收发完成后，您可以通过控制台查看消息消费情况。登录 控制台，在 实例列表 页面选择目标实例。在左侧导航栏单击 消息轨迹。SDK参考 本文以Java SDK为例介绍收发普通消息流程，其他语言SDK和其他类型消息的示例代码，请参见 ...
作为Input接入
根据界面提示信息，通过SDK订阅消息，或者执行Docker命令订阅消息。发送方式 选择 Docker，运行Docker容器。执行 运行 Docker 容器生产示例消息 区域的Docker命令，发送消息。执行 发送后如何消费消息？区域的Docker命令，订阅消息。发送...
订阅仪表盘
日志服务支持您订阅仪表盘，即定期将仪表盘渲染为图片，通过邮件、钉钉等方式发送给指定人员。本文介绍如何在日志服务控制台上订阅仪表盘。前提条件 已创建仪表盘。具体操作，请参见 创建仪表盘。...取消订阅后，不再向指定渠道发送订阅消息。
订阅消息API
订阅者可通过调用订阅消息API来消费 云消息队列 RocketMQ 版 服务端中的消息。请求构造 请求行 GET/topics/TopicName/messages?ns=INSTANCE_ID&consumer=GID&tag=taga&numOfMessages=3&waitseconds=3 HTTP/1.1 重要 请求行总长度不能超过...
作为Input接入
根据界面提示信息，通过SDK订阅消息，或者执行Docker命令订阅消息。发送方式 选择 Docker，运行Docker容器。执行 运行 Docker 容器生产示例消息 区域的Docker命令，发送消息。执行 发送后如何消费消息？区域的Docker命令，订阅消息。发送...
功能与特性概述
消息过滤：云消息队列 RocketMQ 版 支持设置消息属性给消息进行分类，云消息队列 RocketMQ 版 服务端会根据您订阅消息时设置的过滤条件对消息进行过滤，您将只消费到需要关注的消息。消息功能 消息查询：云消息队列 RocketMQ 版 提供了三种...
三方模型应用
History[x].Bot string 是 对话历史大的模型消息。是的 TopP float 否 生成时，核采样方法的概率阈值。例如，取值为0.8时，仅保留累计概率之和大于等于0.8的概率分布中的token，作为随机采样的候选集。取值范围为（0,1.0)，取值越大，生成...
作为Input接入
根据界面提示信息，通过SDK订阅消息，或者执行Docker命令订阅消息。发送方式 选择 Docker，运行Docker容器。执行 运行 Docker 容器生产示例消息 区域的Docker命令，发送消息。执行 发送后如何消费消息？区域的Docker命令，订阅消息。发送...
普通消息
典型场景一：微服务异步解耦 如上图所示，以在线的电商交易场景为例，上游订单系统将用户下单支付这一业务事件封装成独立的普通消息并发送至 云消息队列 RocketMQ 版 服务端，下游按需从服务端订阅消息并按照本地消费逻辑处理下游任务。...
消息轨迹
取值如下：成功 失败 消息基础信息 消息类型 普通消息 顺序消息 定时/延时消息 事务消息 消息ID 消息的全局唯一标识，由 云消息队列 RocketMQ 版 系统自动生成。Topic 消息所属的主题名称。消息Keys MessageKey，消息的业务标识，由消息...
插件和流程编排应用
History[x].Bot string 是 对话历史大的模型消息。是的 TopP float 否 生成时，核采样方法的概率阈值。例如，取值为0.8时，仅保留累计概率之和大于等于0.8的概率分布中的token，作为随机采样的候选集。取值范围为（0,1.0)，取值越大，生成...
检索增强应用
History[x].Bot string 是 对话历史大的模型消息。是的 TopP float 否 生成时，核采样方法的概率阈值。例如，取值为0.8时，仅保留累计概率之和大于等于0.8的概率分布中的token，作为随机采样的候选集。取值范围为（0,1.0)，取值越大，生成...
物模型透传开发
物模型消息的回调函数*/static void demo_dm_msg_callback(void*device,const aiot_dm_msg_t*dm_msg,void*userdata){ if(dm_msg=NULL){ return;} printf("[thing-message]recv msg type%d\r",dm_msg->type);switch(dm_msg->type){ case ...
应用开发手册
（数据消费方）应用可以通过查询数据模型的API接口获取消息，也可以通过数据变更消息订阅方式获取消息。数据模型支持图片文件上传，例如人脸通行事件的人脸照片 物业管理一体机框架：物业管理一体机是基于K8s框架实现的，底层是托管底座，...
广播拉取消息模型
消息服务MNS 支持一对多拉取消息消费模型，以满足一对多订阅、主动拉取的场景。本文介绍如何高效利用该模型实现多消费者并行拉取与处理消息。说明 本文以Java SDK为例介绍广播拉取消息流程，其他语言SDK请参见 新版SDK参考（推荐）。前提...
应用场景
通过 云消息队列 Kafka 版 的发布/订阅模型，您可以实时收集网站活动数据（例如注册、登录、充值、支付、购买），根据业务数据类型将消息发布到不同的Topic，然后利用订阅消息的实时投递，将消息流用于实时处理、实时监控或者加载到Hadoop...
基本概念
更多信息，请参见 云消息队列 Kafka 版的发布/订阅模型。订阅关系 Topic被 Group 订阅的情况。云消息队列 Kafka 版 支持查看订阅了指定Topic的在线 Group 的情况，非在线 Group 的情况无法查看。Producer 向 云消息队列 Kafka 版 发送消息...
消息通知概述
旨在提供一对多的发布订阅以及消息通知功能，支持您实现一站式多种消息通知方式，主题中的一条消息可以同时被多个订阅者订阅，且按照多个订阅指定的推送方式和服务器接入地址进行消息推送，您可以从多个渠道接收到该条消息。消息接收通知 ...
AMQP和JMS差异
本文介绍AMQP 0-9-1协议与JMS的差异性，帮助您更清楚地了解两种协议消息收发模型、消息类型以及消息流的不同。项目 AMQP 0-9-1协议 JMS 定义 线级协议 Java API 跨平台 是 否 跨语言 是 否 消息收发模型 4种消息收发模型：Direct Exchange ...
订阅关系（Subscription）
本文介绍 云消息队列 RocketMQ 版 中订阅关系（Subscription）的定义、模型关系、内部属性及使用建议。定义 订阅关系是 云消息队列 RocketMQ 版 系统中消费者获取消息、处理消息的规则和状态配置。订阅关系由消费者分组动态注册到服务端...
远程调试
运行测试用例前请注释StartService类@Componen防止启动自动运行三方节点的测试影响数据模型测试的效率 H2 注意：需要开启订阅功能才能获取消息，比如数据模型添加时选择订阅选项进入Http2Test类启动，运行测试用例前请注释StartService类@...
消费进度管理
消费位点（ConsumerOffset）云消息队列 RocketMQ 版 领域模型为发布订阅模式，每个主题的队列都可以被多个消费者分组订阅。若某条消息被某个消费者消费后直接被删除，则其他订阅了该主题的消费者将无法消费该消息。因此，云消息队列 ...
MQTT与RocketMQ的消息结构映射
消息结构映射 云消息队列 MQTT 版 和 云消息队列 RocketMQ 版 都是基于发布/订阅（Pub/Sub）模型的消息系统，两者概念上存在很多相似之处，下图列举了关键概念的区别和映射关系。如上图所示，在 云消息队列 MQTT 版 中Topic是多级结构，而 ...
直播互动解决方案
名词解释 MQTT 一个基于订阅/发布的长连接双向通信模型，订阅方便灵活，非常适合直播消息互动场景。云消息队列 MQTT 版 基于标准的MQTT协议，广泛服务于终端应用场景。MQTT服务器 云消息队列 MQTT 版 提供的MQTT协议交互的服务端节点，用于...
- 产品推荐
- 这些文档可能帮助您