Linux MQTT通信:实现轻量级物联网传输协议

简介: MQTT(Message Queuing Telemetry Transport)是一种轻量级的物联网传输协议,专门设计用于低带宽、不稳定网络环境下的传感器和物联网设备通信。本文将深入探讨Linux环境下如何实现MQTT通信,介绍MQTT协议的基本原理、常用MQTT库以及如何在Linux系统中编写MQTT客户端和服务器端程序。

1. MQTT协议概述

MQTT协议是IBM开发的一种发布/订阅消息传递协议。它采用发布-订阅模式,支持多个客户端同时连接到MQTT服务器(也称为MQTT代理或MQTT broker),并通过主题(Topic)进行消息的发布和订阅。

MQTT协议的特点:

  • 轻量级:MQTT协议设计简单,协议头部较小,适合在带宽有限的环境下使用。
  • 可靠性:支持三种消息传递质量等级(QoS级别),可以根据需要选择消息的可靠性。
  • 灵活性:支持动态创建和销毁主题,客户端可以根据需求订阅感兴趣的主题。
  • 异步性:消息的发布和订阅是异步的,客户端无需等待确认。

2. MQTT通信的基本原理

MQTT通信包括两个主要角色:MQTT客户端和MQTT服务器(MQTT broker)。

  • MQTT客户端:可以是传感器、物联网设备或应用程序,它可以发布消息到主题,也可以订阅感兴趣的主题以接收消息。
  • MQTT服务器:也称为MQTT代理或MQTT broker,它负责接收从客户端发送的消息,并将消息转发给订阅该主题的客户端。

MQTT通信流程如下:

  1. 客户端连接到MQTT服务器,并建立TCP连接。
  2. 客户端向服务器发送连接请求,并提供客户端ID等信息。
  3. 服务器接受连接请求,并回复确认连接。
  4. 客户端可以发布消息到指定的主题,也可以订阅感兴趣的主题。
  5. 服务器接收客户端发布的消息,并将消息转发给订阅该主题的客户端。

3. MQTT库

为了在Linux环境下实现MQTT通信,我们可以使用现有的MQTT库来简化开发过程。常用的MQTT库包括:

  • Eclipse Paho:Eclipse Paho是一个开源的MQTT实现,支持多种编程语言,包括C、C++、Java、Python等。
  • Mosquitto:Mosquitto是一个轻量级的MQTT代理,同时也提供了C库用于实现MQTT客户端。

4. MQTT客户端与服务器端实现

下面给出一个简单的MQTT客户端和服务器端的代码示例,使用Eclipse Paho库来实现MQTT通信。

MQTT服务器端:

#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <MQTTClient.h>

#define ADDRESS     "tcp://localhost:1883"
#define CLIENTID    "Server"
#define TOPIC       "test"
#define QOS         1
#define TIMEOUT     10000L

int main() {
   
    MQTTClient client;
    MQTTClient_connectOptions conn_opts = MQTTClient_connectOptions_initializer;
    int rc;

    MQTTClient_create(&client, ADDRESS, CLIENTID,
        MQTTCLIENT_PERSISTENCE_NONE, NULL);
    conn_opts.keepAliveInterval = 20;
    conn_opts.cleansession = 1;

    if ((rc = MQTTClient_connect(client, &conn_opts)) != MQTTCLIENT_SUCCESS) {
   
        printf("Failed to connect, return code %d\n", rc);
        exit(EXIT_FAILURE);
    }

    while (1) {
   
        char message[1024];
        printf("Enter message: ");
        fgets(message, sizeof(message), stdin);
        message[strcspn(message, "\n")] = '\0';

        MQTTClient_message pubmsg = MQTTClient_message_initializer;
        pubmsg.payload = message;
        pubmsg.payloadlen = strlen(message);
        pubmsg.qos = QOS;
        pubmsg.retained = 0;

        MQTTClient_deliveryToken token;
        MQTTClient_publishMessage(client, TOPIC, &pubmsg, &token);
        printf("Waiting for up to %d seconds for publication of %s\n"
                "on topic %s for client with ClientID: %s\n",
                (int)(TIMEOUT/1000), message, TOPIC, CLIENTID);
        rc = MQTTClient_waitForCompletion(client, token, TIMEOUT);
        printf("Message with delivery token %d delivered\n", token);
    }

    MQTTClient_disconnect(client, 10000);
    MQTTClient_destroy(&client);
    return rc;
}

MQTT客户端:

#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <MQTTClient.h>

#define ADDRESS     "tcp://localhost:1883"
#define CLIENTID    "Client"
#define TOPIC       "test"
#define QOS         1
#define TIMEOUT     10000L

void messageArrived(void *context, char *topicName, int topicLen, MQTTClient_message *message) {
   
    char payload[1024];
    strncpy(payload, (char *)message->payload, message->payloadlen);
    payload[message->payloadlen] = '\0';
    printf("Message arrived: %s\n", payload);
    MQTTClient_freeMessage(&message);
    MQTTClient_free(topicName);
}

