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编程对于物联网开发和系统优化都是非常有益的。

相关实践学习
CentOS 8迁移Anolis OS 8
Anolis OS 8在做出差异性开发同时,在生态上和依赖管理上保持跟CentOS 8.x兼容,本文为您介绍如何通过AOMS迁移工具实现CentOS 8.x到Anolis OS 8的迁移。
目录
相关文章
|
9天前
|
数据可视化 关系型数据库 MySQL
嵌入式C++、STM32、MySQL、GPS、InfluxDB和MQTT协议数据可视化
通过本文的介绍,我们详细讲解了如何结合嵌入式C++、STM32、MySQL、GPS、InfluxDB和MQTT协议,实现数据的采集、传输、存储和可视化。这种架构在物联网项目中非常常见,可以有效地处理和展示实时数据。希望本文能帮助您更好地理解和应用这些技术,构建高效、可靠的数据处理和可视化系统。
127 82
|
11天前
|
消息中间件 Linux
Linux中的System V通信标准--共享内存、消息队列以及信号量
希望本文能帮助您更好地理解和应用System V IPC机制,构建高效的Linux应用程序。
81 48
|
4月前
|
Ubuntu Linux 测试技术
Linux系统之部署轻量级Markdown文本编辑器
【10月更文挑战第6天】Linux系统之部署轻量级Markdown文本编辑器
213 1
Linux系统之部署轻量级Markdown文本编辑器
|
8天前
|
消息中间件 Linux C++
c++ linux通过实现独立进程之间的通信和传递字符串 demo
的进程间通信机制,适用于父子进程之间的数据传输。希望本文能帮助您更好地理解和应用Linux管道,提升开发效率。 在实际开发中,除了管道,还可以根据具体需求选择消息队列、共享内存、套接字等其他进程间通信方
40 16
|
2月前
|
数据采集 传感器 监控
多协议网关BL110钡铼6路RS485转MQTT协议云网关
BL110钡铼6路RS485转MQTT协议云网关是一款高性能、易配置的工业级设备,适用于各种需要远程监控和数据采集的物联网应用场景。通过将传统RS485设备的数据转换为MQTT协议并上传至云平台,实现了设备的远程管理和智能控制,极大地提升了系统的管理效率和响应速度。
65 2
|
4月前
|
存储 消息中间件 安全
JUC组件实战:实现RRPC(Java与硬件通过MQTT的同步通信)
【10月更文挑战第9天】本文介绍了如何利用JUC组件实现Java服务与硬件通过MQTT的同步通信(RRPC)。通过模拟MQTT通信流程,使用`LinkedBlockingQueue`作为消息队列,详细讲解了消息发送、接收及响应的同步处理机制,包括任务超时处理和内存泄漏的预防措施。文中还提供了具体的类设计和方法实现,帮助理解同步通信的内部工作原理。
JUC组件实战:实现RRPC(Java与硬件通过MQTT的同步通信)
|
4月前
|
网络协议 物联网 网络性能优化
物联网协议比较 MQTT CoAP RESTful/HTTP XMPP
【10月更文挑战第18天】本文介绍了物联网领域中四种主要的通信协议:MQTT、CoAP、RESTful/HTTP和XMPP,分别从其特点、应用场景及优缺点进行了详细对比,并提供了简单的示例代码。适合开发者根据具体需求选择合适的协议。
110 5
|
4月前
|
网络协议 Linux 网络性能优化
Linux C/C++之TCP / UDP通信
这篇文章详细介绍了Linux下C/C++语言实现TCP和UDP通信的方法,包括网络基础、通信模型、编程示例以及TCP和UDP的优缺点比较。
100 0
Linux C/C++之TCP / UDP通信
|
4月前
|
网络协议 Linux
linux学习之套接字通信
Linux中的套接字通信是网络编程的核心,允许多个进程通过网络交换数据。套接字提供跨网络通信能力,涵盖本地进程间通信及远程通信。主要基于TCP和UDP两种模型:TCP面向连接且可靠,适用于文件传输等高可靠性需求;UDP无连接且速度快,适合实时音视频通信等低延迟场景。通过创建、绑定、监听及读写操作,可以在Linux环境下轻松实现这两种通信模型。
68 1
|
5月前
|
消息中间件 Kafka 数据安全/隐私保护
RabbitMQ异步通信详解
RabbitMQ异步通信详解
149 16