socket tcp粘包处理

在Linux中，TCP粘包是指发送方在发送一段数据时，由于网络缓冲区大小限制或者网络拥塞等原因，导致接收方一次性接收到了多个数据包，即多个TCP数据包被合并成一个数据包接收，这就是TCP粘包现象。 处理TCP粘包问题的方法有很多，其中比较常用的方法是在数据包中添加特定的分隔符或者长度字段，以便接收方正确地处理数据包。以下是一段简单的示例代码，用于处理TCP粘包问题： ```c #include <stdio.h> #include <stdlib.h> #include <string.h> #include <unistd.h> #include <sys/socket.h> #include <netinet/in.h> #define MAXLINE 1024 int main(int argc, char **argv) { int sockfd; struct sockaddr_in servaddr; char sendline[MAXLINE], recvline[MAXLINE]; int n; if (argc != 2) { printf("usage: %s <IP address>\n", argv[0]); exit(1); } if ((sockfd = socket(AF_INET, SOCK_STREAM, 0)) < 0) { printf("socket error\n"); exit(1); } bzero(&servaddr, sizeof(servaddr)); servaddr.sin_family = AF_INET; servaddr.sin_port = htons(13); if (inet_pton(AF_INET, argv[1], &servaddr.sin_addr) <= 0) { printf("inet_pton error for %s\n", argv[1]); exit(1); } if (connect(sockfd, (struct sockaddr *)&servaddr, sizeof(servaddr)) < 0) { printf("connect error\n"); exit(1); } while (fgets(sendline, MAXLINE, stdin) != NULL) { send(sockfd, sendline, strlen(sendline), 0); while ((n = recv(sockfd, recvline, MAXLINE, 0)) > 0) { recvline[n] = 0; if (fputs(recvline, stdout) == EOF) { printf("fputs error\n"); exit(1); } if (strstr(recvline, "\r\n") != NULL) { break; } } if (n < 0) { printf("recv error\n"); exit(1); } } return 0; } ``` 在这个示例代码中，我们使用了一个while循环来接收数据，每次读取一定长度的数据，并判断是否包含特定的分隔符（这里使用的是"\r\n"），如果包含，则将接收到的数据输出到标准输出，并且退出循环，否则继续读取数据。这样就可以保证每次读取的数据都是一个完整的数据包，从而避免TCP粘包问题。

在Flutter中，可以使用dart:io库中的Socket类来进行TCP通信，以下是一段简单的TCP粘包处理代码示例： ``` import 'dart:io'; // 接收数据缓冲区 List<int> buffer = []; // 连接服务器 Socket.connect('127.0.0.1', 8888).then((socket) { // 监听数据 socket.listen((data) { // 将接收到的数据添加到缓冲区 buffer.addAll(data); // 处理接收到的数据 handleData(); }); }); // 处理接收到的数据 void handleData() { // 判断缓冲区中是否有足够的数据构成一个完整的数据包 if (buffer.length >= packetLength) { // 从缓冲区中取出一个完整的数据包 List<int> packet = buffer.sublist(0, packetLength); // 对数据包进行处理 // 这里可以根据协议自行解析数据包 // 从缓冲区中删除已处理的数据包 buffer.removeRange(0, packetLength); // 继续处理剩余的数据 handleData(); } } ``` 在接收数据时，可以设置一个List<int>类型的缓冲区来存储接收到的数据，然后对缓冲区中的数据进行处理。如果缓冲区中的数据不足以构成一个完整的数据包，可以继续等待后续数据的到来，直到缓冲区中的数据足够构成一个完整的数据包。如果缓冲区中的数据超过了一个完整数据包的长度，可以将多余的数据存储在缓冲区中，以备后续处理。在处理完一个完整的数据包后，需要从缓冲区中删除已处理的数据包，然后继续处理剩余的数据。