上云无忧 > 文档中心 > 天翼云分布式消息服务MQTT消息数据存储
分布式消息服务MQTT
天翼云分布式消息服务MQTT消息数据存储

文档简介:
终端消息数据按父topic存储至kafka队列,需先在控制台创建父topic;对未创建父topic的消息可正常收发,但不会存储至kafka队列。 Kafka存储内容格式:{ "clientId": 设备clientId, "topic": 主题, "payload": 消息内容, "ts": 发送的时间戳
*产品来源:中国电信天翼云。免费试用 咨询热线:400-826-7010,为您提供专业的售前咨询,让您快速了解云产品,助您轻松上云! 微信咨询
  免费试用、价格特惠

终端消息数据按父topic存储至kafka队列,需先在控制台创建父topic;对未创建父topic的消息可正常收发,但不会存储至kafka队列。

Kafka存储内容格式:{

  • "clientId": 设备clientId,

  • "topic": 主题,

  • "payload": 消息内容,

  • "ts": 发送的时间戳


相似文档
  • 终端 clean session=true,断线后会话信息清除,再次上线后之前所有的订阅关系以及离线消息丢失。 clean session=false断开连接的情况下,MQTT Broker也会为断连客户端保存一个会话,默认2小时,超期未重连订购关系清除;对于clean session=false的客户端断线重连后可接收Qos>0的离线消息。
  • 对于clean session=false的客户端在未超出会话失效期断线重连后可接收Qos>0的离线消息
  • 系统主题 说明 mq2mqtt 用于云端服务向终端发送消息。发往该主题消息会转发至MQTT Broker实现云端与移动端互通 mqtt-device-connect 设备上线主题,内容 {"clientid":客户端ID,"ts":上线时间戳 }
  • 终端连接地址 即MQTT Broker端接入地址,设备端使用; 服务端连接地址 即kakfa集群连接地址,云端应用服务使用 订阅关系 终端设备每订阅一个主题即一个订阅关系
  • 分布式消息服务MQTT支持标准的MQTT协议,理论上适配所有的MQTT客户端SDK。 推荐对应的第三方 SDK 如下表: 语言/平台 推荐的第三方 SDK Java Eclipse Paho SDK
官方微信
联系客服
400-826-7010
7x24小时客服热线
分享
  • QQ好友
  • QQ空间
  • 微信
  • 微博
返回顶部