1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
#ifndef __MQTT_H
#define __MQTT_H
#include "stm32f10x.h"
/*
*以下参数需要用户自行修改才能测试用过
*/
#define User_ESP8266_SSID
"abgo"
//wifi名字
#define User_ESP8266_PWD
"1234567889"
//wifi密码
#define User_ESP8266_client_id
"12345|securemode=3\,signmethod=hmacsha1|"
//MQTTclientID 用于标志client身份
最长256字节
#define User_ESP8266_username
"STM32F103C8T6&gvksFxpgc8R"
//用于登录 MQTT 服务器 的 username, 最长 64 字节
#define User_ESP8266_password
"A256A5DE1F22B4EAB28CA00974D115D074169E9F"
//用于登录 MQTT 服务器 的 password, 最长 64 字节
#define User_ESP8266_MQTTServer_IP
"gvksFxpgc8R.iot-as-mqtt.cn-shanghai.aliyuncs.com"
//MQTT本地服务器IP或者域名
#define User_ESP8266_MQTTServer_PORT
1883
//服务器端口号
//自定义Topic
#define User_ESP8266_MQTTServer_Topic
"/gvksFxpgc8R/STM32F103C8T6/user/test"
//属性上报
#define User_ESP8266_MQTTServer_Topic_Property_Post
"/sys/gvksFxpgc8R/STM32F103C8T6/thing/event/property/post"
#define User_ESP8266_MQTTServer_Topic_Property_Post_Reply	"/sys/gvksFxpgc8R/STM32F103C8T6/thing/event/property/post_reply"
//属性设置
#define User_ESP8266_MQTTServer_Topic_Property_Set
"/sys/gvksFxpgc8R/STM32F103C8T6/thingrvice/propertyt"
#define User_ESP8266_MQTTServer_Topic_Property_Set_Reply	"/sys/gvksFxpgc8R/STM32F103C8T6/thingrvice/propertyt_reply"
//事件上报
#define User_ESP8266_MQTTServer_Topic_Event_Post
"/sys/gvksFxpgc8R/STM32F103C8T6/thing/event/${tsl.event.identifier}/post"
#define User_ESP8266_MQTTServer_Topic_Event_Post_Reply
"/sys/gvksFxpgc8R/STM32F103C8T6/thing/event/${tsl.event.identifier}/post_reply"
//服务调用
#define User_ESP8266_MQTTServer_Topic_Service_Post
"/sys/gvksFxpgc8R/STM32F103C8T6/thingrvice/${tsl.service.identifier}"
#define User_ESP8266_MQTTServer_Topic_Service_Post_Reply	"/sys/gvksFxpgc8R/STM32F103C8T6/thingrvice/${tsl.service.identifier}_reply"
extern volatile uint8_t MQTTClosedFlag;
//连接状态标志
extern volatile uint8_t MQTTReceiveFlag;
//接收数据标志
void ESP8266_STA_MQTTClient_Link(void);
//MQTT连接阿里云服务器
void Wait_SUB(void);
//等待接收消息并对消息进行解析
#endif

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
#include "mqtt.h"
#include "esp8266.h"
#include "usart.h"
#include "delay.h"
#include <stdlib.h>
#include "led.h"
volatile u8 MQTTClosedFlag = 0;
volatile u8 MQTTReceiveFlag = 0;
void ESP8266_STA_MQTTClient_Link(void)
//MQTT连接阿里云
{
printf("正在配置 ESP8266 MQTT ...rn");
ESP8266_AT_Test();
//恢复出厂默认
ESP8266_Net_Mode_Choose(STA);
//配置热点信息
while(!ESP8266_JoinAP(User_ESP8266_SSID, User_ESP8266_PWD));
ESP8266_MQTTUSERCFG(User_ESP8266_client_id,User_ESP8266_username,User_ESP8266_password);
ESP8266_MQTTCONN( User_ESP8266_MQTTServer_IP, User_ESP8266_MQTTServer_PORT);
ESP8266_MQTTSUB( User_ESP8266_MQTTServer_Topic);
ESP8266_MQTTSUB(User_ESP8266_MQTTServer_Topic_Property_Set);
ESP8266_MQTTSUB( User_ESP8266_MQTTServer_Topic_Property_Set_Reply);
ESP8266_MQTTSUB( User_ESP8266_MQTTServer_Topic_Property_Post_Reply);
printf("ESP8266 MQTT 配置完成 ...rn");
ESP8266_Fram_Record_Struct.InfAll = 0;
}
void ESP8266_STA_MQTTClient_Pub(void)
//通过topic给MQTT服务器发送消息
{
char mqtt_message[1024];
char str[128] = {0};
//STM32向阿里云发送消息
memset(str, sizeof(str),0);
memset(mqtt_message,sizeof(mqtt_message),0);
//sprintf(str,"PowerSwitch:1");//格式化发送字符串到MQTT服务器
//MQTT_SendString (User_ESP8266_MQTTServer_Topic,str);//发送数据到MQTT服务器
//sprintf(mqtt_message,"{\"method\":\"thing.service.property.post\"\,\"id\":\"2012934115\"\,\"params\":{\"PowerSwitch\":1}\,\"version\":\"1.0.0\"}");
//MQTT_SendString (User_ESP8266_MQTTServer_Topic_Property_Post,mqtt_message);//发送数据到MQTT服务器
}
void Wait_SUB(void)
//STM32接收阿里云发来的消息并对消息进行解析
{
char *ret;
char str[20];
int
val;
if(MQTTReceiveFlag == 1)
//判断是否接收到TCP网络数据
{
printf("Message From ESP8266 : %srn",ESP8266_Fram_Record_Struct .Data_RX_BUF);
printf("Length Of Message
: %drn",ESP8266_Fram_Record_Struct.InfBit.FramLength);
ret=strstr(ESP8266_Fram_Record_Struct .Data_RX_BUF,"PowerSwitch");
/rstr函数是找到powerSwitch指针位置
if(ret!=NULL)
{
//printf("This is : %srn",ret);
//测试
str[0]=*(ret+13);
//将powerswith后边的数字提取到str中（但是1此时还是字符型）
str[1]='';
//printf("This is str : %srn",str);
//测试
val=atoi(str);
//atoi函数是将字符型数据转换为十进制数字1或者0
//printf("This is val : %drn",val);
//测试
if(val==0)
{
LED1( OFF );
// 灭
delay_ms(50000);
}
else if(val==1)
{
LED1( ON );
// 亮
delay_ms(50000);
}
}
}
ESP8266_Fram_Record_Struct.InfAll = 0;
//清空ESP8266_Fram_Record_Struct接收标志，准备接收下一条消息
MQTTReceiveFlag = 0;
}

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
#include "stm32f10x.h"
#include "stm32f10x_it.h"
#include "stdio.h"
#include "string.h"
#include "delay.h"
#include "usart.h"
#include "esp8266.h"
#include "tcp.h"
#include "mqtt.h"
#include "led.h"
int main(void)
{
SystemInit();	// 配置系统时钟为72M
LED_GPIO_Config(); //LED 端口初始化
NVIC_PriorityGroupConfig(NVIC_PriorityGroup_2);
delay_init();
uart3_Init(115200);
ESP8266_Init(115200);
ESP8266_STA_MQTTClient_Link();
//MQTT连接阿里云
//UASRT3_RX_TX_TEST();
//测试串口通讯
//ESP8266_STA_TCPClient_UnvarnishSend_Test();
//测试TCP透传模式通讯
//ESP8266_STA_TCPClient_Test();
//测试TCP非透传模式通讯
while(1)
{
delay_ms(60000);
//ESP8266_STA_MQTTClient_Pub();
//通过topic给阿里云发送消息
Wait_SUB();
//检测阿里云发送的消息并显示
}
}