MQTT触发器可以订阅分布式消息服务MQTT并根据消息触发关联的函数，借此能力，使得函数可以消费指定Topic的消息，执行自定义处理逻辑。 前提条件 已创建函数。 已创建MQTT实例 操作步骤 1. 登录函数计算控制台，点击目标函数，进入函数详情。 2. 选择详情下顶部的配置选项卡。 3. 在配置选项卡中，选择左边的触发器选项卡。 4. 点击创建触发器 ，在弹出的右抽屉中选择MQTT触发器，配置参数解释如下: 配置项 操作 示例 触发器类型 选择MQTT触发器。 MQTT触发器 名称 填写自定义的触发器名称。 mqtttrigger 版本或别名 默认值为LATEST，支持选择任意函数版本或函数别名。 LATEST MQTT实例 选择已创建的MQTT实例。 Topic 填写订阅的消息Topic，请确保topic的命名符合以下"^[azAZ09/ +]+$"正则表达式 mytopic 调用方法 选择函数调用方式。 同步调用 ：指触发器消费消息后投递到函数是同步调用，会等待函数响应后继续下一个消息投递。 异步调用：指触发器消费消息后投递到函数是异步调用，不会等待函数响应，可以快速消费事件。 用户ID 终端设备连接MQTT队列需要先创建用户密码，详情请查看认证授权 密钥 终端设备连接MQTT队列需要先创建用户密码，详情请查看认证授权 触发器启用状态 创建触发器后是否立即启用。默认选择开启，即创建触发器后立即启用触发器。 启用 注意 需要对用户名进行主题授权，MQTT触发器才能正常工作

本文为您介绍分布式消息服务MQTT的创建实例内容。 实例介绍 MQTT实例订购支持用户自定义规格和自定义特性，采用物理隔离的方式部署。租户独占MQTT实例，可根据业务需要可定制相应规格的MQTT实例。在新的资源池节点上，还支持选择主机类型和存储规格等丰富用户选项。 操作步骤 1、在产品详情页点击立即开通按钮，或者进入消息管理控制台订购实例，进入订购分布式消息MQTT页面。 2、 订购实例，注意选择产品规格。 （1）填写实例名称，长度4~40个字符，大小写字母开头，只能包含大小写字母、数字及分隔符()。 （2）选择计费模式：包年包月/按需计费，两种模式说明参见计费模式。 （3）购买时长按照计费模式选择变化： 计费模式为包年包月，可选择购买时长16个月、13年。该模式提供自动续期功能，勾选后可以自动续期购买时长：16个月、13年。 计费模式为按需计费，则该选项隐藏无需选择。 （4）部署方式有单可用区和多可用区两个选项，目前仅支持单可用区和3可用区部署,单可用区部署请选中任意一个AZ；多可用区部署请选中3个AZ，系统会自动将Broker节点平均分配至各可用区。 （5）设置节点数，可输入3~16个。MQTT 的节点数是指MQTT 集群中的节点数量。在MQTT 集群中，可以有多个节点组成一个集群，每个节点都是一个独立的MQTT 服务器实例。 （6）下拉选择主机类型，目前提供计算增强型。计算增强型云主机独享宿主机的CPU资源，实例间无CPU争抢，并且没有进行资源超配，同时搭载全新网络加速引擎，实现接近物理服务器的强劲稳定性能。 （7）选择实例规格，分布式消息服务MQTT提供计算增强型多种云主机规格，各规格详细说明参见弹性云主机规格。 （8）选择已有虚拟私有云，若无虚拟私有云，点击创建跳转到虚拟私有云页面新增，了解更多内容参见虚拟私有云。 （9）选择已有子网，若无子网，点击创建跳转到子网页面新增，了解更多内容参见虚拟私有云子网管理 创建子网。 （10）选择已有安全组，若无安全组，点击创建跳转到安全组页面新增，了解更多内容参见虚拟私有云安全组 创建安全组。 3、 填写完上述信息后，单击“下一步”，进入费用确认页面。 4、 确认实例信息无误后，提交请求。 5、 在实例列表页面，查看MQTT实例是否创建成功。创建实例大约需要3到15分钟，此时实例状态为“创建中”。