int main() {
   
    MQTTClient client;
    MQTTClient_connectOptions conn_opts = MQTTClient_connectOptions_initializer;
    int rc;

    MQTTClient_create(&client, ADDRESS, CLIENTID,
        MQTTCLIENT_PERSISTENCE_NONE, NULL);
    conn_opts.keepAliveInterval = 20;
    conn_opts.cleansession = 1;

    if ((rc = MQTTClient_connect(client, &conn_opts)) != MQTTCLIENT_SUCCESS) {
   
        printf("Failed to connect, return code %d\n", rc);
        exit(EXIT_FAILURE);
    }

    MQTTClient_subscribe(client, TOPIC, QOS);
    MQTTClient_setCallbacks(client, NULL, NULL, messageArr

ived, NULL);

    printf("Subscribed to topic %s\n", TOPIC);

    while (1) {
   
        // Wait for messages to arrive
    }

    MQTTClient_disconnect(client, 10000);
    MQTTClient_destroy(&client);
    return rc;
}

5. 编译和运行

将以上代码分别保存为mqtt_server.c和mqtt_client.c,并使用以下命令编译:

gcc -o mqtt_server mqtt_server.c -lpaho-mqtt3c
gcc -o mqtt_client mqtt_client.c -lpaho-mqtt3c

然后运行服务器端和客户端:

./mqtt_server
./mqtt_client

客户端会向服务器端发送一条消息,并通过回调函数接收服务器端发送的消息。

6. 结论

MQTT是一种轻量级的物联网传输协议,在Linux环境下可以通过现有的MQTT库来实现MQTT通信。通过实现MQTT客户端和服务器端的代码示例,我们深入了解了MQTT通信的基本原理和编程接口。MQTT协议适用于在低带宽、不稳定网络环境下的物联网设备通信,是物联网应用开发中不可或缺的重要技术。熟练掌握MQTT编程对于物联网开发和系统优化都是非常有益的。

目录
相关文章
|
24天前
|
传感器 网络协议 物联网
在Linux中搭建Mosquitto MQTT协议消息服务端并结合内网穿透工具实现公网访问
Mosquitto是一个开源的消息代理,它实现了MQTT协议版本3.1和3.1.1。它可以在不同的平台上运行,包括Windows、Linux、macOS等。mosquitto可以用于物联网、传感器、移动应用程序等场景,提供了一种轻量级的、可靠的、基于发布/订阅模式的消息传递机制。
|
15天前
|
消息中间件 DataWorks 物联网
MQTT问题之接入阿里云物联网平台如何解决
MQTT接入是指将设备或应用通过MQTT协议接入到消息服务器,以实现数据的发布和订阅;本合集着眼于MQTT接入的流程、配置指导以及常见接入问题的解决方法,帮助用户实现稳定可靠的消息交换。
59 1
|
5天前
|
消息中间件 Linux 网络安全
Linux环境安装RabbitMQ
Linux环境安装RabbitMQ
|
15天前
|
物联网 Linux 开发工具
MQTT协议接入问题之连接失败如何解决
MQTT接入是指将设备或应用通过MQTT协议接入到消息服务器,以实现数据的发布和订阅;本合集着眼于MQTT接入的流程、配置指导以及常见接入问题的解决方法,帮助用户实现稳定可靠的消息交换。
45 2
|
15天前
|
JSON 网络协议 物联网
MQTT协议问题之消息类型分类如何解决
MQTT协议是一个轻量级的消息传输协议,设计用于物联网(IoT)环境中设备间的通信;本合集将详细阐述MQTT协议的基本原理、特性以及各种实际应用场景,供用户学习和参考。
26 3
|
15天前
|
消息中间件 网络协议 物联网
MQTT协议问题之阿里云物联网服务器断开如何解决
MQTT协议是一个轻量级的消息传输协议,设计用于物联网(IoT)环境中设备间的通信;本合集将详细阐述MQTT协议的基本原理、特性以及各种实际应用场景,供用户学习和参考。
57 1
|
15天前
|
存储 监控 物联网
MQTT协议问题之OTA升级包下载如何解决
MQTT协议是一个轻量级的消息传输协议,设计用于物联网(IoT)环境中设备间的通信;本合集将详细阐述MQTT协议的基本原理、特性以及各种实际应用场景,供用户学习和参考。
40 3
|
15天前
|
消息中间件 Web App开发 监控
mqtt数据问题之如何实现webRTC 协议的监控视频压测
MQTT协议是一个轻量级的消息传输协议,设计用于物联网(IoT)环境中设备间的通信;本合集将详细阐述MQTT协议的基本原理、特性以及各种实际应用场景,供用户学习和参考。
35 0
|
15天前
|
监控 安全 物联网
Mqtt协议问题之下标准的Mqtt协议在哪里可以下载
MQTT协议是一个轻量级的消息传输协议,设计用于物联网(IoT)环境中设备间的通信;本合集将详细阐述MQTT协议的基本原理、特性以及各种实际应用场景,供用户学习和参考。
33 3
|
1月前
|
物联网 Go 网络性能优化
MQTT协议本身支持多种消息收发模式
MQTT协议本身支持多种消息收发模式【1月更文挑战第24天】【1月更文挑战第120篇】
23 3

热门文章

最新文章