最近一直在做关于气浮台的项目,里面有一个小环节就是需要把设备的数据传输下来,因为之前对通信几乎是小白,加上时间比较紧,凡是涉及到底层的东西都不敢碰,最后比较了一番选了ESP 8266这个模块来开发,通过AT指令进行开发,用的是C语言,运行在PC 104上(当然普通PC更没问题了),大概五天时间就做完了,下面介绍一下详细内容。
(一)ESP 8266模块介绍
这个模块的详细资料网上很容易找到,在此就不详述了,简单说几点吧。
这个模块开发有两种方式:第一种是用官方SDK来开发,适合对硬件有一定了解的朋友入手,因为这个模块本身的功能其实很强大,只用来通讯有点小题大做的感觉,但是这种方式不适合新手,入手难度有点高;第二种就是AT指令开发,很简单,拿一般的串口助手就可以调试。(注意调试的时候一定要先按回车再发送)
?
?
这个模块总共有三种工作方式:AP,STATION,AP+STATION。因为我需要完成的是多个设备数据传输,因此透传就不考虑了,这里我用的是一个模块用作热点同时开启服务器(用AP+STATION),通过串口接在终端上收数据;其他的模块通过串口接在设备上(用STATION)。相当于组建了一个小的局域网,基于TCP协议的WiFi通信。
这里再单独提一下,用AT指令开发有一个很头疼的地方在于指令的返回格式不统一,所以程序里面的判断条件会比较多。后面我会仔细的总结一下,其他的信息大家可以去找用户手册,里面对模块的介绍以及AT指令都比较完整。
(二)用C语言实现WIN 32下的串口通讯
这一步说白了就是怎么用C语言去完成串口助手最基本的功能,但是也必须要仔细,很多地方容易出错。
1. 首先打开串口,Createfile函数的具体用法在此不详述了,不熟悉的朋友可以去百度。
espCom = CreateFile("COM3", GENERIC_READ | GENERIC_WRITE, 0, NULL, OPEN_EXISTING, 0, NULL); if (espCom == INVALID_HANDLE_VALUE) { printf("open COM3 failed\n"); exit(2); }
提醒一下大家,如果设备的串口不是COM1-COM9,比如是COM10,那么函数第一个不能写成“COM10”了,得写成“\\\\.\\COM10”,因为COM10以上的串口对于文件名系统而言只是一般的文件,而非串行设备。
2. 完成串口相应的配置工作
espTimeOuts.ReadIntervalTimeout = 500;//MAXDWORD; //5000; espTimeOuts.ReadTotalTimeoutConstant = 5000; //0;//1000; espTimeOuts.ReadTotalTimeoutMultiplier = 500;// 0;//500; espTimeOuts.WriteTotalTimeoutConstant = 2000; espTimeOuts.WriteTotalTimeoutMultiplier = 500; if (!SetCommTimeouts(espCom, &espTimeOuts)) { printf("写入超时参数错误\n"); exit(3); } if (!SetupComm(espCom, 1024, 1024)) { printf("设置串口读写缓冲区失败\n"); exit(4); } if (!GetCommState(espCom, &espdcb)) { printf("获取串口属性失败\n"); exit(5); } espdcb.BaudRate = BAUD_RATE; espdcb.ByteSize = 8; espdcb.Parity = NOPARITY; espdcb.StopBits = ONESTOPBIT; if (!SetCommState(espCom, &espdcb)) { printf("设置串口参数出错\n"); exit(6); } printf("无线通信串口打开成功!\n"); PurgeComm(espCom, PURGE_TXCLEAR | PURGE_RXCLEAR | PURGE_RXABORT | PURGE_TXABORT); //清空缓冲区
里面总共涉及到了5个工作,对应的函数介绍不理解请自行百度,代码只简单地注释了一下。其中容易出问题的在于SetCommTimeouts的时间设置,读取时间间隔、延时这些大家一定要仔细,初始参数可以就按上面的取,但如果出现乱码或者读取不完整的情况,先调一调这几个参数,每个人的需求不同,以上参数也可能不同。
3. 接下来分别建立读和写的线程
为了方便后面的介绍,这里先把一些代码定义贴出来(以下介绍将分为服务器和客户端两部分)
(1)这是客户端的定义
HANDLE espCom; COMMTIMEOUTS espTimeOuts; COMSTAT comstat; DCB espdcb; unsigned int esp_order = 0; //指令执行顺序 char ESP_RXBUFF[200]; char ESP_SENDDATA[200] = {}; //数据发送包 float ESP_SYS_DATA[20] = {}; //系统数据 BOOL ESP_RTS=0; //数据发送请求标志 //AT指令集 const char *esp_com_AT = { "AT\r\n" }; //test const char *esp_com_AT_CWMODE = { "AT+CWMODE=1\r\n" }; //Station模式 const char *esp_com_AT_CIPMUX = { "AT+CIPMUX=1\r\n" }; //多连接模式 const char *esp_com_AT_CIPSERVER = { "AT+CIPSERVER=0\r\n" }; //关闭服务器 const char *esp_com_AT_CWJAP = { "AT+CWJAP=\"esp\",\"123456\"\r\n" }; //连接esp网络 const char *esp_com_AT_CIPSTART = { "AT+CIPSTART=\"TCP\",\"192.168.4.1\",5000\r\n" }; //加入服务器 const char *esp_com_AT_CIPSEND = { "AT+CIPSEND=40\r\n" }; //请求发送数据 const char *esp_com_AT_RST = { "AT+RST\r\n" }; //ESP8266重启 int esp_AT_len = strlen(esp_com_AT); int esp_AT_CWMODE_len = strlen(esp_com_AT_CWMODE); int esp_AT_CIPMUX_len = strlen(esp_com_AT_CIPMUX); int esp_AT_CIPSERVER_len = strlen(esp_com_AT_CIPSERVER); int esp_AT_CWJAP_len = strlen(esp_com_AT_CWJAP); int esp_AT_CIPSTART_len = strlen(esp_com_AT_CIPSTART); int esp_AT_CIPSEND_len = strlen(esp_com_AT_CIPSEND); int esp_AT_RST_len = strlen(esp_com_AT_RST);
主函数中开启读写线程
HANDLE hThread1 = CreateThread(NULL, 0, ReadThread, 0, 0, NULL); //读线程 HANDLE hThread2 = CreateThread(NULL, 0, WriteThread, 0, 0, NULL); //写线程 CloseHandle(hThread1); CloseHandle(hThread2);
函数具体内容。总的来说就是依靠esp_order来一条一条发送指令,在确保指令执行后再发送下一条。(在这里希望大家把需要用到的指令都在串口助手上试一遍,特别是返回的内容一定要看清楚,大部分指令都是返回XXXXXXXXXXX OK,这一部分只需要检测OK就能确保指令执行了,但有些特殊的就需要单独设置了,比如重启指令最后会返回一串乱码+ready)
int ESP_ReceiveChar() //读命令 { DWORD ESP_READ_COUNT; BOOL bReadResult; BOOL bResult; DWORD dwError; for (;;) { bResult = ClearCommError(espCom, &dwError, &comstat); if (comstat.cbInQue == 0) continue; bReadResult = ReadFile(espCom, ESP_RXBUFF, 200, &ESP_READ_COUNT, NULL); if (!bReadResult) { printf("读串口失败!\n"); return FALSE; } if ((esp_order == 0)||(esp_order>=4)) //检查测试指令以及后续指令的返回情况 { if (ESP_RXBUFF[ESP_READ_COUNT - 4] == ‘O‘) { printf("%s\r", ESP_RXBUFF); esp_order++; } } else { if (ESP_RXBUFF[ESP_READ_COUNT - 4] == ‘d‘) //重启指令检查 { printf("ready\n"); esp_order++; } } if ((ESP_RXBUFF[ESP_READ_COUNT - 4] == ‘I‘) || (ESP_RXBUFF[ESP_READ_COUNT - 5] == ‘T‘)) //检查自动连接WiFi的情况 { printf("%s\r", ESP_RXBUFF); esp_order++; } if (ESP_RXBUFF[ESP_READ_COUNT - 2] == ‘>‘) //数据发送请求成功标志 { printf("%s", ESP_RXBUFF); esp_order++; } memset(ESP_RXBUFF, 0, 200);//清空缓冲区 PurgeComm(espCom, PURGE_RXCLEAR | PURGE_RXABORT); } return 0; } DWORD WINAPI ReadThread(LPVOID pParam) //读线程 { ESP_ReceiveChar(); return 0; } int ESP_WriteChar(const char* WriteBuffer, DWORD NumToSend) //写命令 { COMSTAT ComStat; DWORD dwErrorFlags; BOOL bWriteStat; DWORD BytesSent; ClearCommError(espCom, &dwErrorFlags, &ComStat); bWriteStat = WriteFile(espCom, WriteBuffer, NumToSend, &BytesSent, NULL); if (!bWriteStat) printf("写串口失败"); if (BytesSent != NumToSend) printf("WARNING: WriteFile() error.. Bytes Sent: %d; MessageLength: %d\n", BytesSent, NumToSend); PurgeComm(espCom, PURGE_TXCLEAR | PURGE_TXABORT); return true; } DWORD WINAPI WriteThread(LPVOID pParam) //写线程 { while (espCom != INVALID_HANDLE_VALUE) { Sleep(1000); if (esp_order == 0) ESP_WriteChar(esp_com_AT, esp_AT_len); if (esp_order == 1) ESP_WriteChar(esp_com_AT_RST, esp_AT_RST_len); if (esp_order == 4) ESP_WriteChar(esp_com_AT_CIPSTART, esp_AT_CIPSTART_len); if ((esp_order >= 5) && (esp_order % 2 != 0) && (ESP_RTS == 0)) //发送数据请求 { ESP_RTS = 1; ESP_WriteChar(esp_com_AT_CIPSEND, esp_AT_CIPSEND_len); //Sleep(500); //ESP_WriteChar(ESP_SENDDATA_TEST, strlen(ESP_SENDDATA_TEST)); } if ((esp_order >= 5) && (esp_order % 2 == 0) && (ESP_RTS == 1)) //数据发送 { ESP_RTS = 0; memset(ESP_SENDDATA, 0, 200); unsigned char esp_ls[4]; for (int i = 0, j = 0; i < 10; i++, j += 4) { memcpy(esp_ls, &ESP_SYS_DATA[i], sizeof(float)); ESP_SENDDATA[j] = esp_ls[0]; ESP_SENDDATA[j + 1] = esp_ls[1]; ESP_SENDDATA[j + 2] = esp_ls[2]; ESP_SENDDATA[j + 3] = esp_ls[3]; } //检查发送数据 float final[10]; for (int i = 0, j = 0; i < 10; i++, j += 4) { memcpy(&final[i], &ESP_SENDDATA[j], sizeof(float)); } for (int i = 0; i<10; i++) printf("%f ", final[i]); printf("\n"); ESP_WriteChar(ESP_SENDDATA, 40); } } return true; }
!!!注意:以上代码执行的前提是先按以下指令在串口助手进行设置
AT+CWMODE=1
AT+CIPMUX=1
AT+CIPSERVER=0
AT+CWJAP="esp","123456" //这个是默认的WiFi,也可以自己设置名字密码
AT+CIPSTART="TCP","192.168.4.1",5000 //ip地址需要在服务器那个模块上进行查询(后面关于服务器的代码有),5000是开服务器的时候设置的端口
(2)服务器的定义
HANDLE espCom; COMMTIMEOUTS espTimeOuts; COMSTAT comstat; DCB espdcb; unsigned int esp_order = 0; //指令执行顺序 char ESP_RXBUFF[200]; //读入数据缓冲区 //AT指令集 const char *esp_com_AT = { "AT\r\n" }; //TEST const char *esp_com_AT_CWMODE = { "AT+CWMODE=3\r\n" }; //AP+Station const char *esp_com_AT_CIPMUX = { "AT+CIPMUX=1\r\n" }; //多连接模式 const char *esp_com_AT_CIPSERVER = { "AT+CIPSERVER=1,5000\r\n" }; //开启服务器 const char *esp_com_AT_CIFSR = { "AT+CIFSR\r\n" }; //查询IP地址 int esp_AT_len = strlen(esp_com_AT); int esp_AT_CWMODE_len = strlen(esp_com_AT_CWMODE); int esp_AT_CIPMUX_len = strlen(esp_com_AT_CIPMUX); int esp_AT_CIPSERVER_len = strlen(esp_com_AT_CIPSERVER); int esp_AT_CIFSR_len = strlen(esp_com_AT_CIFSR);
读写线程的开启与客户端相同,下面贴出具体函数
int ESP_ReceiveChar() //读指令 { DWORD ESP_READ_COUNT; BOOL bReadResult; BOOL bResult; DWORD dwError; for (;;) { bResult = ClearCommError(espCom, &dwError, &comstat); //清除串口error if (comstat.cbInQue == 0) continue; bReadResult = ReadFile(espCom, ESP_RXBUFF, 200, &ESP_READ_COUNT, NULL); if (!bReadResult) { printf("读串口失败!\n"); return FALSE; } if (esp_order == 6) //注意两个if调用顺序 { if (ESP_RXBUFF[ESP_READ_COUNT - 5] == ‘E‘) //显示client连接情况 printf("%s\n", ESP_RXBUFF); else //client发送的数据 { //printf("原始:%s\n", ESP_RXBUFF); float final[10]; for (int i = 0; i <= 11; i++) //ESP_RXBUFF头字节 { printf("%c", ESP_RXBUFF[i]); } printf("\n"); for (int i = 0, j = 12; i < 10; i++, j += 4) //数据包 { memcpy(&final[i], &ESP_RXBUFF[j], sizeof(float)); } for (int i = 0; i < 10; i++) printf("%f ", final[i]); printf("\n"); } } if (ESP_RXBUFF[ESP_READ_COUNT - 4] == ‘O‘) //指令执行情况 { printf("%s\r", ESP_RXBUFF); esp_order++; //printf("%d\n",strlen(ESP_RXBUFF));//AT指令下返回字符串长度为11 } memset(ESP_RXBUFF, 0, 200);//清空缓冲区 //printf("缓冲区长度:%d\n", strlen(ESP_RXBUFF)); PurgeComm(espCom, PURGE_RXCLEAR | PURGE_RXABORT); } return 0; } DWORD WINAPI ReadThread(LPVOID pParam) //读线程 { ESP_ReceiveChar(); return 0; } int ESP_WriteChar(const char* WriteBuffer, DWORD NumToSend) //写指令 { COMSTAT ComStat; DWORD dwErrorFlags; BOOL bWriteStat; DWORD BytesSent; ClearCommError(espCom, &dwErrorFlags, &ComStat); bWriteStat = WriteFile(espCom, WriteBuffer, NumToSend, &BytesSent, NULL); if (!bWriteStat) { printf("写串口失败"); } if (BytesSent != NumToSend) { printf("WARNING: WriteFile() error.. Bytes Sent: %d; MessageLength: %d\n", BytesSent, NumToSend); } PurgeComm(espCom, PURGE_TXCLEAR | PURGE_TXABORT); return true; } DWORD WINAPI WriteThread(LPVOID pParam) //写线程 { while (espCom != INVALID_HANDLE_VALUE) { Sleep(1000); if (esp_order == 0) ESP_WriteChar(esp_com_AT, esp_AT_len); else if (esp_order == 1) ESP_WriteChar(esp_com_AT_CWMODE, esp_AT_CWMODE_len); else if (esp_order == 2) ESP_WriteChar(esp_com_AT_CIPMUX, esp_AT_CIPMUX_len); else if (esp_order == 3) ESP_WriteChar(esp_com_AT_CIPSERVER, esp_AT_CIPSERVER_len); else if (esp_order == 4) { esp_order++; ESP_WriteChar(esp_com_AT_CIFSR, esp_AT_CIFSR_len); } } return true; }
代码有点绕,简单解释一下吧。先按照所需的AT指令进行设置,然后就是接收客户端发来的数据,我上面的发送内容是设备数据,都是float类型,通过memcpy换到char数组然后发送出去。可以对照客户端的代码看一下。
这是实际测试效果
?
(三)总结
ESP 8266是一个很容易上手的无线通信模块,在物联网领域用的很多。用AT指令可以加快开发速度,但是如果对传输要求较高,时间比较充裕也可以去采用SDK,效果会更好。上面的代码又不太明白的朋友可以留言或者私信,有空我会尽可能帮助大家。
原文地址:https://www.cnblogs.com/qi-zhang/p/11375182.html