首页 > 其他分享> > 111-STM32+ESP8266+AIR202基本控制篇-移植单片机MQTT包,实现stm32+esp8266连接MQTT服务器(透传和非透传模式下都有)

111-STM32+ESP8266+AIR202基本控制篇-移植单片机MQTT包,实现stm32+esp8266连接MQTT服务器(透传和非透传模式下都有)

2021-07-31 12:04:17 作者：互联网

说明

此节适用于所有支持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);//´¦Àí·¢ËÍÐÄÌø°ü
        }