摘要：前言作為一個(gè)消息代理客戶端與服務(wù)端的通信時(shí)基于協(xié)議的而現(xiàn)在的主流應(yīng)用時(shí)呈現(xiàn)在瀏覽器中這意味著用戶與服務(wù)端只能通過或者這類瀏覽器能理解的協(xié)議傳輸所以后端還要建立一個(gè)代理層將協(xié)議傳輸?shù)膬?nèi)容解析一下以協(xié)議發(fā)送到最后再由發(fā)送到硬件端在瀏覽器支持的協(xié)

mosquitto 作為一個(gè)消息代理, 客戶端與 mosquitto 服務(wù)端的通信時(shí)基于 MQTT 協(xié)議的, 而現(xiàn)在的主流 web 應(yīng)用時(shí)呈現(xiàn)在瀏覽器中, 這意味著用戶與服務(wù)端只能通過 HTTP 或者 HTTPS 這類瀏覽器能理解的協(xié)議傳輸, 所以后端還要建立一個(gè)代理層, 將 HTTP 協(xié)議傳輸?shù)膬?nèi)容解析一下以 MQTT 協(xié)議發(fā)送到 mosquitto, 最后再由 mosquitto 發(fā)送到硬件端.

在瀏覽器支持的協(xié)議中, 還有一個(gè)適用于長(zhǎng)連接的 WS 協(xié)議, 參考: 瀏覽器中常見網(wǎng)絡(luò)協(xié)議介紹. 如果客戶端直接通過 websocket 連接到 mosquitto 端, 那么就不需要中間的后端代理層. 后端只需要一個(gè)推送服務(wù)和控制系統(tǒng)就可以實(shí)現(xiàn)對(duì)客戶端的監(jiān)聽, 控制, 推送(當(dāng)然, 如果業(yè)務(wù)量巨大, 業(yè)務(wù)邏輯復(fù)雜, 代理層還是有必要的, 因?yàn)檫@樣不但可以為 mosquitto 過濾一些不必要的業(yè)務(wù), 而且可以做一些數(shù)據(jù)統(tǒng)計(jì), 設(shè)計(jì)事件鉤子).

在編譯 mosquitto 和它的驗(yàn)證插件 mosquitto-auth-plug 的時(shí)候, 我注意到 mosquitto 有一個(gè)監(jiān)聽的 9001 端口, 事后查了一下, 發(fā)現(xiàn) mosquitto 開放的這個(gè)端口是支持直接與客戶端進(jìn)行 websocket 通信的.

其實(shí)純粹的 MQTT 服務(wù)器是沒有這個(gè)功能的, mosquitto 需要在編譯的時(shí)候設(shè)置 configure.mk中

WITH_WEBSOCKETS := yes

所幸的是, eclipse 官方的 docker 鏡像 已經(jīng)支持了 websocket 通信方式. 只需要在 mosquitto.conf 中啟用:

port 1883
listener 9001
protocol websockets

eclipse 提供了用于 瀏覽器客戶端利用 javascript 和 mosquitto 進(jìn)行 websocket 通信的 paho-mqtt.js, 這是這個(gè) js 庫的文檔: Paho.MQTT DOC.

我們假設(shè)有客戶端用戶為 client, 服務(wù)端用戶為 server. 為他們分配的主題與權(quán)限為:

 id | username |      topic         | rw 
----+----------+--------------------+----
  1 | client   | /p/client/upload   |  2
  2 | server   | /p/client/upload   |  2
  3 | client   | /p/client/download |  1
  4 | server   | /p/client/download |  2

那么 server 和 client 均可以在 /p/client/upload 讀寫. 我們約定只有 client 在 /p/client/upload 寫, server 只讀 /p/client/upload, 這個(gè) topic 是用于 client 向 server 發(fā)送消息.

對(duì)于 topic /p/client/download, server 可讀可寫, client 只讀, 這個(gè) topic 是用于 client 接受 server 向下推送的消息, 具體的邏輯如下:

