本文纯手打,只是本人近期摸索MQTT的总结,不是从其它地方复制的,所以有可能因为认知的偏差或文笔水平导致个别的地方表述不准确,如有问题,欢迎指出。
Mqtt是什么?
跟http类似,也是一个数据传输协议,基于TCP协议开发,它的特点是传输内容精简,而且有QoS(Quality of Service服务质量)机制,更适合物联网等网络环境不稳定,网络带宽小的场景使用;
Mqtt Broker是什么?
Broker是经纪人、中介的意思,其实对我来说,我更愿意称它为Mqtt服务器,因为它是整个传输过程的关键,一直要保持运行的,它负责转发传输的参与方【发布者】与【订阅者】的消息,所有的消息都要经过他转发;
对于Mqtt服务器来说,同一个终端即可以是发布者也可以是订阅者,举个例子:一台物联网空调,它可以作为发布者,把自己的运行状态(如当前是开还是关)用status主题上报给MQTT服务器,其余订阅了status主题的终端就能收到Mqtt服务器的推送,而空调自身也可以是订阅者,例如订阅operation主题,当有终端发布operation主题的内容时,例如内容是open,它就打开空调,收到close就关闭空调,这个具体的业务逻辑可以自己定义和实现,通常与硬件交互时要做PLC编程的。
Mqtt服务器是多种多样的,因为mqtt只是一个传输协议,所有实现了这个协议的都可以做Mqtt服务器,我所了解到的实现方案有Swoole(PHP平台的)、Mosquitto(一个独立的mqtt协议服务组件)、Emqx(一个独立的mqtt协议服务组件)等,还有大量云平台提供Mqtt协议传输服务,如腾讯云、阿里云、华为云等云计算服务商都有,自己搭的优点是成本低,因为可以基于现有服务器装一个组件就可以了,不需要额外的成本,也不用持续付费,直接使用云服务的好处是方便弹性扩展,如果预见不久的将来会达到一个超级大的量级就建议考虑云服务。
怎样搭建Mqtt服务器?
我选择的是Mosquitto组件来搭建Mqtt服务器,用法很简单,我的腾讯云服务器操作系统是Centos7.6,直接用yum install mosquitto命令就可以一健安装好了,安装好后用mosquitto -v即可以在控制台启动mqtt服务,而且会在命令窗口实时输出当前被连接或发布的消息,在调试时很有用,例如可以看到某些ip的连接因为账号密码错误而被拒绝了,哪些连接因超时断开了,包括连接的ClientId都会输出来,是排查问题的利器,如果已经调试完了或希望在后台运行,就用mosquitto -d命令启动,就会转为后台运行了,关于配置的问题不在这里详细展开,可以用whereis mosquitto.conf命令查找这个文件,网上有很多详细介绍配置项的文章。
怎样连接Mqtt服务器?
这个不同的Mqtt服务器的连接方法有细微差异,在这里我主要说一下mosquitto的。 用php连接Mosquitto通常有两种办法,一个是phpMqtt库,我当时下载下来用了,能发布但订阅的消息收不到,后来查了一下说是这种方式不稳定,所以没继续纠结下去;二是安装libmosquitto扩展,这个方式比较稳定,调用起来也更加方便; 而我最终选择的是用python连接,python里有一个paho包,用pip install paho-mqtt 就可以安装了,封装得很好,调用简单,具体用法和注意事项有空再另外写一篇文章讲解。