STM32+W5500+MQTT+Android实现远程数据采集及控制

1万 · 2019-11-12 16:42

STM32+W5500+MQTT+Android实现远程数据采集及控制

1万 · 2019-11-12 16:42

1，STM32F405为主控芯片，它通过传感器采集环境数据，比如温度，湿度，光照度，大气压强等；
2，主控芯片通过W5500模块将测量的数据通过MQTT协议方式发布到MQTT服务器（服务器域名和IP见固件程序）；
3，主控订阅LED灯控制的消息，当接收到对应的控制指令后点亮或者熄灭对应的LED灯；
4，安卓手机端订阅传感器数据的消息，当接收到消息后将传感器数据在界面显示；
5，安卓手机可发送点亮或者熄灭LED灯的指令到服务器，然后服务器会将该指令转发给STM32主控，然后STM32主控解析该指令并执行指令。

1万 · 2019-11-12 16:44

1.1 MQTT的移植
MQTT的移植非常简单，将C/C++ MQTT Embedded clients的代码添加到工程中，然后我们只需要再次封装4个函数即可：

int transport_sendPacketBuffer(unsigned char* buf, int buflen);
int transport_getdata(unsigned char* buf, int count);
int transport_open(void);
int transport_close(void);
transport_sendPacketBuffer：通过网络以TCP的方式发送数据；
transport_getdata：TCP方式从服务器端读取数据，该函数目前属于阻塞函数；
transport_open：打开一个网络接口，其实就是和服务器建立一个TCP连接；
transport_close：关闭网络接口。

1万 · 2019-11-12 16:44

/**
* @brief  通过TCP方式发送数据到TCP服务器
* @param  buf 数据首地址
* @param  buflen 数据长度
* @retval 小于0表示发送失败
*/
int transport_sendPacketBuffer(unsigned char* buf, int buflen)
{
return send(SOCK_TCPS,buf,buflen);
}

1万 · 2019-11-12 16:44

/**
* @brief  阻塞方式接收TCP服务器发送的数据
* @param  buf 数据存储首地址
* @param  count 数据缓冲区长度
* @retval 小于0表示接收数据失败
*/
int transport_getdata(unsigned char* buf, int count)
{
return recv(SOCK_TCPS,buf,count);
}

1万 · 2019-11-12 16:44

/**
* @brief 打开一个socket并连接到服务器
* @param 无
* @retval 小于0表示打开失败
*/
int transport_open(void)
{
int32_t ret;
//新建一个Socket并绑定本地端口5000
ret = socket(SOCK_TCPS,Sn_MR_TCP,5000,0×00);
if(ret != SOCK_TCPS){
printf(“%d:Socket Error\r\n”,SOCK_TCPS);
while(1);
}else{
printf(“%d:Opened\r\n”,SOCK_TCPS);
}

1万 · 2019-11-12 16:44

//连接TCP服务器
ret = connect(SOCK_TCPS,domain_ip,1883);//端口必须为1883
if(ret != SOCK_OK){
printf(“%d:Socket Connect Error\r\n”,SOCK_TCPS);
while(1);
}else{
printf(“%d:Connected\r\n”,SOCK_TCPS);
}
return 0;
}

1万 · 2019-11-12 16:45

/**
* @brief 关闭socket
* @param 无
* @retval 小于0表示关闭失败
*/
int transport_close(void)
{
close(SOCK_TCPS);
return 0;
}

1万 · 2019-11-12 16:45

/**
* @brief  向代理（服务器）发送一个消息
* @param  pTopic 消息主题
* @param  pMessage 消息内容
* @retval 小于0表示发送失败
*/
int mqtt_publish(char *pTopic,char *pMessage)
{
int32_t len,rc;
MQTTPacket_connectData data = MQTTPacket_connectData_initializer;
unsigned char buf[200];
MQTTString topicString = MQTTString_initializer;
int msglen = strlen(pMessage);
int buflen = sizeof(buf);

data.clientID.cstring = “me”;
data.keepAliveInterval = 5;
data.cleansession = 1;
len = MQTTSerialize_connect(buf, buflen, &data); /* 1 */

topicString.cstring = pTopic;
len += MQTTSerialize_publish(buf + len, buflen – len, 0, 0, 0, 0, topicString, (unsigned char*)pMessage, msglen); /* 2 */

len += MQTTSerialize_disconnect(buf + len, buflen – len); /* 3 */
transport_open();
rc = transport_sendPacketBuffer(buf,len);
transport_close();
if (rc == len)
printf(“Successfully published\n\r”);
else
printf(“Publish failed\n\r”);
return 0;
}

1万 · 2019-11-12 16:45

下面我们看下主函数的代码，思路也比较清晰：

int main(void)
{
static char meassage[200];
int rc;
char *led;
char led_value;
float temperature,humidity,light,pressure;
srand(0);
//配置LED灯引脚
LED_Config();
//初始化配置网络
network_init();
while(1){
memset(meassage,0,sizeof(meassage));
//订阅消息
rc = mqtt_subscrib(“pyboard_led”,meassage);
printf(“rc = %d\n\r”,rc);
if(rc >= 0){
printf(“meassage = %s\n\r”,meassage);
//解析JSON格式字符串并点亮相应的LED灯
cJSON *root = cJSON_Parse(meassage);
if(root != NULL){
led = cJSON_GetObjectItem(root,”led”)->valuestring;
printf(“led = %s\n\r”,led);
led_value = cJSON_GetObjectItem(root,”value”)->valueint;
if(!strcmp(led,”red”)){
if(led_value){
LED_On(LED_RED);
}else{
LED_Off(LED_RED);
}
}else if(!strcmp(led,”green”)){
if(led_value){
LED_On(LED_GREEN);
}else{
LED_Off(LED_GREEN);
}
}else if(!strcmp(led,”blue”)){
if(led_value){
LED_On(LED_BLUE);
}else{
LED_Off(LED_BLUE);
}
}else if(!strcmp(led,”yellow”)){
if(led_value){
LED_On(LED_YELLOW);
printf(“Yellow On\n\r”);
}else{
LED_Off(LED_YELLOW);
printf(“Yellow Off\n\r”);
}
}
// 释放内存空间
cJSON_Delete(root);
}else{
printf(“Error before: [%s]\n\r”,cJSON_GetErrorPtr());
}
}
delay_ms(500);
//获取传感器测量数据，该示例使用随机数
temperature = rand()%50;
humidity = rand()%100;
light = rand()%1000;
pressure = rand()%1000;
//将数据合成为JSON格式数据
sprintf(meassage,”{\”temperature\”:%.1f,\”humidity\”:%.1f,\”light\”:%.1f,\”pressure\”:%.1f}”,temperature,humidity,light,pressure);
//将数据发送出去
mqtt_publish(“pyboard_value”,meassage);
}
}