MQTT协议学习总结

本文纯手打，只是本人近期摸索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 就可以安装了，封装得很好，调用简单，具体用法和注意事项有空再另外写一篇文章讲解。