本文为您介绍分布式消息服务MQTT的API消息发送。 POST ContentType：application/json 请求体json参数说明： 参数名 参数类型 是否必填 参数描述 prodInstId String 是 实例ID mqttTopic String 是 MQTT主题 payload String 是 消息内容 返回参数说明： 参数名 参数类型 参数描述 message String 描述状态 statusCode Integer 800成功 其他失败 成功 { "message": "success","statusCode": "800"} 失败 {"returnObj": null,"message": "error","statusCode": "900"}

本文为您介绍分布式消息服务MQTT各功能项使用限制。 功能信息项 限制值 说明 实例名称 长度4~40个字符，大小写字母开头，只能包含大小写字母、数字及分隔符() 实例名称不可重复。 Topic 长度 64 个字符 Topic 长度不得超过该限制，否则会导致无法发送或者订阅。 Topic 和 Client ID 可用字符 仅限数字 09，字母 az 或 AZ，和符号“”、“” Client ID 和MQTT 的 Topic 不允许使用“/”、“:”、“,”、“%”等其他非常规字符，否则可能导致无法连接和收发消息。 Client ID 长度 64 个字符 使用微消息队列 MQTT 收发消息时，Client ID 长度不得超过该限制，否则会导致连接被断开。 消息大小 64 KB 字节 消息负载不得超过该限制，否则消息会被丢弃。 单个设备订阅Topic 数量 30 个 每个客户端最多允许同时订阅 30 个 Topic，超过该限制会导致无法新增新的订阅关系。 每个持久化会话离线消息存储数量 1,000,条 服务端会限制每个持久化会话的离线消息数量。超过该限制后，服务端会从最早的消息开始清理。因此，请合理使用持久化订阅模式，以免产生很多无用的离线消息。

为了让更多客户享受到分布式消息MQTT产品服务，我们致力于为客户提供更具竞争力的价格，并持续提升服务质量。 分布式消息服务MQTT自9月25日起开始启用新资费计价，老资费通用型同规格对比新费用降幅达78%84%。 实例规格参数 实例价格费用明细 降幅 实例规格参数 调整前 调整后 降幅 实例规格参数 单价（元/节点/月） 总费用（元/月） 单价（元/节点/月） 总费用（元/月） 降幅 s7.xlarge.4，4vCPUs 16GiB，3节点 4548 13644 720 2160 84% s7.2xlarge.4，8vCPUs 32GiB，3节点 8288 24864 1620 4860 80% s7.4xlarge.4，16vCPUs 64GiB，3节点 14976 44928 3240 9720 78% 同时新增包年折扣优惠，即日起订购分布式消息服务MQTT产品享受1年83折 优惠，11月将陆续开放2年7折，3年5折优惠选项，具体开放时间敬请关注产品公告。 此外，为保障更优的性能，11月计划上架Intel计算增强型规格，原通用型规格将调整为白名单特性，原老客户实例续订不受影响，新用户和新实例订购推荐开通计算增强型规格产品。

本文为您介绍分布式消息服务MQTT的计费模式。 目前天翼云分布式消息服务MQTT提供包周期（包年/包月）、按需2种计费模式供您灵活选择，使用越久越便宜。 下表列出两种模式的区别： 计费模式 包年/包月 按需计费 付费方式 预付费按照订单的购买周期结算。 后付费按照云服务器实际使用时长计费。 计费周期 按订单的购买周期计费。 按小时结算。 实例升级 暂不支持实例升级。 暂不支持实例升级。 更改计费模式 不支持变更为按需资源。 不支持变更为包周期资源。 变更规格 暂不支持变更实例规格。 暂不支持变更实例规格。 适用场景 适用于可预估资源使用周期的场景，价格比按需计费模式更优惠。对于长期使用者，推荐该方式。 适用于消息资源需求波动的场景，可以随时开通，随时删除。 包周期（包年/包月）：天翼云提供包月和包年的购买模式。这种购买方式相对于按需付费则能够提供更大的折扣，对于长期使用者，推荐该方式。包周期计费按照订单的购买周期来进行结算。 按需计费：这种购买方式比较灵活，可以即开即停，支持秒级计费。实例从“开通”开启计费到“删除”结束计费，按实际购买时长（精确到秒）计费。 计费模式变更 ：天翼云分布式消息服务MQTT目前不支持计费模式变更。

