MQTT(Message Queuing Telemetry Transport)是一个客户端服务端架构的发布/订阅模式的消息传输协议。它的设计思想是轻巧、开放、简单、规范,易于实现。这些特点使得它对很多场景来说都是很好的选择,特别是对于受限的环境比如机器和机器通讯(M2M)以及物联网环境(IoT)。 
支持MQTT底层传输协议的相关设备有:

  • 客户端--使用它连接服务端
  • 服务端--全托管的云服务,帮助建立设备与云端之间安全可靠的双向连接,以支撑海量设备的数据收集、监控、故障预测等各种物联网场景

客户端

使用MQTT的程序或设备(推荐使用MQTT.fx,MQTT.fx是目前主流的MQTT客户端,可以快速验证是否可以与IoT Hub服务交流发布或订阅消息)。

  • 发布应用消息给其他相关的客户端
  • 订阅以请求接受相关的应用消息
  • 取消订阅以移除接受应用消息的请求
  • 从服务端断开连接

服务端

全托管的云服务,帮助建立设备与云端之间安全可靠的双向连接,以支撑海量设备的数据收集、监控、故障预测等各种物联网场景。

  • 接受来自客户端的网络连接
  • 接受客户端发布的应用消息
  • 处理客户端的订阅和取消订阅请求
  • 转发应用消息给符合条件的客户端订阅 

使用百度天工物接入来测试

第一步,创建实例,百度物接入需要先创建一个实例(endpoint),一个实例表示一个完整的物接入服务。登陆物接入控制台,点击“创建实例”,填写需要创建IoT Hub服务的实例名称。创建好实例后,物接入默认提供三种地址:

  • tcp://*:1883,端口1883,不支持传输数据加密
  • ssl://*:1884,端口1884,支持SSL/TLS加密传输
  • wss://*:8884,端口8884,支持websockets连接方式 

    第二步,创建策略,输入策略名称,主题,选择策略所支持的权限:发布消息、订阅消息 

    第三步,创建身份,输入身份名称,然后选择之前配置的策略 

    第四步,创建设备,输入设备名称,然后选择之前创建的身份及策略,最后创建成功时返回一个设备的登陆密码,这个密码在客户端登陆时需要用到。 
  • 到这里整个物接入的服务端基本创建完成了,下面我们来看小客户端代码,这里使用python代码,需要注意的是这里的username、password、topic几个配置均来自于前面的服务端配置。
import paho.mqtt.client as mqtt
import sys
import uuidbroker = 'pos.mqtt.iot.gz.baidubce.com'
port = 1883
username = 'pos/ccid-0001'
password = 'AWFjb7rUy1n9MZM2xd77ZGAw0cNbx4N6I5kQHMKxs/ag='
clientid = 'test_mqtt_python_' + str(uuid.uuid4())
topic = 'topic01'def on_connect(client, userdata, rc):print('Connected. Client id is: ' + clientid)client.subscribe(topic)print('Subscribed to topic: ' + topic)client.publish(topic, 'Message from Baidu IoT demo')print('MQTT message published.')def on_message(client, userdata, msg):msg = str(msg.payload).encode('utf-8')print('MQTT message received: ' + msg)if msg == 'exit':sys.exit()client = mqtt.Client(clientid)
client.on_connect = on_connect
client.on_message = on_message
client.username_pw_set(username, password)print('Connecting to broker: ' + broker)
client.connect(broker, port)client.loop_forever()