注意這里的 client 是對(duì) /p/client/upload 具有可讀可寫權(quán)限的, 意味者它可以讀取來自 /p/client/upload 的信息, 但是實(shí)際上這里沒有人往這個(gè)主題發(fā)布消息(除非 client 自己往這里發(fā)消息), 所以 client 擁有可讀權(quán)限也沒有關(guān)系.

建議看一下這篇文章: Using MQTT Over WebSockets with Mosquitto, 它比較詳細(xì)地介紹了客戶端通過 websocket 于 mosquitto 服務(wù)器通信的方式.
比如對(duì)于 client.html:
先引入 paho-mqtt.js, 這里我們先用 cloudflare.com CDN上的這段 js:

下面是創(chuàng)建客戶端 websocket 的例子:

var mqtt;
var host = "mosquitto";
var port = 9001;

// onConnect 事件
function onConnect() {
    console.log("connected.");
    var raw_message = "Hello World!";
    message = new Paho.MQTT.Message(raw_message);
    message.destinationName = "/p/client/upload";
    console.log("sending message: " + raw_message );
    mqtt.send(message);

    // 訂閱 download topic
    var subOptions = {
        qos: 1,
        onSuccess: onSubscribe
    };
    mqtt.subscribe("/p/client/download", subOptions);
}

// 訂閱主題成功事件
function onSubscribe(context) {
    console.log("subscribe success");
    console.log(context);
}

// 連接失敗事件
function onFailure(message) {
    console.log("connect failed.");
}

// onMessageArrived 事件
function onMessageArrived(message) {
    console.log("new message arrived...");
    console.log(message.payloadString);
}


// 建立 MQTT websocket 連接
function MQTTconnect() {
    console.log("connecting to " + host + ":" + port);
    mqtt = new Paho.MQTT.Client(host, port, "clientid");
    var options = {
        timeout: 3,
        onSuccess: onConnect,
        onFailure: onFailure,
        userName: "client",
        password: "123456",
        mqttVersion: 4
    };
    mqtt.onMessageArrived = onMessageArrived;
    mqtt.connect(options);
}

這里我們利用 paho-mqtt.js 新建了一個(gè) mqtt, 然后綁定 onSuccess(連接成功), onFailure(連接失敗) onMessageArrived(消息到來)等事件, 之后用 options 里的配置連接到遠(yuǎn)程的 mosquitto 服務(wù)器. 連接成功后, client 向 server 發(fā)送一條消息到 /p/client/upload topic, 通知服務(wù)端已經(jīng)建立連接. 發(fā)送之后 mqtt 又訂閱 /p/client/download, 準(zhǔn)備接受來自服務(wù)端的信息.

比如, 服務(wù)端可以這樣向客戶端推送消息:

import paho.mqtt.publish as publish
import time

HOST = "mosquitto"
PORT = 1883


if __name__ == "__main__":
    client_id = time.strftime("%Y%m%d%H%M%S", time.localtime(time.time()))
    publish.single(
        "/p/client/download", "hello mqtt", qos=2, hostname=HOST, port=PORT,
        client_id=client_id, auth={"username": "server", "password": "123456"})

這就是基于雙通道的服務(wù)端于客戶端通信

單通道通信原理類似, 但是由于客戶端可能有多臺(tái)設(shè)備, 比如手機(jī)端, 微信小程序端, PC 端. 那么身份的驗(yàn)證不能直接由 mosquitto 確定, 應(yīng)該在消息體內(nèi)確定. 比如我們用 json 作為消息的承載方式. 消息體可以這樣:

{
    "timestamp": "1539141568",
    "client_id": "1001001",
    "message_type": "ping",
    "data": {"detail": "content"},
    "token": "auth_token"
}

這里應(yīng)該按照具體的業(yè)務(wù)需求進(jìn)行鑒權(quán)設(shè)計(jì).