#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;
}