百度360必应搜狗淘宝本站头条
当前位置:网站首页 > 热门文章 > 正文

智能设备对接MQTT服务器,实现远程控制设备

bigegpt 2024-08-01 11:54 11 浏览

引言

上一篇介绍了如何在Ubuntu中搭建我们自己的mqtt服务器,今天就来介绍如何将自己的智能设备对接服务器,实现远程控制设备。当然前提需要大家有一个智能设备哦,这里的智能设备可以是ZigBee,wifi,以太网等,总之能够实现网络通讯即可,这里我们以目前非常流行的esp8266 wifi模块为例,其现价比还是蛮高的,几块钱就能带领我们遨游物联网~

当然熟悉的stm32等单片机的小伙伴也可以外接以太网网卡,并移植lwip(小型开源的TCP/IP协议栈,是目前嵌入式行业中应用最广泛tcp/ip协议栈之一,想深入学习的小伙伴个人推荐可以参考 朱升林编写的<嵌入式网络哪些事>)协议栈,实现网络通讯也是可以的哈,这里我就不展开讲这些底层实现了。

MQTT客户端源码获取

eclipse开源一个了嵌入式平台的mqtt客户端源码,其下载地址:https://github.com/eclipse/paho.mqtt.embedded-c

这里我们只关心3个重要的文件夹: MQTTClinet, MQTTClient-C, MQTTPacket,

其中:

MQTTClinet 是 用C++实现在arduino, linux, mbed平台MQTT客户端代码

MQTTClient-C 是用C语言(正是我们要的)实现在cc3200,FreeRTOS, linux平台的客户端代码。其中MQTTClient.c 和 MQTTClient.h是MQTT客户端应用层实现,如实现了网络初始化,连接,收发数据,解析数据等接口。这些是接口跟具体平台无关。

而该目录下的cc3200, FreeRTOS, linux文件夹中, 以FreeRTOS为例子(因为esp8266是基于freertos操作系统的),则需要具体实现互斥量,超时检测,socket初始化,读写等网络底层操作(因为MQTT是基于tcp的)。

MQTTPacket 是MQTT协议最核心的底层具体实现(C语言),比如连接(Connect), 发布(Public), 订阅(Subscribe)等等。共包含17个源文件和头文件。

我们在到ESP8266_RTOS_SDK(esp8266基于FreeRTOS操作系统的软件开发包, 关于如何搭建esp8266开发环境请参考我置顶视频)中的components(包含所有组件,包括第三方组件)下的mqtt组件

打开ibm-mqtt文件夹:

就会发现与我们下载的源码包含的文件一致: MQTTClinet-C和MQTTPacket

OK, 那我们为了讲解方便,直接基于ESP8266工程来说明,大家在实际中想要了解原理机制,可以直接download ESP8266_RTOS_SDK查看源码即可, 这里还是强调下,不管是什么平台,MQTTPacket中所有源文件和MQTTClient.c , MQTTClient.h是不需要任何改动的,只需要移植MQTTFreeRTOS.c和头文件下(根据自己的平台)的函数即可。

具体对接MQTT服务器

第一步,首先我们需要连接wifi, 实现网络物理连接, 因为我们的MQTT服务器就在我们电脑虚拟机Ubuntu中(内网)呢,因此我们需要保证我们的esp8266与服务器在同一个局域网下。

简单介绍以上函数作用: 初始化lwip协议栈,并注册一个wifi事件(wifi_event_handler),用于wifi相关事件回调, 接着初始化wifi配置,作为station模式去连接家里的wifi。其中wifi_event_handler 具体实现:

第二步,初始化网络接口用于初始化MQTT客户端配置,如收发buf和长度, 命令超时时间(ms),并尝试连接服务器,注意这里是tcp传输层连接。其中MQTT_SERVER_ADDR为实际服务器地址(在Ubuntu中命令行下输入ifconfig,查看即可,这里是“192.168.1.14”), MQTT_SERVER_PORT则是服务器端口号(这里是1883)

