套接字编程read()正在读取我的所有写入()

发布时间：2020-12-16 04:56:40 所属栏目：百科来源：网络整理

导读：我有一个客户端和一个服务器.我的客户端有两个read(),服务器代码有两个write().服务器在第一次write()时向客户端发送数据,客户端读取并存储到缓冲区但它不会停止读取,它会继续读取服务器的第二次write(),因为在我的客户端我将它设置为在流中读取255(根据我的

我有一个客户端和一个服务器.我的客户端有两个read(),服务器代码有两个write().服务器在第一次write()时向客户端发送数据,客户端读取并存储到缓冲区但它不会停止读取,它会继续读取服务器的第二次write(),因为在我的客户端我将它设置为在流中读取255(根据我的理解).我把255放了,因为我不知道第一个write()的数据数据有多长.我该如何解决？

客户：

n = read(sockfd,buffer,255);
if (n < 0) 
     error("ERROR reading from socket");
      printf("%sn",buffer);

 n = read(sockfd,buffer);

服务器：

n = write(newsockfd,datasize,strlen(datasize));
if (n < 0) error("ERROR writing to socket");

n = write(newsockfd,data,255);
if (n < 0) error("ERROR writing to socket");

解决方法

您正在经历的是TCP的工作原理.如果服务器在客户端调用read()之前多次调用write(),则read()可以接收先前写入的所有内容,最多可达到指定的最大缓冲区大小. TCP没有消息边界的概念,就像UDP那样.没有什么不妥.你只需要考虑它,就是这样.

如果您需要知道一条消息的结束位置和下一条消息的开始位置,那么您只需要构建消息框架.有几种不同的方法可以做到这一点.

>在发送实际数据之前发送数据长度,以便客户端知道要读取多少数据,例如：

服务器：

int datalen = ...; // # of bytes in data
int tmp = htonl(datalen);
n = write(newsockfd,(char*)&tmp,sizeof(tmp));
if (n < 0) error("ERROR writing to socket");
n = write(newsockfd,datalen);
if (n < 0) error("ERROR writing to socket");

客户：

int buflen;
n = read(sockfd,(char*)&buflen,sizeof(buflen));
if (n < 0) error("ERROR reading from socket");
buflen = ntohl(buflen);
n = read(sockfd,buflen);
if (n < 0) error("ERROR reading from socket");
else printf("%*.*sn",n,buffer);

>使用未出现在实际数据中的分隔符包装数据,然后客户端可以继续阅读并查找这些分隔符.使用对数据有意义的任何分隔符(STX / ETX,换行符,特殊保留字符等)：

服务器：

char delim = 'x2';
n = write(newsockfd,&delim,1);
if (n < 0) error("ERROR writing to socket");
n = write(newsockfd,datalen);
if (n < 0) error("ERROR writing to socket");
delim = 'x3';
n = write(newsockfd,1);
if (n < 0) error("ERROR writing to socket");

客户：

char tmp;

do
{
    n = read(sockfd,&tmp,1);
    if (n < 0) error("ERROR reading from socket");

    if (tmp != 'x2')
        continue;

    buflen = 0;

    do
    {
        n = read(sockfd,1);
        if (n < 0) error("ERROR reading from socket");

        if (tmp == 'x3')
            break;

        // TODO: if the buffer's capacity has been reached,either reallocate the buffer with a larger size,or fail the operation...
        buffer[buflen] = tmp;
        ++buflen;
    }
    while (1);

    printf("%*.*sn",buflen,buffer);
    break;
}
while (1);

（编辑：李大同）

【声明】本站内容均来自网络，其相关言论仅代表作者个人观点，不代表本站立场。若无意侵犯到您的权利，请及时与联系站长删除相关内容!