Eclipse Mosquitto 客户端定时消息发送实现对比（C/C++/Python）

核心概念

MQTT协议本身不提供定时发送功能，需在客户端实现。核心思路：创建独立计时线程，通过循环/回调触发消息发布。关键要素：

• 计时机制：系统时钟/定时器
• 线程管理：避免阻塞主循环
• 消息队列：线程间通信

C语言实现

依赖库：libmosquitto + POSIX线程
优势：资源占用低，实时性强
挑战：手动管理线程和内存

#include <mosquitto.h>
#include <pthread.h>
#include <unistd.h>

void* timer_thread(void* arg) {
    struct mosquitto* mosq = (struct mosquitto*)arg;
    while (1) {
        sleep(5);  // 5秒间隔
        mosquitto_publish(mosq, NULL, "topic/定时", 6, "Hello", 0, false);
    }
    return NULL;
}

int main() {
    struct mosquitto* mosq = mosquitto_new(NULL, true, NULL);
    mosquitto_connect(mosq, "localhost", 1883, 60);
    
    pthread_t thread;
    pthread_create(&thread, NULL, timer_thread, mosq);
    
    mosquitto_loop_forever(mosq, -1, 1);
    // ...清理资源
}

C++实现

依赖库：libmosquittopp + C++11线程
优势：面向对象封装，代码更简洁
关键改进：使用std::thread和std::chrono

#include <mosquittopp.h>
#include <thread>
#include <chrono>

class MqttClient : public mosqpp::mosquittopp {
public:
    void start_timer() {
        timer_thread = std::thread([this] {
            while (true) {
                std::this_thread::sleep_for(std::chrono::seconds(5));
                publish(nullptr, "topic/定时", 6, "Hello", 0, false);
            }
        });
    }
private:
    std::thread timer_thread;
};

int main() {
    MqttClient client;
    client.connect("localhost", 1883, 60);
    client.start_timer();
    client.loop_forever();
}

Python实现

依赖库：paho-mqtt + 内置线程
优势：开发效率最高，代码量最少
核心方案：使用threading.Timer递归触发

import paho.mqtt.client as mqtt
import threading

def on_connect(client, userdata, flags, rc):
    schedule_next(client)  # 启动首次定时

def schedule_next(client):
    client.publish("topic/定时", "Hello")
    threading.Timer(5.0, schedule_next, [client]).start()  # 递归调用

client = mqtt.Client()
client.on_connect = on_connect
client.connect("localhost", 1883, 60)
client.loop_forever()

对比总结

关键建议：

• 实时系统首选 C/C++（如工业控制器）
• 快速开发首选 Python（如数据采集脚本）
• 需平衡性能与开发成本时选 C++