第三步,设置Connect连接包相关参数,如:协议版本(=3为3.1版本, =4为3.1.1版本), 客户端ID,用户名, 密码等, 并发送给服务器尝试MQTT应用层连接。

第四步,确保第三步成功连接后,订阅一个主题,主题名形式为“xxx/xxx”,可以使用通配符。

这里我订阅的主题是SUB_TOPIC, 其是个宏定义,实质为"esp8266/led", 之后我们就可以通过另一个MQTT客户端(手机或电脑实现一个MQTT客户端)就可以轻松远程控制我们esp8266外接的led灯拉。同时注册一个当与订阅匹配的消息来源时回调函数: messageArrived

在函数中简单实现了如何控制led, 当控制指令包含“led-close”时,关闭led; 当包含“led-open”,打开led,其实指令打印是一个无效指令"===cmd is invaild==="。

第五步,不断轮询是否有MQTT数据包需要处理(包括连接应答,订阅,发布,心跳包等等),并每隔10秒向服务器发送心跳包,当然这里的心跳包时间大家可以自定义,只要不超过设置值(60,我们在前面MQTTPacket_connectData connectData = MQTTPacket_connectData_initializer; 其中MQTTPacket_connectData_initializer是一个连接包结构体,默认设置了心跳超时时间60s )1.5倍即可。

最后,看一下主函数,其初始化了esp8266的flash,wifi, LED的gpio相关配置, 并等待wifi成功连接后,开启一个mqtt 客户端任务,具体内容就是以上第二步~第五步。

实验效果

我们将以上程序编译下载到esp8266开发板上(不熟悉的小伙伴可以参看我的视频,详细介绍了如何在Windows和Linux中搭建esp8266开发环境), 下载完成后, 连接电脑打开串口(因为是文章不方便展示动态效果图,只能以串口日志方式展现)上电:

当前串口最后一行显示了我们esp8266设备已经成功连接家里的路由器咯,并获得了ip地址“192.168.1.15”, 接着我们打开电脑端mqtt客户端,这里使用MQTT.fx-1.7.1(这个工具非常好用,也是各大平台推荐调试MQTT协议使用的工具),并进行以下配置:

注:如果服务器设置不允许匿名登陆,则需要在User Credentials填写相应的用户名和密码。

回到主界面,点击“Connect”连接服务器:

成功连接后,我们发布一个主题(为了控制esp8266设备,当然是发布与上面esp8266订阅的主题一致,即"esp8266/led"),并在下方内容栏输入要发布的信息,如“led-open”, "led-close",然后点击右侧的“Publish”

我们分别依次发布“led-open”, “led-close”消息,然后我们再看看esp8266串口的输出:

可以看到esp8266设备成功接收到了Windows中MQTT客户端发送的数据, 并根据相应控制指令,执行相应操作,成功了实现了远程控制设备。

总结

简单讲解了从如何获取mqtt源码,到如何移植(根据不同操作系统具体实现,可参考源码中src/FreeRTOS文件中的MQTTFreeRTOS.c), wifi(链路层)连接,ip层连接,mqtt应用层连接,订阅,接收数据并进行相应处理,中间省略了MQTT协议的细节,如果大家想对MQTT源码级分析的话或是对MQTT协议感兴趣的话,都可以参考《MQTT-3.1.1-CN.pdf》这份文档,今后有空的话,我也会一步步使用wireshark抓包工具逐步分析MQTT协议,好了,今天就分享到这,感兴趣的小伙伴记得收藏,转发加关注哦~

相关推荐

当Frida来“敲”门(frida是什么)

0x1渗透测试瓶颈目前,碰到越来越多的大客户都会将核心资产业务集中在统一的APP上,或者对自己比较重要的APP,如自己的主业务,办公APP进行加壳,流量加密,投入了很多精力在移动端的防护上。而现在挖...

服务端性能测试实战3-性能测试脚本开发

