MQTTXv1.4.2新增了哪些功能

這篇文章主要介紹“MQTT X v1.4.2新增了哪些功能”，在日常操作中，相信很多人在MQTT X v1.4.2新增了哪些功能問題上存在疑惑，小編查閱了各式資料，整理出簡(jiǎn)單好用的操作方法，希望對(duì)大家解答”MQTT X v1.4.2新增了哪些功能”的疑惑有所幫助！接下來，請(qǐng)跟著小編一起來學(xué)習(xí)吧！

創(chuàng)新互聯(lián)建站主營(yíng)普蘭店網(wǎng)站建設(shè)的網(wǎng)絡(luò)公司,主營(yíng)網(wǎng)站建設(shè)方案,APP應(yīng)用開發(fā),普蘭店h5小程序設(shè)計(jì)搭建,普蘭店網(wǎng)站營(yíng)銷推廣歡迎普蘭店等地區(qū)企業(yè)咨詢

腳本功能

MQTT X 在 v1.4.2 版本后，加入了腳本功能，提供了讓用戶編輯腳本對(duì) MQTT 連接中，發(fā)送和接收的 Payload 進(jìn)行自定義轉(zhuǎn)化的功能?？捎脕砟M自定義測(cè)試場(chǎng)。主要編寫的腳本語(yǔ)言為 JavaScript。下文將簡(jiǎn)單的介紹兩個(gè)簡(jiǎn)單的測(cè)試實(shí)例場(chǎng)景來對(duì)腳本功能進(jìn)行介紹，需注意：在 v1.4.2 版本中腳本功能屬于開放性測(cè)試功能，使用流程、安全性和功能性還需后續(xù)繼續(xù)優(yōu)化提升和完善。也歡迎各位用戶到 MQTT X 的 GitHub issue 區(qū)進(jìn)行詳細(xì)討論，我們將會(huì)認(rèn)真審閱和回復(fù)。

在編輯腳本功能中，全局只包含了一個(gè) execute API，用戶需要編寫一個(gè)自定義函數(shù)，該函數(shù)接收一個(gè) value 參數(shù)，即為 Payload, 函數(shù)中便可對(duì) value 進(jìn)行自定義修改轉(zhuǎn)化，最后將該函數(shù)作為參數(shù)傳入到 execute 中即可執(zhí)行自定義編寫的函數(shù)。

實(shí)例一

配合定時(shí)發(fā)送功能模擬溫濕度數(shù)據(jù)上報(bào)。

例如，當(dāng)用戶使用 EMQ X 時(shí)，需要使用規(guī)則引擎功能將數(shù)據(jù)保存到數(shù)據(jù)庫(kù)。這時(shí)可以在配置完成后，使用 MQTT X 連接到 EMQ X，并使用腳本功能對(duì)其進(jìn)行測(cè)試。這里假設(shè)用戶需要保存上報(bào)的溫濕度數(shù)據(jù)，且數(shù)據(jù)格式為 JSON 類型，我們可以使用下面的腳本對(duì)數(shù)據(jù)進(jìn)行模擬。

/**
 * Simulated temperature and humidity reporting
 * @return Return a simulated temperature and humidity JSON data - { "temperature": 23, "humidity": 40 }
 * @param value, MQTT Payload - {}
 */

function random(min, max) {
  return Math.round(Math.random() * (max - min)) + min
}

function handlePayload(value) {
  let _value = value
  if (typeof value === 'string') {
    _value = JSON.parse(value)
  }
  _value.temperature = random(10, 30)
  _value.humidity = random(20, 40)
  return JSON.stringify(_value, null, 2)
}

execute(handlePayload)

此時(shí)可將這段代碼復(fù)制到腳本頁(yè)面的代碼編輯框內(nèi)，點(diǎn)擊右上角的 保存 按鈕，設(shè)置腳本名稱為 TempAndHum 并保存。我們?cè)?Input 輸入框內(nèi)輸入一個(gè) {} 作為初始數(shù)據(jù)。點(diǎn)擊 測(cè)試 按鈕，在 Output 框內(nèi)查看執(zhí)行結(jié)果，如果結(jié)果符合預(yù)期，接下來將可以正常使用該腳本。

我們使用 EMQ X 提供的 免費(fèi)公共 MQTT 服務(wù)器 新建一個(gè)連接，該服務(wù)基于 EMQ X 的 MQTT 物聯(lián)網(wǎng)云平臺(tái) 創(chuàng)建。服務(wù)器接入信息如下：

• Broker: broker.emqx.io

• TCP Port: 1883

• Websocket Port: 8083

連接成功后，點(diǎn)擊右上角的下拉功能菜單，選擇 使用腳本，在彈出窗中，選擇剛才保存好的 TempAndHum 腳本，然后選擇應(yīng)用類型為發(fā)送時(shí)，點(diǎn)擊確認(rèn)按鈕后開啟腳本功能。

開啟腳本后，我們?cè)倮^續(xù)設(shè)置定時(shí)發(fā)送功能，同樣點(diǎn)擊右上角的下拉功能菜單，選擇 定時(shí)消息，這里我們?cè)O(shè)置發(fā)送頻率為 1 秒，點(diǎn)擊確認(rèn)后定時(shí)消息功能開啟。

