嵌入式

mqtt 协议客户端代码

2019-07-13 02:29发布

站内文章 / 嵌入式Linux
15335 0 957
#include
#include

void my_message_callback(struct mosquitto *mosq, void *userdata, const struct mosquitto_message *message)
{
    if(message->payloadlen){
        printf("msg_call if ");
        printf("%s %s ", message->topic, (char * ) message->payload);
    }else{
        printf("msg_call else ");
        printf("%s (null) ", message->topic);
    }
    fflush(stdout);
}

void my_connect_callback(struct mosquitto *mosq, void *userdata, int result)
{
    int i;
    int test=5;
        int next=6;
    if(!result){
        /* Subscribe to broker information topics on successful connect. */
        printf("conn_call if ");
        mosquitto_subscribe(mosq, &test, "test", 2);
        mosquitto_subscribe(mosq, &next, "next", 2);
    }else{
        printf("conn_call else ");
        fprintf(stderr, "Connect failed ");
    }
}

void my_subscribe_callback(struct mosquitto *mosq, void *userdata, int mid, int qos_count, const int *granted_qos)
{
    int i;
    
    printf("Sub_call ");
    printf("Subscribed (mid: %d):granted_qos[0]= %d ", mid, granted_qos[0]);
    printf("Sub_call qos_count=%d ",qos_count);
    for(i=1; i         
        printf("Sub_call for i=%d ",i);
        printf(", %d", granted_qos[i]);
    }
    printf(" ");
}

void my_log_callback(struct mosquitto *mosq, void *userdata, int level, const char *str)
{
    printf("loging_call ");
    /* Pring all log messages regardless of level. */
        printf("userdata=%s ",(char *)userdata);
    printf("%s ", str);
}

int main(int argc, char *argv[])
{
    int i;
    char *host = "172.16.2.39";
    int port = 1883;
    int keepalive = 30;
    bool clean_session = true;
    struct mosquitto *mosq = NULL;

    mosquitto_lib_init();
    mosq = mosquitto_new("8252", clean_session, "2016");
    if(!mosq){
        fprintf(stderr, "Error: Out of memory. ");
        return 1;
    }
    mosquitto_log_callback_set(mosq, my_log_callback);
    mosquitto_connect_callback_set(mosq, my_connect_callback);
    mosquitto_message_callback_set(mosq, my_message_callback);
    mosquitto_subscribe_callback_set(mosq, my_subscribe_callback);

    if(mosquitto_connect(mosq, host, port, keepalive)){
        fprintf(stderr, "Unable to connect. ");
        return 1;
    }

    mosquitto_loop_forever(mosq, -1, 1);

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

热门文章