前言在前面的两篇文章中,我们分别介绍了性能测试的理论知识以及性能测试计划制定,本篇文章将重点介绍性能测试脚本开发。脚本开发将分为两个阶段:阶段一:了解各个接口的入参、出参,使用Python代码模拟前端...

Springboot整合Apache Ftpserver拓展功能及业务讲解(三)

今日分享每天分享技术实战干货,技术在于积累和收藏,希望可以帮助到您,同时也希望获得您的支持和关注。架构开源地址:https://gitee.com/msxyspringboot整合Ftpserver参...

Linux和Windows下:Python Crypto模块安装方式区别

一、Linux环境下:fromCrypto.SignatureimportPKCS1_v1_5如果导包报错:ImportError:Nomodulenamed'Crypt...

Python 3 加密简介(python des加密解密)

Python3的标准库中是没多少用来解决加密的,不过却有用于处理哈希的库。在这里我们会对其进行一个简单的介绍,但重点会放在两个第三方的软件包:PyCrypto和cryptography上,我...

怎样从零开始编译一个魔兽世界开源服务端Windows

第二章:编译和安装我是艾西,上期我们讲述到编译一个魔兽世界开源服务端环境准备,那么今天跟大家聊聊怎么编译和安装我们直接进入正题(上一章没有看到的小伙伴可以点我主页查看)编译服务端:在D盘新建一个文件夹...

附1-Conda部署安装及基本使用(conda安装教程)

Windows环境安装安装介质下载下载地址:https://www.anaconda.com/products/individual安装Anaconda安装时,选择自定义安装,选择自定义安装路径:配置...

如何配置全世界最小的 MySQL 服务器

配置全世界最小的MySQL服务器——如何在一块IntelEdison为控制板上安装一个MySQL服务器。介绍在我最近的一篇博文中,物联网,消息以及MySQL,我展示了如果Partic...

如何使用Github Action来自动化编译PolarDB-PG数据库

随着PolarDB在国产数据库领域荣膺桂冠并持续获得广泛认可,越来越多的学生和技术爱好者开始关注并涉足这款由阿里巴巴集团倾力打造且性能卓越的关系型云原生数据库。有很多同学想要上手尝试,却卡在了编译数据...

面向NDK开发者的Android 7.0变更(ndk android.mk)

订阅Google官方微信公众号:谷歌开发者。与谷歌一起创造未来!受Android平台其他改进的影响,为了方便加载本机代码,AndroidM和N中的动态链接器对编写整洁且跨平台兼容的本机...

信创改造--人大金仓(Kingbase)数据库安装、备份恢复的问题纪要

问题一:在安装KingbaseES时,安装用户对于安装路径需有“读”、“写”、“执行”的权限。在Linux系统中,需要以非root用户执行安装程序,且该用户要有标准的home目录,您可...

OpenSSH 安全漏洞,修补操作一手掌握

1.漏洞概述近日,国家信息安全漏洞库(CNNVD)收到关于OpenSSH安全漏洞(CNNVD-202407-017、CVE-2024-6387)情况的报送。攻击者可以利用该漏洞在无需认证的情况下,通...

Linux:lsof命令详解(linux lsof命令详解)

介绍欢迎来到这篇博客。在这篇博客中,我们将学习Unix/Linux系统上的lsof命令行工具。命令行工具是您使用CLI(命令行界面)而不是GUI(图形用户界面)运行的程序或工具。lsoflsof代表&...

幻隐说固态第一期:固态硬盘接口类别

前排声明所有信息来源于网络收集,如有错误请评论区指出更正。废话不多说,目前固态硬盘接口按速度由慢到快分有这几类:SATA、mSATA、SATAExpress、PCI-E、m.2、u.2。下面我们来...

新品轰炸 影驰SSD多款产品登Computex

分享泡泡网SSD固态硬盘频道6月6日台北电脑展作为全球第二、亚洲最大的3C/IT产业链专业展,吸引了众多IT厂商和全球各地媒体的热烈关注,全球存储新势力—影驰,也积极参与其中,为广大玩家朋友带来了...