IoT-百度天工物接入相关推荐

  1. mqtt连接百度天工物接入平台

    文章目录 mqtt连接到百度天工物接入 百度天工物接入简介 使用百度天工物接入 创建项目 创建策略 创建身份 创建用户 测试连接 MQTT软件测试连接 手动安装相关的依赖包 拉取mqttclient仓 ...

  2. ESP32 AT指令模式连接百度云天工物接入

    ESP32 AT指令模式连接百度云天工物接入 文章目录 ESP32 AT指令模式连接百度云天工物接入 1. 前言 2. 芯片介绍及资料说明 3. 连接云平台 3.1 下载AT固件 3.2 AT指令测试 ...

  3. 树莓派上云-天工物接入

    目录 创建设备 开通服务 创建项目 设备接入 创建物模型 创建物影子 测试连接 树莓派上云 环境搭建 代码编写 总结   前几天在朋友介绍下试用了阿里云的物联网平台,阿里云IOT平台使用MQTT协议通 ...

  4. 云溪天工生产对接_解读工业智能网关如何快速对接百度天工IoT Hub

    原标题:解读工业智能网关如何快速对接百度天工IoT Hub 在一家染色工厂里,往往最严重的就是空气污染,一是织物上的游离甲醛会引起头痛,软弱无力,体温变化,感觉障碍,排汗不规则,脉搏加快,皮炎皮肤过敏 ...

  5. 百度云平台物接入和实时数据库的使用

    这两天折腾了一下百度云平台的物联网相关,感觉很痛苦,首先是文档更新不及时,发布的视频都是很老的,跟现在的完全不配套,其次是技术支持太差,就那么一个叫袁尤X的人在负责技术支持,想问一些问题根本忙不过来的 ...

  6. c++ mqtt客户端_MQTT详解及百度物接入连接手机测试(含源码) 秦子帅

    MQTT简介 MQTT定义 MQTT(Message Queuing Telemetry Transport,消息队列遥测传输)是IBM开发的一个即时通讯协议,有可能成为物联网的重要组成部分.该协议支 ...

  7. IoT-阿里云物接入套件

    IoT Hub IoT Hub帮助设备连接阿里云IoT服务,IoT Hub支持PUB/SUB与RRPC两种通信方式,其中PUB/SUB是基于Topic进行的消息路由.IoT Hub具有以下特点: 高性 ...

  8. 中国移动、阿里云、百度天工三大物联网平台技术架构对比

    一. 中移物联网平台 1. 官网 https://open.iot.10086.cn/ 2. 平台架构 3. 术语解释 术语 解释 别名 产品 OneNET平台资源(包括设备,APIKey,触发器,应 ...

  9. 公开课|百度天工物联网基础平台的微服务容器化落地实践

    本文整理自中信出版社<物联网时代> 在采用IoT的世界中,改变既是IoT引发的,也是你的生活中无法回避的事实. 弗洛伦斯·赫德森,是Internet2(Internet2,即I2,是指由美 ...

最新文章

  1. 铁线蕨算法(Adiantum)为低端智能手机提供磁盘加密服务
  2. win7任务栏还原为xp样式
  3. .NET架构小技巧(2)——访问修饰符正确姿势
  4. Springboot 之 Hibernate自动建表(Mysql)
  5. C++学习——构造函数,析构函数与虚函数关系
  6. python 多进程 每个进程做不同功能实例_Python 多进程并发操作中进程池Pool的实例...
  7. SqlServer智能提示工具
  8. SDK Manager配置
  9. (转)《2017中国人工智能创新公司50强》榜单
  10. linux新建 txt文件,通过Linux终端快速创建文本文件的3种方法
  11. matlab语言定义变量类型,matlab定义变量-MATLAB,变量
  12. 小布助手对话短文本语义匹配
  13. spring boot 项目页面显示不出来
  14. python+pands+matplotlib分析Excel表格
  15. 网络攻防原理及应用 知识梳理
  16. 网络与验证服务器失联怎样修复,GCP用一键服务器失联了,如何重装系统?
  17. springBoot 在过滤器中如何捕获抛出的异常并自定义返回信息
  18. 同款蓝牙耳机为什么会串联_烂大街的蓝牙耳机音质都一样,为什么有人买更贵的AirPods...
  19. 怎样做好机械设备设计?
  20. 使用wagon-maven-plugin插件自动部署项目

热门文章

  1. Ubuntu 环境下交叉编译运行正点原子的程序
  2. 幼儿园带括号算式口诀_41组“数学顺口溜”+大九九乘法口诀表!给孩子疯狂收藏!...
  3. The 2019 ICPC Asia-East Continent Final(M、E、H、C)
  4. Windows实时拓展套件-Kithara RealTime Suite
  5. Golang 异常panic
  6. Linux下置空文件的方法小结
  7. from 后面的select
  8. UP9601台湾力智UPI首颗QC2.0+DC/DC+识别快充三合一车充芯片方案
  9. 清华法学院横幅_法学院在开源法方面落后
  10. 每天工作4小时的程序员