MQTT-C-PUB

/*
============================================================================
Name        : mqtest.c
Author      :
Version     :
Copyright   : Your copyright notice
Description : Hello World in C, Ansi-style
============================================================================
*/

#include <stdio.h>
#include <stdlib.h>
#include <mosquitto.h>
#include <string.h>
void my_message_callback(struct mosquitto *mosq, void *userdata, const struct mosquitto_message *message)
{
   if(message->payloadlen){
       printf("%s %s\n", message->topic, message->payload);
   }else{
       printf("%s (null)\n", message->topic);

}

fflush(stdout);
}

void my_connect_callback(struct mosquitto *mosq, void *userdata, int result)
{
int i;
if(!result){

mosquitto_subscribe(mosq, NULL, "lgt", 2);
       /*mosquitto_publish(mosq,NULL,"lgt")*/
       /*int payloadlen, const void *payload, int qos, bool retain*/
   }else{
       fprintf(stderr, "Connect failed\n");
   }
}

void my_subscribe_callback(struct mosquitto *mosq, void *userdata, int mid, int qos_count, const int *granted_qos)
{
int i;

printf("Subscribed (mid: %d): %d", mid, granted_qos[0]);
   for(i=1; i<qos_count; i++){
       printf(", %d", granted_qos[i]);
   }

printf("\n");
}

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

int main(void) {
puts("!!!Hello World!!!");
/* prints !!!Hello World!!! */

int i=0;
       char *host = "localhost";
       char dst[]="lgttest12321321";
       char dst1[20];
       char ddd[200];
       int port = 1883;
       int keepalive = 60;
       bool clean_session = true;
       struct mosquitto *mosq = NULL;
       mosquitto_lib_init();
       mosq = mosquitto_new("track01", clean_session, NULL);
           if(!mosq){
           fprintf(stderr, "Error: Out of memory.\n");
           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(", %d", i);
return 1;

}

for(;;)
{

i++;
           /*itoa(i,dst1,10);*/
           sprintf(dst1, "%d", i);
           /**ddd=strcat(dst, dst1);*/
           //dst1=dst;
           mosquitto_publish(mosq, NULL, "lgt",strlen(dst1), dst1, 0, true);
           /*fprintf(", %d", i);*/
                }

mosquitto_loop_forever(mosq, -1, 1);

mosquitto_destroy(mosq);
mosquitto_lib_cleanup();

return 0;
/*return EXIT_SUCCESS;*/
}

巴特西

MQTT-C-PUB

最新文章

热门文章