說明

此節適用於所有支持TCP通信的模組!

准備一份程序(先看透傳版)

透傳版就是配置好模組以后直接發送數據給模組,模組就把信息直接轉發到網絡

模組從網絡接收到數據就直接輸出.

1.准備一份已經實現TCP通信的程序

2.TCP連接

注:因為是WiFi模塊,所以需要連接路由器(連接的路由器名稱和密碼根據自己的修改)

連接的IP地址是MQTT服務器的地址

連接TCP以后模塊進入透傳模式

2.我把網絡接收的數據緩存到了環形隊列

開始移植

1.把這節里面的mem和MQTT文件夾拷貝到工程目錄

注:我提供的STM32F10xTemplate工程里面已經有了mem,可不用拷貝

2.把mem和MQTT添加到工程

3.寫上下面的程序

注:MQTT信息根據自己的修改

#include "mqtt.h"

char mqtt_connect_flag=0;//1:Á¬½ÓÉÏMQTT·þÎñÆ÷; 0:Î´Á¬½ÓÉÏMQTT·þÎñÆ÷
char mqtt_id[50] = "11223344";//ClientID
char mqtt_username[20] = "yang";//ÓÃ»§Ãû
char mqtt_password[50] = "11223344";//ÃÜÂë
char mqtt_keepalive = 30;//ÐÄÌø°üÊ±¼ä
unsigned char mqtt_publish_topic[30]="";//´æ´¢MQTT·¢²¼µÄÖ÷Ìâ
unsigned char mqtt_subscribe_topic[30]="";//´æ´¢MQTT¶©ÔÄµÄÖ÷Ìâ


/**¶©ÔÄÖ÷Ìâ³É¹¦**/
void subscribedCb(int pdata){
    printf("\r\n³É¹¦¶©ÔÄÖ÷Ìâ\r\n");
}
/**¶©ÔÄÖ÷ÌâÊ§°Ü**/
void failsubscribedCb(int pdata){
    printf("\r\n¶©ÔÄÖ÷ÌâÊ§°Ü\r\n");
}
/**·¢²¼³É¹¦**/
void PublishedCb(){
    printf("\r\n·¢²¼³É¹¦\r\n");
}

/*Á¬½ÓÉÏMQTT»Øµ÷º¯Êý*/
void MqttConnect(){
    printf("\r\nÁ¬½Ó³É¹¦**********************************************************\r\n");
    mqtt_connect_flag = 1;
}
/**MQTT¶Ï¿ªÁ¬½Ó»Øµ÷**/
void MqttDisConnect(){
    printf("\r\nÁ¬½Ó¶Ï¿ª**********************************************************\r\n");
    mqtt_init(&mymqtt);
    mqtt_connect_flag=0;
}
/**
* @brief   MQTT½ÓÊÕÊý¾Ý»Øµ÷
* @param   topic:Ö÷Ìâ
* @param   topic_len:Ö÷Ìâ³¤¶È
* @param   data:½ÓÊÕµÄÊý¾Ý
* @param   lengh:½ÓÊÕµÄÊý¾Ý³¤¶È
* @retval  None
* @warning None
* @example
**/
void MqttReceive(const char* topic, uint32_t topic_len,const char *data, uint32_t lengh)
{    
}


void MqttConnect(void);//Á¬½ÓÉÏMQTT»Øµ÷
void MqttDisConnect(void);//MQTT¶Ï¿ªÁ¬½Ó»Øµ÷
void subscribedCb(int pdata);//¶©ÔÄ³É¹¦»Øµ÷
void failsubscribedCb(int pdata);//¶©ÔÄÊ§°Ü»Øµ÷
void PublishedCb(void);//³É¹¦·¢²¼ÏûÏ¢»Øµ÷
void MqttReceive(const char* topic, uint32_t topic_len,const char *data, uint32_t lengh);//½ÓÊÕµ½Êý¾Ý»Øµ÷

    mqtt_init(&mymqtt);
    mqtt_connect_reg(&mymqtt,MqttConnect);//×¢²áÁ¬½Ó»Øµ÷º¯Êý
    mqtt_disconnect_reg(&mymqtt,MqttDisConnect);//×¢²á¶Ï¿ªÁ¬½Ó»Øµ÷º¯Êý
    mqtt_received_reg(&mymqtt,MqttReceive);//×¢²á½ÓÊÕÊý¾Ý»Øµ÷º¯Êý

//Á¬½ÓÉÏMQTT·þÎñÆ÷
        if(mqtt_connect_flag)
        {
            mqtt_send_function(&mymqtt);//ÌáÈ¡·¢ËÍ»º´æµÄMQTTÐÒé
            mqtt_keep_alive(&mymqtt);//´¦Àí·¢ËÍÐÄÌø°ü
        }