【STM32】esp8266通过MQTT连接服务器|订阅发布

1. MQTT协议

该协议为应用层协议，传输层使用的是tcp,MQTT的订阅和发布，就相当于在抖音中你关注了某个领域的博主（订阅），如果有其他人发了作品就会推给你（发布），默认已经安装好了

简单演示
订阅

mosquitto_sub -h "47.121.24.16" -p 1883  -t "A" 

mosquitto_sub 订阅指令
-h 主机ip
-p 端口号1883
-t 主题

发布

mosquitto_pub -h "47.121.24.16" -p 1883 -t "A" -m "nihaoma"

mosquitto_pub 发布指令
-h 主机ip
-p 端口号1883
-t 主题
-m 内容

订阅主题“A”的就可以收到

2.esp8266通过MQTT连接服务器

1.需要在单片机里面建立配置用户信息

void esp8266_connect_MQTT(const char*ip,int port,const char* user,const char* password)

//需要云服务器ip地址和端口号，以及MQTT服务器的用户名以及密码，如果是匿名用户的话，用户名和密码随便给

根据手册构建指令配置信息保存在单片机rom

2.eps8266连接MQTT



连接成功在服务器这边验证

isof -i |grep mosquitto   //查看链接情况

3.发布

单片机发布，MQTT服务器这边订阅就可以收到

void esp8266_Publish(const char* topic,const char*content);//发布的主题以及内容

4.订阅

在MQTT服务器这边发布，esp8266这边订阅，然后通过串口2返回给单片机，单片机将其给串口1，然后在串口助手上显示出来

void esp8266_subscribe(const char* topic)//订阅主题

发现发送的helloworld收到成了helloword了，所以我们需要

	   uint8_t data,flag=0;
	   uint32_t old_tick=0;
  while (1)
  {
    /* USER CODE END WHILE */

    /* USER CODE BEGIN 3 */
	
		if(HAL_GetTick()-old_tick>50&&flag) //假如说收到最后一个字符后等50ms后，说明接收完了
		{
		
		    clearbuffer();  //打印到串口1，清除缓冲区
			  flag=0;  //防止频繁冲刷缓冲区
		
		
		}
    if(HAL_UART_Receive(&huart2,(uint8_t*)&data,1,10)==HAL_TIMEOUT)  //一个字符和另一个字符很快就能接收，如果超过10ms，就直接continue
		{
		 continue;
		
		}
		else
		{	
		  buffer[num++]=data;  //放到缓冲区里面
		  old_tick=HAL_GetTick();//获取当前字符时间，用于和下一个字符作对比
			flag=1;
		
		
		
		}
	 
		
  }