MQTT的使用

文字解读

Mqtt(Message Queuing Telemetry Transport，消息队列遥测传输)是IBM开发的用于各种设备的一种基于发布/订阅编程模式的即时通讯协议。

发布/订阅机制

拟物化解读

比如一个电台播放音乐，无论是收音机、手机自带收音机还是车载收音机，只要调到这个调频，就可以听到这个电台播放的音乐。
特点：
1、使用发布/订阅消息模式，可以进行一对多的消息发布；
2、对负载内容屏蔽的消息传输；
3、可以使用TCP/IP连接；
4、提供三种消息发布
“至多一次”，也就是意味着可能一次，也有可能一次也没(丢失)
“至少一次”，顾名思义，也就是说消息会多次发送
“只有一次”，这就表明是只成功发送一次。
5、小型传输(固定长度的头部是2字节)，可以达到协议交换最小化，降低网络流量。
6、使用Last Will和Testament特性通知有关各方客户端异常中断的机制。
消息类型：
1、CONNECT：客户端连接到MQTT代理
2、CONNACK：连接确认
3、PUBLISH：发布新消息
4、PUBACK：新消息确认，QoS1给PUBLISH消息回复
5、PUBREC：QoS2消息流第一部分，消息发布已经记录
6、PUBREL：QoS2消息流第二部分，消息发布已经释放
7、PUBCOMP：QoS2消息流第三部分，消息发布完成
8、SUBSCRIBE：客户端订阅主题
9、SUBACK：确认客户端订阅的主题
10、UNSUBSCRIBE：客户端终止订阅消息
11、UNSUBACK：确认客户端终止订阅消息
12、PINGRESP：心跳
13、PINGREQ：确认心跳
14、DISCONNECT：客户端在终止连接前通知MQTT代理

代码实例

HTML部分:

        <!-- pub --> 
        topic:<input type="text" id="topicSend">
        text:<input type="text" id="textSend">
        <input type="button" value="send" id="btn" onclick="hanleSend（）">
        <!-- sub -->
        <input type="text" id="subCount" disabled>
        <ul id="subMessage"></ul> 

JavaScript部分：

            var subCount = 0;
            var client;
            function MQTTconent({
                client = new Paho.MQTT.Client("主机名","端口号","clientId（可选项）")
                client.onConnectionLost = onConnectionLost;
                client.onMessageArrived = onMessageArrived;
                client.connect({
                    userName: "", //连接账号
                    password: "", //密码
                    onSuccess: onConnect //连接服务器并注册连接成功处理
                })
            })
            // 客户端连接
            function onConnect() {
                client.subscribe() //订阅主题
            }
            // 连接断开处理
            function onConnectionList(res) {
                if(res.errorCode !== 0){
                    console.log("连接断开了")
                }
            }
            // 消息接收处理
            function onMessageArrived(message) {
                var topic = message.destinationName; //收到的消息主题名
                var payload = message.payloadString; //收到的消息内容
                subCount++;
                $('#subCount').val('收到' +subCount + '条');
                $('#subMessage').prepend('<li>' + topic + ':' + payload + '</li>')
            }
            // 发送
            function hanleSend() {
                var message = new Paho.MQTT.Message($('#textSend').val());
                message.destinationName = $('#topicSend').val();
                message.qos = 0;
                client.send(message)
            }
            $(document).ready(function(){
                MQTTconnect()
            })

MQTT安全的就不在这里说了，开始愉快的去试试吧。