Чтобы создать клиент MQTT в консоли Ubuntu, вы можете использовать различные языки программирования, такие как Python, Java или Node.js. Вот примеры использования Python и Node.js:
Пример Python:
-
Установите необходимую библиотеку MQTT, выполнив следующую команду:
pip install paho-mqtt -
Создайте файл Python, например,
mqtt_client.py, и добавьте следующий код:import paho.mqtt.client as mqtt # Callback function for connection established def on_connect(client, userdata, flags, rc): print("Connected:", rc) # Subscribe to a topic client.subscribe("my_topic") # Callback function for message received def on_message(client, userdata, msg): print("Received message:", msg.payload.decode()) # Create an MQTT client instance client = mqtt.Client() # Set the callback functions client.on_connect = on_connect client.on_message = on_message # Connect to the MQTT broker client.connect("broker.example.com", 1883, 60) # Start the network loop to handle incoming messages client.loop_start() -
Замените
"broker.example.com"адресом брокера MQTT, к которому вы хотите подключиться. -
Запустите скрипт Python с помощью следующей команды:
python mqtt_client.py
Пример Node.js:
-
Установите библиотеку MQTT, выполнив следующую команду:
npm install mqtt -
Создайте файл JavaScript, например,
mqtt_client.js, и добавьте следующий код:const mqtt = require('mqtt'); // Create an MQTT client instance const client = mqtt.connect('mqtt://broker.example.com'); // Callback function for connection established client.on('connect', function () { console.log('Connected'); // Subscribe to a topic client.subscribe('my_topic'); }); // Callback function for message received client.on('message', function (topic, message) { console.log('Received message:', message.toString()); }); -
Замените
'broker.example.com'адресом брокера MQTT, к которому вы хотите подключиться. -
Запустите сценарий Node.js, используя следующую команду:
node mqtt_client.js