本章节主要介绍如何开启分布式消息服务RabbitMQ实例插件。 RabbitMQ实例创建后，支持开启如下插件，实例创建后默认都是关闭状态。 RabbitMQ插件功能可用于测试和迁移业务等场景，不建议用于生产业务。详情请参考约束与限制。 表1 支持修改状态的实例插件 插件名称 功能描述 端口号 rabbitmqamqp10 表示实例是否支持AMQP1.0协议。 rabbitmqdelayedmessageexchange 表示实例是否开启消息延迟功能。插件延迟时间存在1%左右的误差，可能提前或者推迟发送消息给消费者。 rabbitmqfederation 表示实例是否开启消息同步功能。 rabbitmqsharding 表示实例是否开启消息分片功能。 rabbitmqshovel 表示实例是否开启消息迁移功能。 rabbitmqtracing 表示实例是否开启消息追踪功能。 rabbitmqmqtt 表示实例是否支持MQTT协议（TCP方式）。 1883 rabbitmqwebmqtt 表示实例是否支持MQTT协议（WebSocket方式）。 15675 rabbitmqstomp 表示实例是否支持STOMP协议（TCP方式）。 61613 rabbitmqwebstomp 表示实例是否支持STOMP协议（WebSocket方式）。 15674 rabbitmqconsistenthashexchange 表示实例是否支持xconsistenthash。 说明 插件端口号不支持修改。

本文为您介绍分布式消息服务MQTT的快速入门创建实例。 实例介绍 MQTT实例订购支持用户自定义规格和自定义特性，采用物理隔离的方式部署。租户独占MQTT实例，可根据业务需要可定制相应规格的MQTT实例。在新的资源池节点上，还支持选择主机类型和存储规格等丰富用户选项。 操作步骤 1、在产品详情页点击立即开通按钮，或者进入消息管理控制台创建实例，进入订购分布式消息MQTT页面。 2、 创建实例，注意选择产品规格。 （1）填写实例名称，长度4~40个字符，大小写字母开头，只能包含大小写字母、数字及分隔符()。 （2）选择计费模式：包年包月/按需计费，两种模式说明参见计费模式。 （3）购买时长按照计费模式选择变化： 计费模式为包年包月，可选择购买时长16个月、13年。该模式提供自动续期功能，勾选后可以自动续期购买时长：16个月、13年。 计费模式为按需计费，则该选项隐藏无需选择。 （4）部署方式有单可用区和多可用区两个选项，目前仅支持单可用区和3可用区部署,单可用区部署请选中任意一个AZ；多可用区部署请选中3个AZ，系统会自动将Broker节点平均分配至各可用区。 （5）设置节点数，可选择3/5/7/9。MQTT 的节点数是指MQTT 集群中的节点数量。在MQTT 集群中，可以有多个节点组成一个集群，每个节点都是一个独立的MQTT 服务器实例。 （6）下拉选择主机类型，可选择通用型和计算增强型。通用型云主机共享宿主机的CPU资源，主要提供基本水平的vCPU性能、平衡的计算、内存和网络资源，具有较高性价比，支持通用的业务运行。计算增强型云主机独享宿主机的CPU资源，实例间无CPU争抢，并且没有进行资源超配，同时搭载全新网络加速引擎，实现接近物理服务器的强劲稳定性能。 （7）选择实例规格，分布式消息服务MQTT提供通用型和计算增强型各3类规格，各规格详细说明参见弹性云主机规格。 （8）选择存储空间，包括磁盘类型和空间。 磁盘类型提供高IO/普通IO/超高IO三类。普通IO适用于大容量、读写速率中等、事务性处理较少的应用场景。高IO：适用于主流的高性能、高可靠应用场景。超高IO：适用于超高IOPS、超大带宽需求的读写密集型应用场景。了解更多磁盘类型说明参见云硬盘规格。 磁盘空间以100G起步，可以以100倍数增加磁盘空间。 （9）选择已有虚拟私有云，若无虚拟私有云，点击创建跳转到虚拟私有云页面新增，了解更多内容参见虚拟私有云。 （10）选择已有子网，若无子网，点击创建跳转到子网页面新增，了解更多内容参见虚拟私有云子网管理 创建子网。 （11）选择已有安全组，若无安全组，点击创建跳转到安全组页面新增，了解更多内容参见虚拟私有云安全组 创建安全组。 3、 填写完上述信息后，单击“下一步”，进入费用确认页面。 4、 确认实例信息无误后，提交请求。 5、 在实例列表页面，查看MQTT实例是否创建成功。创建实例大约需要3到15分钟，此时实例状态为“创建中”。

