Создание клиента MQTT в консоли Ubuntu: примеры с кодом

Чтобы создать клиент MQTT в консоли Ubuntu, вы можете использовать различные языки программирования, такие как Python, Java или Node.js. Вот примеры использования Python и Node.js:

Пример Python:

  1. Установите необходимую библиотеку MQTT, выполнив следующую команду:

    pip install paho-mqtt
  2. Создайте файл 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()
  3. Замените "broker.example.com"адресом брокера MQTT, к которому вы хотите подключиться.

  4. Запустите скрипт Python с помощью следующей команды:

    python mqtt_client.py

Пример Node.js:

  1. Установите библиотеку MQTT, выполнив следующую команду:

    npm install mqtt
  2. Создайте файл 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());
    });
  3. Замените 'broker.example.com'адресом брокера MQTT, к которому вы хотите подключиться.

  4. Запустите сценарий Node.js, используя следующую команду:

    node mqtt_client.js