MQTT是一種輕量級的、可靠的消息傳輸協(xié)議，通常用于連接低帶寬和不穩(wěn)定網(wǎng)絡的設備，比如物聯(lián)網(wǎng)設備。而MySQL則是一個流行的開源關系型數(shù)據(jù)庫，用于存儲和管理數(shù)據(jù)。在本文中，我們將介紹如何在MQTT和MySQL之間建立一個簡單的數(shù)據(jù)流，以便將設備生產(chǎn)的數(shù)據(jù)同步到數(shù)據(jù)庫中。

首先，我們需要在MQTT中訂閱一個主題，以便接收來自設備的數(shù)據(jù)。在下面的代碼中，我們使用JavaScript語言的MQTT客戶端庫來創(chuàng)建與MQTT代理的連接，并訂閱一個名為“data”的主題：

var mqtt = require('mqtt')
var client  = mqtt.connect('mqtt://mqtt.example.com')
client.on('connect', function () {
client.subscribe('data')
})
client.on('message', function (topic, message) {
console.log(message.toString())
})

接下來，我們需要將從MQTT接收到的數(shù)據(jù)寫入到MySQL中。在這里，我們將使用Node.js的MySQL客戶端庫來連接數(shù)據(jù)庫，并將數(shù)據(jù)插入到一個名為“data”的表中：

var mysql = require('mysql')
var connection = mysql.createConnection({
host: 'mysql.example.com',
user: 'user',
password: 'password',
database: 'database'
})
client.on('message', function (topic, message) {
var data = JSON.parse(message.toString())
var query = 'INSERT INTO data SET ?'
connection.query(query, data, function (error, results, fields) {
if (error) throw error;
console.log('Data inserted successfully');
});
})

在上面的代碼中，我們首先使用JSON.parse()函數(shù)將從MQTT接收到的文本轉換為一個JavaScript對象，然后將對象作為參數(shù)傳遞給MySQL的INSERT語句。一旦數(shù)據(jù)被成功插入，我們將在控制臺上打印一條成功的消息。

現(xiàn)在，MQTT和MySQL之間的簡單數(shù)據(jù)流已經(jīng)建立。當設備發(fā)布一個message到“data”主題時，我們的代碼將自動將數(shù)據(jù)寫入到MySQL中。這個簡單的示例可以為建立更復雜的MQTT-MYSQL數(shù)據(jù)流提供基礎。