本文介绍分布式消息服务MQTT的API请求状态码。 正常状态码 描述 800 成功 900 失败

本文为您介绍分布式消息服务MQTT的API参考如何调用API。 请求头header参数 参数名 示例值 参数类型 是否必填 参数描述 regionId 921d904cca2211e99aa20242ac110006 String 是 资源池编码

云服务名称 区域 支持IAM 支持企业项目 支持IAM 支持企业项目 系统策略 分布式消息服务Kafka 全局 是 是 是 是 有 分布式消息服务RabbitMQ 全局 是 是 是 是 有 分布式消息服务RocketMQ 全局 是 是 是 是 有 微服务云应用平台 全局 是 是 是 是 有 云容器引擎 全局 是 是 是 是 有 弹性容器实例 全局 是 是 是 是 有 函数计算 全局 是 是 是 是 有 云日志服务LTS 全局 是 是 是 是 有 容器镜像服务 全局 是 是 是 是 有 分布式消息服务MQTT 全局 是 是 是 是 有 应用服务网格 全局 是 是 是 是 有 微服务引擎 全局 是 是 是 是 有

本文为您介绍分布式消息服务MQTT的API设备客户端查设备连接信息。 GET URI参数说明： 参数名 参数类型 是否必填 参数描述 prodInstId String 是 实例ID clientId String 是 设备ID 返回参数说明： 参数名 参数类型 参数描述 statusCode Integer 800成功 其他失败 message String 描述状态 returnObj Object 返回对象 returnObj.connectedat String 连接时间 returnObj.sendmsg Integer 发送消息数量 returnObj.disconnectedat String 断开时间 returnObj.recvmsg Integer 接收消息数量 returnObj.protoname String 协议名称 returnObj.connected Boolean 是否在线 returnObj.username String 用户名 returnObj.cleanstart Boolean 持久化会话 返回示例：(800)成功 {"statusCode": 800,"message": "success","returnObj": [{"connectedat": "20220824 16:28:14","sendmsg": 181,"subscriptionscnt": 1,"disconnectedat": "20220824 16:47:30","recvmsg": 0,"protoname": "MQTT","connected": false,"username": "test","cleanstart": false}]} 返回示例：失败 {"returnObj": null,"message": "error","statusCode": "900"}

面向长期稳定客户，我们特别推出了更加优惠的包年订阅选项，旨在通过深度折扣，帮助客户显著降低资源单位成本，优化整体支出。 自2024年11月9日起订购和续订分布式消息服务MQTT产品更长包周期即可享受2年7折，3年5折优惠。

介绍分布式消息服务MQTT实例列表内容。 操作说明 1、 进入控制台查看已购买的实例列表，若列表为空，可点击右上角【订购实例】进入购买页面，创建实例详情见具体操作步骤。 2、 支持按照实例名称查询，输入查询内容，点击【查询】按钮即可展示需要的实例数据。 3、 查看实例基本信息，包括实例ID、规格、计费模式、创建时间、到期时间、状态。其中状态说明见下文。 运行状态 1、 登录管理控制台。 2、 进入MQTT管理控制台。 3、 当前页面会列出所购买的MQTT实例，并查看状态，状态说明如下 状态 说明 运行中 MQTT实例正常运行状态。在这个状态的实例可以运行您的业务。 已关闭 MQTT实例处于故障的状态。 变更中 MQTT实例正在进行规格变更操作。 变更失败 MQTT实例处于规格变更失败状态。 暂停 MQTT实例处于已冻结状态，用户可以在“更多”中续费开启冻结的MQTT实例。 注销 MQTT实例已经过期并关闭，需要重新购买实例。 回收站 1、实例退订后，在回收站可查看已退订实例。 2、回收站实例销毁。 点击回收站实例列表“销毁”，进入实例销毁页面，提交订单。

