云計(jì)算服務(wù)
服務(wù)器租用
DDOS 防護(hù)
虛擬主機(jī)
域名服務(wù)
基礎(chǔ)設(shè)施
關(guān)于我們
transformWsUrl
});
const client = connection.client;
基礎(chǔ)了解 MQTT（Message Queuing Telemetry Transport）是一種輕量級(jí)的發(fā)布/訂閱網(wǎng)絡(luò)協(xié)議，它被設(shè)計(jì)用于在帶寬有限和網(wǎng)絡(luò)不可靠的環(huán)境中，為遙測和控制提供可靠的消息傳輸，MQTT協(xié)議廣泛應(yīng)用于物聯(lián)網(wǎng)（IoT）、移動(dòng)通訊、智能硬件等領(lǐng)域，因其輕量級(jí)特性和對(duì)低功耗設(shè)備的優(yōu)化而受到重視。 MQTT.js客戶端庫 MQTT.js是MQTT協(xié)議的一個(gè)JavaScript實(shí)現(xiàn)，提供了Node.js和瀏覽器環(huán)境下的MQTT客戶端功能，該庫支持多種連接方式，包括但不限于MQTT over WebSocket、MQTT over TCP等，適用于各種應(yīng)用環(huán)境，包括微信小程序和支付寶小程序等定制瀏覽器環(huán)境。 安裝與使用 初始化項(xiàng)目 確保你的開發(fā)環(huán)境已經(jīng)安裝好了Node.js和npm或yarn，通過npm或yarn安裝MQTT.js：
npm install mqtt save
或者使用 yarn
yarn add mqtt
對(duì)于瀏覽器環(huán)境，可以通過CDN引入MQTT.js：
創(chuàng)建MQTT客戶端 創(chuàng)建MQTT客戶端的連接通常需要指定服務(wù)器的URL以及一些連接選項(xiàng)，如下所示：
const mqtt = require(‘mqtt’);
// 定義連接參數(shù)
const connectUrl = ‘ws://broker.emqx.io:8083/mqtt’;
const options = {
clean: true,
connectTimeout: 4000,
username: ‘test’,
password: ‘test’,
clientId: ‘myClientID’
};
// 連接到MQTT代理
const client = mqtt.connect(connectUrl, options);
訂閱主題和發(fā)布消息 一旦建立連接，你就可以訂閱特定的主題，并開始發(fā)布或接收消息：
client.on(‘connect’, () => {
console.log(‘已連接至MQTT代理’);
// 訂閱主題
client.subscribe(‘myTopic’, (err) => {
if (!err) {
console.log(‘已成功訂閱主題’);
}
});
// 發(fā)布消息
client.publish(‘myTopic’, ‘Hello MQTT!’);
});
client.on(‘message’, (topic, message) => {
console.log(收到來自主題【${topic}】的消息： ${message.toString()});
});
高級(jí)用法和注意事項(xiàng)斷線重連機(jī)制：MQTT.js內(nèi)置了自動(dòng)重連的支持，當(dāng)連接意外斷開時(shí)，客戶端會(huì)嘗試重新連接，你可以通過配置選項(xiàng)來調(diào)整重連策略：
const options = {
// 其他選項(xiàng)…
reconnectPeriod: 1000 // 斷線后等待1秒再次嘗試連接
};
WebSocket和TCP的選擇：根據(jù)運(yùn)行環(huán)境和需求選擇適當(dāng)?shù)膮f(xié)議，在瀏覽器環(huán)境中，通常使用MQTT over WebSocket；而在Node.js環(huán)境中，可以選擇MQTT over TCP或MQTT over WebSocket。 相關(guān)問答FAQsQ1: 如何確保MQTT連接的安全性？A1: 確保MQTT連接安全的最佳實(shí)踐包括：使用TLS加密連接（通過使用mqtts或wss協(xié)議），確保僅通過安全通道發(fā)送敏感信息；實(shí)施嚴(yán)格的身份驗(yàn)證和授權(quán)機(jī)制，如使用用戶名和密碼或API密鑰；定期更新和審核使用的庫和服務(wù)以修補(bǔ)潛在的安全漏洞。Q2: 如何處理MQTT消息的接收和解析？A2: 處理接收到的MQTT消息通常涉及設(shè)置一個(gè)監(jiān)聽器來監(jiān)聽message事件，接收到的消息可能是Buffer或字符串類型，根據(jù)需要進(jìn)行解析。
client.on(‘message’, (topic, message) => {
let messageText = message.toString(); // 如果消息是Buffer，轉(zhuǎn)換為字符串
console.log(從【${topic}】收到消息： ${messageText});
// 根據(jù)業(yè)務(wù)邏輯進(jìn)一步處理消息內(nèi)容…
});
.png)
.png)
