WSL和Windows建立TCP通信协议
1.windows配置
首先是windows端,启动TCP服务端,用来监听指定的端口号,其中IP地址可以设置为任意,否则服务器可能无法正常打开。
addrSer.sin_addr.S_un.S_addr = INADDR_ANY;
recv函数用来接收客户端传输的数据,其中sum表示接收到的字节数。
为了能将接收到的char数据转换成16进制形式,方便与发送数据进行比对。
rece = ToHexString((unsigned char*)recvbuf, sum);
这里sum不能替换为strlen(recvbuf),strlen在检测到"00"后会自动结束,打印的数据不全。
string ToHexString(unsigned char* input, int datasize)
{stringstream ss;ss << setbase(16) << setfill('0');for (int i = 0; i < datasize; i++)ss << setw(2) << (UINT)input[i];return ss.str();
}
TCP接收到的不是一个一个的数据,而是一段一段的数据,中间可能包含着多条信息,需要根据起始位将信息提取出来。
vector<int> positions = findAllSubstringPositions(rece, "aaa55a");
vector<string> s;
if(positions.size()>0){s.push_back(rece.substr(0, positions[0] + 2));for (int i = 1; i < positions.size(); i++) {cout << positions[i - 1] << endl;s.push_back(rece.substr(positions[i-1] + 2, positions[i]- positions[i - 1]));}s.push_back(rece.substr(positions[positions.size()-1]+2));
}
else {s.push_back(rece);
}
for(int j=0;j<= positions.size();j++)cout << s[j] << endl;
这里由于不知道一段包含命令的个数,所以用vector容器来存放比较合适,同时substr第一个参数是起始位置,第二个参数是需要提取字符串的长度,不是终止位置。
2.WSL配置
WSL作客户端,用来监听串口数据并返还给服务端。
第一步:让WSL可以检测到USB
powershell输入usbipd list查看当前USB设备(电脑间测试需要串口盒辅助,另外一台电脑打开串口调试助手,向WSL发送十六进制数据)
usbipd bind --busid 1-6 共享串口
usbipd attach --wsl -b 1-6 附加USB设备到WSL上
WSL输入lsusb检测当前USB设备
ls /dev/tty*查看USB设备的端口号
第二步:WSL开启串口监听
根据查询到的端口号配置端口
//listen uartfd1 = open( "/dev/ttyS9", O_RDWR);if (fd1 == -1) {printf("open error!\n");}int nset = set_opt(fd1, 115200, 8, 'N', 1);if (nset == -1) {printf("set error!\n");}
第三步:配置接收线程
主函数开启线程std::thread uart(uart_read);
while(1)循环里连续接收n = read(fd1, send_buf, UART_BUFF);
n表示接收到的字符串长度,这里read可能会分段接收,加入起始位和长度的判断
if(n>0){if(n>2){if(ToHexString((unsigned char*)send_buf,2) == "a55a"){flag=1;count=0;memset(rece_buf,'\0',UART_BUFF);numchar = (unsigned char)send_buf[2];sum = (int)numchar;}}if(flag){for(int i=count;i<(count+n);i++){rece_buf[i] = send_buf[i-count];}count += n;if(sum == (count-2)){cout << ToHexString((unsigned char*)rece_buf,sum+2) << endl;len=send(client_sockfd, rece_buf, count, 0);//TCP客户端发送count = 0;}else if(sum < (count-2)){flag = 0;count = 0;}}}
这里数据的长度为unsigned char类型,用int强转
count表示接收到的字符串长度,其中rece_buf不能使用strcat来进行拼接,还是"00"的问题。
第四步:文件编译
一般的文件编译使用gcc -o 工程名 工程文件的格式
而std::thread则要
g++ -o 工程名 工程文件名 -lpthread -std=c++11
执行:
./工程名
完整代码
#include<iostream>
#include<cstring>
#include<unistd.h>
#include<sys/types.h>
#include<sys/socket.h>
#include<netinet/in.h>
#include<arpa/inet.h>
#include <termios.h>
#include <stdio.h>
#include <fcntl.h>
#include <sys/stat.h>
#include <unistd.h>
#include <thread>
#include <time.h>
#include <exception>
#include <syslog.h>
#include <stdlib.h>
#include <sstream>
#include <iomanip>
#include <string>using namespace std;
typedef unsigned int UINT;
#define UART_BUFF 2048int client_sockfd;
int len;
int fd1=-1;string ToHexString(unsigned char* input, int datasize)
{stringstream ss;ss << setbase(16) << setfill('0');for (int i = 0; i < datasize; i++)ss << setw(2) << (UINT)input[i];return ss.str();
}int set_opt(int fd,int nSpeed, int nBits, char nEvent, int nStop)
{struct termios newtio,oldtio;if ( tcgetattr( fd,&oldtio) != 0){perror("SetupSerial 1");return -1;}bzero( &newtio, sizeof( newtio ) );newtio.c_cflag |= CLOCAL | CREAD;newtio.c_cflag &= ~CSIZE;switch( nBits ){case 7:newtio.c_cflag |= CS7;break;case 8:newtio.c_cflag |= CS8;break;}switch( nEvent ){case 'O':newtio.c_cflag |= PARENB;newtio.c_cflag |= PARODD;newtio.c_iflag |= (INPCK | ISTRIP);break;case 'E':newtio.c_iflag |= (INPCK | ISTRIP);newtio.c_cflag |= PARENB;newtio.c_cflag &= ~PARODD;break;case 'N':newtio.c_cflag &= ~PARENB;break;}switch( nSpeed ){case 2400:cfsetispeed(&newtio, B2400);cfsetospeed(&newtio, B2400);break;case 4800:cfsetispeed(&newtio, B4800);cfsetospeed(&newtio, B4800);break;case 9600:cfsetispeed(&newtio, B9600);cfsetospeed(&newtio, B9600);break;case 115200:cfsetispeed(&newtio, B115200);cfsetospeed(&newtio, B115200);break;case 460800:cfsetispeed(&newtio, B460800);cfsetospeed(&newtio, B460800);break;default:cfsetispeed(&newtio, B9600);cfsetospeed(&newtio, B9600);break;}if( nStop == 1 )newtio.c_cflag &= ~CSTOPB; else if ( nStop == 2 )newtio.c_cflag |= CSTOPB;newtio.c_cc[VTIME] = 0;newtio.c_cc[VMIN] = 0;tcflush(fd,TCIFLUSH);if((tcsetattr(fd,TCSANOW,&newtio))!=0){perror("com set error");return -1;}return 0;
}void uart_read(){char send_buf[UART_BUFF];int flag=0;int sum=0,count=0;char rece_buf[UART_BUFF];char send_buf_use[UART_BUFF];string numStr;unsigned char numchar;int n;while(1){n = read(fd1, send_buf, UART_BUFF);//cout << n << endl;if(n>0){if(n>2){if(ToHexString((unsigned char*)send_buf,2) == "a55a"){flag=1;count=0;memset(rece_buf,'\0',UART_BUFF);numchar = (unsigned char)send_buf[2];sum = (int)numchar;// cout << ToHexString((unsigned char*)send_buf,n) << "***" << endl;}}if(flag){cout << ToHexString((unsigned char*)send_buf,n) << "***" << endl;for(int i=count;i<(count+n);i++){rece_buf[i] = send_buf[i-count];}count += n;//cout << ToHexString((unsigned char*)rece_buf,count) << endl;if(sum == (count-2)){cout << ToHexString((unsigned char*)rece_buf,sum+2) << endl;len=send(client_sockfd, rece_buf, count, 0);count = 0;}else if(sum < (count-2)){flag = 0;count = 0;}}}//else//usleep(5000);}return;
}int main()
{struct sockaddr_in remote_addr;char recv_buf[UART_BUFF];char send_buf[UART_BUFF];memset(&remote_addr, 0, sizeof(remote_addr));remote_addr.sin_family=AF_INET;remote_addr.sin_addr.s_addr=inet_addr("192.168.192.100");remote_addr.sin_port=htons(6666);//listen uartfd1 = open( "/dev/ttyS9", O_RDWR);if (fd1 == -1) {printf("open error!\n");}int nset = set_opt(fd1, 115200, 8, 'N', 1);if (nset == -1) {printf("set error!\n");}//IPv4 tcpif((client_sockfd=socket(PF_INET, SOCK_STREAM, 0))<0){cout<<"socket error";return 1;}if(connect(client_sockfd, (struct sockaddr*)&remote_addr, sizeof(struct sockaddr))<0){cout<<"connect error";return 1;} cout<<"connected to server"<<endl;std::thread uart(uart_read);while(1){usleep(100);}uart.join();close(client_sockfd);close(fd1);return 0;
}