node环境 安装依赖 plaintext $ npm install mqtt save js代码示例 python const mqtt require('mqtt') const fs require('fs') // 连接选项 const options { host: '127.0.0.1', // MQTT服务器地址。填入您的mqtt实例绑定的公网ip地址 port: 8084, // 端口号 (MQTTS通常用8883，MQTT用1883，WS用8083，WSS用8084) path: '/mqtt', // WebSocket 路径参数 username: 'yourusername', // 用户名 password: 'yourpassword', // 密码 protocol: 'wss', // 协议: mqtt, mqtts, ws, wss rejectUnauthorized: false, // 如果需要禁用证书验证，如果使用wss协议，默认的服务端证书客户端需要开启该选项进行禁用证书验证 } // 创建客户端连接 const client mqtt.connect(options) // 连接事件处理 client.on('connect', () > { console.log('成功连接到MQTT服务器') // 订阅主题 client.subscribe('test/topic', (err) > { if (!err) { console.log('成功订阅主题: test/topic') // 发布消息 client.publish('test/topic', 'Hello MQTT!') } }) }) // 接收消息 client.on('message', (topic, message) > { console.log(收到消息 [${topic}]: ${message.toString()}) }) // 错误处理 client.on('error', (err) > { console.error('连接错误:', err) }) // 断开连接处理 client.on('close', () > { console.log('连接已关闭') }) 浏览器环境 html代码示例 python 浏览器 MQTT 客户端 body { fontfamily: Arial, sansserif; maxwidth: 800px; margin: 0 auto; padding: 20px; }

本文为您介绍分布式消息服务MQTT的API参考如何调用API。 登录云网门户，在“控制台”>“个人中心”>“ 第三方账号绑定 ”，通过创建或者查看获取ak，sk。

本文为您介绍分布式消息服务MQTT的API第三方认证授权停用MySQL认证授权。 POST ContentType：application/json 请求体参数说明： 参数名 参数类型 是否必填 参数描述 id Integer 是 id prodInstId String 是 实例ID 返回参数说明： 参数名 参数类型 参数描述 message String 描述状态 statusCode Integer 800成功 其他失败 返回示例：成功 { "message": "success","statusCode": "800"} 返回示例：失败 {"returnObj": null,"message": "error","statusCode": 900}

本文为您介绍分布式消息服务MQTT的API设备客户端客户端下线。 POST ContentType：application/json 请求体json参数说明： 参数名 参数类型 是否必填 参数描述 prodInstId String 是 实例Id clientId String 是 设备ID 返回参数说明： 参数名 参数类型 参数描述 returnObj Object 返回对象 message String 描述状态 statusCode Integer 800成功 返回示例：成功 {"returnObj": null,"message": "success","statusCode": 800} 返回示例：(900)失败 {"returnObj": null,"message": "error","statusCode": "900"}

安装依赖 plaintext pip3 install pahomqtt 代码示例 python import ssl import random from paho.mqtt import client as pahoclient 填入您在mqtt控制台创建的ACL账号密码。 USERNAME "yourusername" AUTHPASSWORD "yourpassword" 是否使用tls加密传输 isTls True class MQTTClient: def init(self): 填写mqtt云消息服务的接入点，去掉:{端口号}部分 self.broker "tcp://localhost" 指定连接客户端的id self.clientid "ctgmqttclienttest" self.client None def onconnect(self, client, userdata, flags, rc): 连接建立成功 if rc 0: print("Connected to MQTT Broker!") else: print(f"Failed to connect, return code {rc}") def ondisconnect(self, client, userdata, rc): 连接丢失 print(f"Disconnected with result code {rc}") 可以在这里添加重连逻辑 def onmessage(self, client, userdata, msg): 收到消息的回调 print(f"Received {msg.payload.decode()} from {msg.topic} topic") def onpublish(self, client, userdata, mid): 成功发送消息到服务端 print(f"Message {mid} published successfully") def connectmqtt(self): 创建客户端实例 self.client pahoclient.Client(clientidself.clientid) self.client.usernamepwset(USERNAME, AUTHPASSWORD) 设置回调函数 self.client.onconnect self.onconnect self.client.ondisconnect self.ondisconnect self.client.onmessage self.onmessage self.client.onpublish self.onpublish 设置TLS if isTls: 创建不验证证书的SSL上下文 context ssl.createdefaultcontext() context.checkhostname False context.verifymode ssl.CERTNONE self.client.tlssetcontext(context) 设置其他连接选项 self.client.connect(self.broker.replace("tcp://", "").replace("ssl://", ""), port8883 if isTls else 1883) self.client.loopstart()

