1

我写了一个简单的tcp/ip连接client-server。c++

这是处理连接的服务器部分

int sockfd, newsockfd;
socklen_t clilen;
struct sockaddr_in serv_addr, cli_addr;
int n = 0;

sockfd = socket(AF_INET,SOCK_STREAM,0);
if(sockfd < 0){
    cout << "Error opening socket" << endl;
    exit(1);
}

bzero((char*)&serv_addr, sizeof(serv_addr));

serv_addr.sin_family = AF_INET;
serv_addr.sin_addr.s_addr = INADDR_ANY;
serv_addr.sin_port = htons(portno);

if(bind(sockfd,(struct sockaddr *) &serv_addr,sizeof(serv_addr))<0){
    cout << "Error binding" << endl;
    exit(1);
}

listen(sockfd,1);
clilen = sizeof(cli_addr);

newsockfd = accept(sockfd,(struct  sockaddr *)&cli_addr, &clilen );

if(newsockfd < 0){
    cout << "Error accepting" << endl;
    exit(1);
}

bzero(bytes,size_tot);
uint64_t total_bytes_read = 0;
uint64_t total_bytes_to_read = size_tot;
while(total_bytes_read < total_bytes_to_read){
    int bytes_read = read(newsockfd,bytes + total_bytes_read,total_bytes_to_read - total_bytes_read);
    if(bytes_read == -1){
        cout << "error reading "<< endl;
        n = -1;
        break;
    }
    total_bytes_read += bytes_read;
}

但如果我知道要读取的字节总数，这将有效。如果要读取的数据总量未知怎么办？我如何修改这段代码？

4

2 回答 2

3

你问如何修复你的低级接收代码。这很简单——只需调用read一次，不要使用while循环。read只要可以读取至少一个字节的数据，对的调用就会返回。对于要读取的字节数，只需传入缓冲区的大小（或者如果先前调用中已经有一些剩余空间，则传入其中的空间）。

您还需要高级协议代码，就像您知道字节数一样。该代码可能需要有所不同。如果您获得的字节块包含停止指示，则处理所有字节直到停止指示，并将多余的字节保留在缓冲区中以备下次使用。如果没有，只需read再次调用并获取更多字节。

您的协议处理代码应如下所示：

  1. 调用read并将获得的字节数添加到缓冲区中。（在这里处理错误或正常关闭。）
  2. 如果缓冲区中的数据不包括停止指示，则转到步骤 1。
  3. 处理所有字节直到停止指示。
  4. 从缓冲区中删除已处理的字节，留下任何未处理的字节。
  5. 转到第 2 步。

此外，如果对方关闭连接，您在问题中提供的代码将永远旋转。在这种情况下，read将返回零，您将永远无法从连接中读取更多数据。read如果返回零，您应该跳出循环。

于 2015-12-30T21:02:40.837 回答
2

首先，摆脱所有bzero呼叫。我不知道为什么这会一直蔓延到好人的代码中。有零，nada，nicht需要这个。

其次，您需要事先以某种方式传达传输的大小 - 例如，HTTP 1.1 在标头中提供了此信息 - 或者只是声明在所有数据传输后关闭连接 - 这将是 HTTP 1.0 模型。

于 2015-12-30T21:04:37.313 回答