文章用于记录学习心得，分享学习经验。如有雷同，错误或者涉及侵权等问题，请联系作者！！！

1 MQTT介绍

mqtt是一种协议，建立在IP，tcp网络上。相比于tcp,更加简单，轻便，多用于物联网中，终端设备或者客户端不具备浏览器功能，但是能连接网络。

组成：客户端，服务器端 

服务器端 MQTT服务器也称为“消息代理”（Broker）

通过订阅和发布来实现双向连接。订阅是指客户端向服务器订阅主题topic，有消息message后，服务器立即向订阅者根据订阅的主题topic来推送消息。发布是指客户端向服务器推送带有主题topic的消息message。每一个客户端都可以作为订阅或者发布者，客户端只和服务端建立联系，客户端之间不联系。通过订阅、发布实现客户端之间的消息发送。主题可以多人发布，也可以多人接收。

官网：https://www.emqx.io/zh
github：https://github.com/emqx/emqx

2 EMQX服务器

使用EMQX在本地建立mqtt服务器，实现局域网或者互联网的mqtt通信。安装使用请到官网下载，解压，再此不赘述。

局域网：局域网相比于互联网而言，局域网使用私网IP，比如：手机热点WiFi，家里路由器，校园网，企业内部网，都是局域网。局域网内可以再建立局域网，比如，校园网连接互联网，手机连接校园网，esp8266连接手机热点，实现局域网向下扩展。

客户端通过IP来实现服务端的识别，并发送消息，客户端会先在本局域网中查找服务端IP，在上一级局域网，再，再，直到互联网中，全部没有 则链接失败。

EMQX启动问题，通过cmd命令提示符启动，安装位置在d盘时，d:回车把操作位置改为d盘，

启动：在安装包位置\emqx-5.0.26-windows-amd64\bin\emqx start

启动后会出现2行字符，然后自行cmd关闭，浏览器打开127.0.0.1:18083，登录，跳过密码，管理后台，默认用户名/密码： admin/public  启动成功

关闭：在安装包位置\emqx-5.0.26-windows-amd64\bin\emqx stop

没有提示，然后自行cmd关闭，127.0.0.1:18083管理后台打不开，关闭成功

tip：

启动关闭麻烦，可以在安装包下即bin的同级文件，新建txt,写入.\bin\emqx start，更改txt后缀名为.bat，变为一键启动。关闭类似操作。

3 MQTT客户端测试

自带客户端进行测试。

端口号问题：网页html版客户端、h5+app制作的手机app，不能直接连接mqtt,通过websocket进行映射连接，端口为8083；单片机esp8266、电脑exe软件等直接连接的端口号为1883。

在同一个mqtt服务器里面，客户端的ID不能重复，后来者会挤掉先来着，用户名和密码可以多个客户端使用。

4 库

1 HTML 

mqtt.js

url = 'mqtt://127.0.0.1:8083/mqtt';  var options = {                                                //创建一个参数对象             clientId:'123',                                        //clientID             username:'123',                                            //用户名             password:'123'                                        //用户密码         };         client = mqtt.connect(url,options);                            //连接服务器

client.publish(topic, message);							//发送消息

注意：clientId:
            username:
            password:

大小写区别，特别是clientId，不然识别不到id，但是能连接上服务器，服务器会自动分配id号。

2 esp8266 

 PubSubClient.h

arduinoide编写esp8266代码

适用于MQTT的Arduino客户端 (knolleary.net)

#include  #include  //通过WiFi连接mqtt服务器，发送订阅主题，控制板载led亮灭 /**********************网络设置项 **********************/ const char* ssid = "123";                                //路由器名字 const char* password = "123";                            //路由器密码 const char* mqtt_server = "123.123.123.123";          //MQTT服务器IP const int mqttPort = 1883;                            //MQTT服务器端口 /*****************用户信息项 (全部为自定义项)*****************/ const char* ESP8266_ID = "esp8266ID";                 //自定义ID const char* ESP8266_user = "test";                   //用户名 const char* ESP8266_password = "123";              //密码 const char* ESP8266_pub = "esp2/sub";                 //发送主题（对方的订阅主题） const char* ESP8266_sub = "esp2/pub";                 //订阅主题（对方的发送主题） WiFiClient espClient; PubSubClient client(espClient);                      //定义客户端对象

//指定客户端要连接的MQTT服务器IP和端口   client.setServer(mqtt_server, mqttPort);

 //连接MQTT服务器，提交ID，用户名，密码    client.connect(ESP8266_ID, ESP8266_user, ESP8266_password);