MQTT X v1.4.2新增了哪些功能

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

腳本功能

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

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

實例一

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

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

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

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

• Broker: broker.emqx.io

• TCP Port: 1883

• Websocket Port: 8083

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

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

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

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

實例二

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

在一些測試場景中，用戶測試接收到的 Payload 內(nèi)可能會包含時間戳信息，如果需要觀察和測試對時間較為敏感的數(shù)據(jù)，可能需要復(fù)制出數(shù)據(jù)，再將時間戳轉(zhuǎn)化時間，較為麻煩。此時可以使用腳本對接收到的數(shù)據(jù)進(jìn)行自動轉(zhuǎn)化，方便用戶觀察數(shù)據(jù)信息。我們可以使用下面的腳本對數(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)

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

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

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

到此，關(guān)于“MQTT X v1.4.2新增了哪些功能”的學(xué)習(xí)就結(jié)束了，希望能夠解決大家的疑惑。理論與實踐的搭配能更好的幫助大家學(xué)習(xí)，快去試試吧！若想繼續(xù)學(xué)習(xí)更多相關(guān)知識，請繼續(xù)關(guān)注億速云網(wǎng)站，小編會繼續(xù)努力為大家?guī)砀鄬嵱玫奈恼拢?/p>