mqtt发布和订阅

mqtt发布和订阅，使用方法：1）开始mqtt服务端；2编译fake_user_publish和fake_user_sub;3运行两个可执行文件；效果：当fake_user_publish发布一个内容时，fake_user_sub订阅进程会收到相关的topic和payload。验证通过！

#include 
#include 
#include 
#include 

#define HOST “localhost“
#define PORT  1883
#define KEEP_ALIVE 60
#define MSG_MAX_SIZE  512

bool session = true;

int main（）
{
    char buff[MSG_MAX_SIZE];
    struct mosquitto *mosq = NULL;
    
    mosquitto_lib_init（）;
   
    mosq = mosquitto_new（NULLsessionNULL）;
    if（!mosq）{
        printf（“create client failed..\n“）;
        mosquitto_lib_cleanup（）;
        return 1;
    }
   
    if（mosquitto_connect（mosq HOST PORT KEEP_ALIVE））{
        fprintf（stderr “Unable to connect.\n“）;
        return 1;
    }
    
    int loop = mosquitto_loop_start（mosq）;
    if（loop != MOSQ_ERR_SUCCESS）
    {
        printf（“mosquitto loop error\n“）;
        return 1;
    }
    while（fgets（buff MSG_MAX_SIZE stdin） != NULL）
    {
                /*·¢²¼ÏϢ*/
                mosquitto_publish（mosqNULL“Gai:“strlen（buff）+1buff00）;
                memset（buff0sizeof（buff））;
    }
    mosquitto_destroy（mosq）;
    mosquitto_lib_cleanup（）;
    return 0;
}

 属性            大小     日期    时间   名称
----------- ---------  ---------- -----  ----

     文件       1052  2018-11-28 15:56  mqtt-client\fake_user_publish.c

     文件       1987  2018-11-28 15:54  mqtt-client\fake_user_sub.c

     目录          0  2018-11-29 10:53  mqtt-client

----------- ---------  ---------- -----  ----

                 3039                    3