MQTT在C语言中的消息过滤

在C语言中，使用MQTT协议进行消息过滤通常涉及到订阅特定主题并设置消息回调函数。MQTT客户端库（如libmosquitto）提供了订阅和回调的功能，允许你根据主题过滤接收到的消息。

以下是一个简单的示例，展示了如何使用libmosquitto库在C语言中订阅特定主题并过滤消息：

1. 首先，确保已经安装了libmosquitto库。在Ubuntu系统中，可以使用以下命令安装：

sudo apt-get install libmosquitto-dev

2. 创建一个C文件（例如：MQTTClient.c），并包含必要的头文件：

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

3. 定义回调函数，该函数将在接收到消息时被调用。在这个示例中，我们将只打印主题名称：

int message_callback(void *userdata, struct mosquitto_message *message) {
    printf("Received message on topic: %s\n", message->topic);
    return 0;
}

4. 在main函数中，初始化MQTT客户端并连接到MQTT代理：

int main(int argc, char *argv[]) {
    int rc;
    struct mosquitto *mosq;
    const char *broker = "tcp://broker.hivemq.com:1883";
    const char *client_id = "C_Client_1";

    mosq = mosquitto_new(client_id, true, NULL);
    if (!mosq) {
        fprintf(stderr, "Failed to create mosquitto client\n");
        return 1;
    }

    rc = mosquitto_connect(mosq, broker, 1883, 60);
    if (rc != MOSQ_ERR_SUCCESS) {
        fprintf(stderr, "Failed to connect to broker\n");
        mosquitto_destroy(mosq);
        return 1;
    }

    // 订阅特定主题
    const char *topic = "example/topic";
    rc = mosquitto_subscribe(mosq, topic, 0, message_callback);
    if (rc != MOSQ_ERR_SUCCESS) {
        fprintf(stderr, "Failed to subscribe to topic: %s\n", topic);
        mosquitto_disconnect(mosq);
        mosquitto_destroy(mosq);
        return 1;
    }

    // 开始循环以处理网络流量、自动重连等
    printf("Connected to broker and subscribed to topic. Press Ctrl+C to exit.\n");
    while (1) {
        int msg_rc = mosquitto_loop();
        if (msg_rc == MOSQ_ERR_CONNACK_RECEIVED) {
            printf("Connection established\n");
        } else if (msg_rc == MOSQ_ERR_DISCONNECTED) {
            printf("Disconnected\n");
        } else if (msg_rc == -1) {
            fprintf(stderr, "Error\n");
            break;
        }
    }

    mosquitto_disconnect(mosq);
    mosquitto_destroy(mosq);
    return 0;
}

5. 编译并运行程序：

gcc MQTTClient.c -o MQTTClient -lmosquitto
./MQTTClient

现在，程序将连接到MQTT代理并订阅example/topic主题。当从该主题接收到消息时，message_callback函数将被调用，并打印出主题名称。你可以根据需要修改回调函数以实现更复杂的过滤逻辑。