本文为您介绍分布式消息服务MQTT的API认证授权回收认证用户权限。 POST ContentType：application/json 请求体json参数说明： 参数名 参数类型 是否必填 参数描述 prodInstId String 是 实例ID userName String 是 认证用户 topic String 是 主题 返回参数说明： 参数名 参数类型 参数描述 message String 描述状态 statusCode String 800成功 其他失败 返回示例：成功 { "message": "success","statusCode": "800"} 返回示例：失败 {"returnObj": null,"message": "error","statusCode": "900"}

本文介绍分布式消息服务MQTT的keepalive设置推荐 在MQTT中，Keep Alive是一个用于保持客户端和服务器之间的活动连接的机制。它是通过客户端定期发送PINGREQ消息来实现的，以确保连接保持活动状态。当服务器接收到PINGREQ消息后，会回复PINGRESP消息，表示连接仍然活动。 Keep Alive的设置取决于你的应用需求和网络环境。以下是一些建议： 1. 根据网络稳定性设置：如果你的网络环境非常稳定，连接很少会断开，你可以将Keep Alive设置为较长的时间，例如60秒或更长。这样可以减少PINGREQ和PINGRESP消息的频繁发送，减少网络流量和资源消耗。 2. 根据应用实时性设置：如果你的应用对实时性要求较高，需要及时获取和响应消息，则可以将Keep Alive设置为较短的时间，例如10秒或更短。这样可以快速检测到连接丢失，并尽快重新连接或采取相应的处理措施。 3. 根据网络延迟设置：如果你的网络延迟较高，连接速度较慢，你可能需要将Keep Alive设置为较长的时间，以允许更多的时间来处理网络延迟和连接恢复。 需要注意的是，Keep Alive的设置不应过于频繁或过于长久。太频繁的Keep Alive会增加网络流量和服务器负载，太长久的Keep Alive可能会导致连接超时和断开。 一般来说，根据网络稳定性和应用实时性的考虑，将Keep Alive设置为30秒到5分钟之间是比较常见的。你可以根据你的具体需求和实际情况进行调整和优化。

本文为您介绍分布式消息服务MQTT的API第三方认证授权启用MySQL认证授权。 POST ContentType：application/json 请求体参数说明： 参数名 参数类型 是否必填 参数描述 id Integer 是 id prodInstId String 是 实例ID 返回参数说明： 参数名 参数类型 参数描述 message String 描述状态 statusCode Integer 800成功 其他失败 返回示例：成功 { "message": "success","statusCode": "800"} 返回示例：失败 {"returnObj": null,"message": "error","statusCode": 900}

本文为您介绍分布式消息服务MQTT的API认证授权认证用户授权。 POST ContentType：application/json 请求体json参数说明： 参数名 参数类型 是否必填 参数描述 prodInstId String 是 实例Id userName String 是 认证用户 topic String 是 主题 action String 是 权限 sub/pub/pubsub 返回参数说明： 参数名 参数类型 参数描述 message String 描述状态 statusCode String 800成功 其他失败 返回示例：成功 { "message": "success","statusCode": "800"} 返回示例：失败 {"returnObj": null,"message": "error","statusCode": "900"}

本文为您介绍分布式消息服务MQTT的API设备客户端查询设备是否在线。 GET URI参数说明： 参数名 参数类型 是否必填 参数描述 prodInstId String 是 实例ID clientId String 是 设备ID 返回参数说明：成功 参数名 参数类型 参数描述 returnObj Object 返回对象 returnObj.clientId String 设备ID returnObj.online Boolean 是否在线 message String 描述状态 statusCode String 800成功 其他失败 成功 {"returnObj": {"clientId":"aaa","online":true},"message": "success","statusCode": "800"} 失败 {"returnObj": null,"message": "error","statusCode": 900}

尊敬的天翼云客户，分布式消息服务MQTT自2025年12月27日起，订购和续订2年、3年选项默认不开放，调整为白名单特性。 调整时间 2025年12月27日 影响范围 所有区域 调整影响 新订购和续订的实例默认不开放2年、3年选项，您可以选择1年包年选项，如仍需要23年包周期选项，请联系技术支持开通后使用。 已购买2年、3年且还在服务期间的实例仍可继续正常使用不受影响。