準(zhǔn)備好后，便可以輸入初始的 Payload 和需要發(fā)送到的Topic，點(diǎn)擊發(fā)送成功一條消息后，便可以看到 MQTT X 將每秒自動(dòng)發(fā)送了一次模擬數(shù)據(jù)。

這樣避免了用戶去手動(dòng)輸入和修改數(shù)據(jù)的麻煩，且使用腳本時(shí)模擬數(shù)據(jù)可控，模擬數(shù)據(jù)區(qū)間可在腳本的 random 函數(shù)中設(shè)定，如果有對(duì)保存的數(shù)據(jù)進(jìn)行可視化圖表測(cè)試需求或需要添加一定的數(shù)據(jù)量的數(shù)據(jù)來測(cè)試時(shí)，都較為方便和友好。

實(shí)例二

將接收到的 Payload 中的時(shí)間戳轉(zhuǎn)化為正常時(shí)間。

在一些測(cè)試場(chǎng)景中，用戶測(cè)試接收到的 Payload 內(nèi)可能會(huì)包含時(shí)間戳信息，如果需要觀察和測(cè)試對(duì)時(shí)間較為敏感的數(shù)據(jù)，可能需要復(fù)制出數(shù)據(jù)，再將時(shí)間戳轉(zhuǎn)化時(shí)間，較為麻煩。此時(shí)可以使用腳本對(duì)接收到的數(shù)據(jù)進(jìn)行自動(dòng)轉(zhuǎn)化，方便用戶觀察數(shù)據(jù)信息。我們可以使用下面的腳本對(duì)數(shù)據(jù)進(jìn)行轉(zhuǎn)化。依然假設(shè)接收到的數(shù)據(jù)為 JSON 類型，并且包含了 time 字段。

/**
 * Convert timestamp to normal time.
 * @return Return the UTC time - { "time": "2020-12-17 14:18:07" }
 * @param value, MQTT Payload - { "time": 1608185887 }
 */

function handleTimestamp(value) {
  let _value = value
  if (typeof value === 'string') {
    _value = JSON.parse(value)
  }
  // East Eight District needs an additional 8 hours
  const date = new Date(_value.time * 1000 + 8 * 3600 * 1000)
  _value.time = date.toJSON().substr(0, 19).replace('T', ' ')
  return JSON.stringify(_value, null, 2)
}

execute(handleTimestamp)

此時(shí)可將這段代碼復(fù)制到腳本頁(yè)面的代碼編輯框內(nèi)，點(diǎn)擊右上角的 保存 按鈕，設(shè)置腳本名稱為 Time 并保存。我們?cè)?Input 輸入框內(nèi)輸入一個(gè) { "time": 1608365158 } 作為初始數(shù)據(jù)。點(diǎn)擊 測(cè)試 按鈕，在 Output 框內(nèi)查看執(zhí)行結(jié)果，如果結(jié)果符合預(yù)期，接下來將可以正常使用該腳本。

此時(shí)我們依然新建一個(gè)連接，使用上述中描述的方法來開啟腳本。注意選擇應(yīng)用類型時(shí)，需要選擇為接收時(shí)。

腳本功能開啟后，我們添加一個(gè) testtopic/time 的 Topic，然后我們向該 Topic 發(fā)送一條包含時(shí)間戳信息的 Payload。然后查看接收到的 Payload 信息，可以看到已經(jīng)自動(dòng)幫時(shí)間戳轉(zhuǎn)化為了正常時(shí)間。

到此，關(guān)于“MQTT X v1.4.2新增了哪些功能”的學(xué)習(xí)就結(jié)束了，希望能夠解決大家的疑惑。理論與實(shí)踐的搭配能更好的幫助大家學(xué)習(xí)，快去試試吧！若想繼續(xù)學(xué)習(xí)更多相關(guān)知識(shí)，請(qǐng)繼續(xù)關(guān)注創(chuàng)新互聯(lián)網(wǎng)站，小編會(huì)繼續(xù)努力為大家?guī)砀鄬?shí)用的文章！

新聞名稱：MQTTXv1.4.2新增了哪些功能
轉(zhuǎn)載注明：http://muchs.cn/article18/gjgogp.html

成都網(wǎng)站建設(shè)公司_創(chuàng)新互聯(lián)，為您提供電子商務(wù)、標(biāo)簽優(yōu)化、品牌網(wǎng)站制作、網(wǎng)站內(nèi)鏈、網(wǎng)站建設(shè)、商城網(wǎng)站

廣告

聲明：本網(wǎng)站發(fā)布的內(nèi)容（圖片、視頻和文字）以用戶投稿、用戶轉(zhuǎn)載內(nèi)容為主，如果涉及侵權(quán)請(qǐng)盡快告知，我們將會(huì)在第一時(shí)間刪除。文章觀點(diǎn)不代表本網(wǎng)站立場(chǎng)，如需處理請(qǐng)聯(lián)系客服。電話：028-86922220；郵箱：631063699@qq.com。內(nèi)容未經(jīng)允許不得轉(zhuǎn)載，或轉(zhuǎn)載時(shí)需注明來源： 創(chuàng)新互聯(lián)