本文为您介绍分布式消息服务MQTT的API认证授权删除认证用户。 POST ContentType：application/json 请求体json参数说明： 参数名 参数类型 是否必填 参数描述 prodInstId String 是 实例Id userName String 是 认证用户 返回参数说明： 参数名 参数类型 参数描述 message String 描述状态 statusCode String 800成功 其他失败 返回示例：成功 { "message": "success","statusCode": "800"} 返回示例：失败 {"returnObj": null,"message": "error","statusCode": "900"}

本文为您介绍分布式消息服务MQTT的API设备客户端退订客户端主题。 POST ContentType：application/json 请求体参数说明： 参数名 参数类型 是否必填 参数描述 prodInstId String 是 实例ID clientId String 是 设备ID topic String 是 主题 返回参数说明: 参数名 参数类型 参数描述 message String 描述状态 statusCode Integer 800成功 其他失败 返回示例：成功 { "message": "success","statusCode": "800"} 返回示例：失败 {"returnObj": null,"message": "error","statusCode": "900"}

本文为您介绍分布式消息服务MQTT的API第三方认证授权更新MySQL认证授权。 POST ContentType：application/json 请求体参数说明： 参数名 参数类型 是否必填 参数描述 id Integer 是 id ip String 是 ip port Integer 是 端口 dbName String 是 数据库名 accessAccount String 是 用户名 accessKey String 是 密码 authKeyCryType String 是 认证密码类型，plain和sha256 prodInstId String 是 实例id 返回参数说明： 参数名 参数类型 参数描述 message String 描述状态 statusCode Integer 800成功 其他失败 返回示例：成功 { "message": "success","statusCode": "800"} 返回示例：失败 { "message": "success","statusCode": "900"}

为保障更优的性能，分布式消息服务MQTT上线并主推计算增强型主机类型，原通用型规格调整为白名单特性，更多产品类型信息请参阅产品规格。 调整时间 2024年11月9日 影响范围 所有区域 调整影响 新用户默认不开放主机类型通用型规格订购开通，如需要该特性，请联系技术支持开通后使用。 已购买主机类型通用型规格实例的用户，原实例仍可正常使用，续费等操作不受影响。

本文为您介绍分布式消息服务MQTT的API第三方认证授权配置MySQL认证授权。 POST ContentType：application/json 请求体json参数说明： 参数名 参数类型 是否必填 参数描述 ip String 是 mysql ip port Integer 是 端口 accessAccount String 是 mysql用户 accessKey String 是 mysql用户密码 dbName String 是 数据库名 authKeyCryType String 是 认证密码类型，plain和sha256 prodInstId String 是 实例id 返回参数说明： 参数名 参数类型 参数描述 message String 描述状态 statusCode Integer 800成功 其他失败 返回示例： { "message": "success","statusCode": "800"} 返回示例：失败 {"returnObj": null,"message": "error","statusCode": 900}

本文为您介绍分布式消息服务MQTT的API设备客户端批量查询设备在线状态。 POST ContentType：application/json 请求体json参数说明： 参数名 参数类型 是否必填 参数描述 prodInstId Text 是 实例Id clientIds Text 是 clientIds 设备ID 多个以逗号隔开 必填,一次最多查10个 返回参数说明： 参数名 参数类型 参数描述 returnObj Object 返回对象 returnObj.clientId String 设备ID returnObj.online Boolean 是否在线 message String 描述状态 statusCode Integer 800成功 其他失败 返回示例：成功 {"returnObj": [{"clientId": "aaa","online": true},{"clientId": "aaax","online": true}]} 返回示例：失败 {"returnObj": null,"message": "error","statusCode": "900"}

本文为您介绍分布式消息服务MQTT的API设备客户端查询设备订阅信息。 GET URI参数说明： 参数名 参数类型 是否必填 参数描述 prodInstId String 是 实例ID clientId String 是 设备ID 返回参数说明： 参数名 参数类型 参数描述 statusCode Integer 800成功 其他失败 message String 描述状态 returnObj Object 返回对象 returnObj.node String 设备节点 returnObj.clientid String 设备ID returnObj.qos Integer qos级别 returnObj.topic String 主题 返回示例：成功 {"statusCode": 800,"message": "success","returnObj": [{"node": "MQTT2@172.31.0.217","clientid": "DEFAULT@TESTSUB2","qos": 1,"topic": "test/aaa"}]} 返回示例：失败 {"returnObj": null,"message": "error","statusCode": "900"}