Nic*_*k S 2 c sockets tcp tcp-ip sendfile
我写程序,它工作正常,但是我想用sendfile()重写它,现在我陷入了循环。
服务器端:
客户端:
PS在以前的程序版本中,我花了一些时间,但这取决于我为什么使用printf多少?例如,我添加一行,并保留printf程序,将其删除,即可正常工作。
UPDT:重写代码客户端/服务器
客户
/* Received file name */
int rc_byte = 0;
rc_byte = recv(fd, rx_tx_file->out_name, sizeof(rx_tx_file->out_name),0);
if (rc_byte < 0){
perror("Failed to receive file name: ");
exit(-1);
} else
printf("Recv out name %s\n", rx_tx_file->out_name);
//printf("file name rc %s\n", rx_tx_file->out_name);
trimm_path_name(rx_tx_file);
/* Received md5sum */
rc_byte = recv(fd, rx_tx_file->md5sum, sizeof(rx_tx_file->md5sum), 0);
if (rc_byte < 0) {
perror("Failed to receive check sum: ");
exit(-1);
} else
printf("recv md5s %s\n", rx_tx_file->md5sum);
/* Received file size */
rc_byte = recv(fd, &size, sizeof(size), 0);
if(rc_byte < 0) {
perror("Recevid size of file: ");
exit(-1);
}
printf("%d recv size\n", size);
to_read = size;
if (stat(dir, &st) == -1){
mkdir(dir, 0777);
}
Run Code Online (Sandbox Code Playgroud)
send_data :(将func添加到服务器)
void send_data(int client_fd, m_file *rx_tx_file, int option, int size) {
int send_byte = 0;
int total_send = 0;
if (option == SEND_NAME) {
while (total_send < strlen(rx_tx_file->in_name)) {
send_byte = send(client_fd, rx_tx_file->in_name, sizeof(rx_tx_file->in_name),0);
if(send_byte == -1) {
perror("Failed to send file name to client: ");
exit(SEND_TO_CLIENT_ERROR);
}
total_send += send_byte;
}
}
else if (option == SEND_MD5) {
total_send = 0;
send_byte = 0;
while (total_send < strlen(rx_tx_file->md5sum)) {
send_byte = send(client_fd, rx_tx_file->md5sum, sizeof(rx_tx_file->md5sum),0);
if(send_byte == -1){
perror("Failed to send file md5sum to client: ");
exit(-1);
}
total_send += send_byte;
}
}
else if (option == SEND_SIZE) {
send_byte = send(client_fd, &size, sizeof(size),0);
if (send_byte == -1) {
perror("Failed to send size: ");
}
}
}
Run Code Online (Sandbox Code Playgroud)
服务器:
client_fd = accept(server_fd, (struct sockaddr*) &client_addr, &length)
/*send name of file*/
send_data(client_fd, rx_tx_file, SEND_NAME, 0);
/*send md5 sum*/
take_check_sum(rx_tx_file,rx_tx_file->file_in, 0);
send_data(client_fd, rx_tx_file, SEND_MD5, 0);
/*send size of file*/
size = stats.st_size;
send_data(client_fd, rx_tx_file, SEND_SIZE, size);
remain_data = stats.st_size;
printf("File [%s] ready to send\ncheck sum [%s]\n", rx_tx_file->in_name,rx_tx_file->md5sum);
while (((send_byte = sendfile(client_fd, file_fd, &offset, size)) > 0) && (remain_data > 0))
{
remain_data -= send_byte;
printf("remain %d", remain_data);
}
printf("Succesfully");
Run Code Online (Sandbox Code Playgroud)
由于我使用一个客户端并传递应通过命令行args在服务器端发送的文件,因此我不需要等待(client_fd = accpet),而只需使用一个连接并关闭服务器即可。现在它的工作很好。但是有一个问题是开放的,我应该如何在循环中重写客户端以接收数据。我不知道我应该恢复哪个尺寸,因此我无法在while循环中写入正确的条件。THX全部为您提供帮助。
TCP是一个流。它没有消息边界。因此,您的代码将无法正常工作。
首先,发送文件名:
send(client_fd, rx_tx_file->in_name, strlen(rx_tx_file->in_name)+1,0)
Run Code Online (Sandbox Code Playgroud)
然后您立即发送md5总和,然后发送文件大小:
send(client_fd, rx_tx_file->md5sum, strlen(rx_tx_file->md5sum)+1, 0)
send(client_fd, &size, sizeof(int),0)
Run Code Online (Sandbox Code Playgroud)
由于前两个字符串没有固定的字节数,因此当您尝试从服务器读取文件大小或md5 sum时,很可能还会读取文件大小,甚至可能读取某些文件数据。
首先,停止尝试将尽可能多的发送和读取代码放入ifand while语句的条件子句中。
到底是什么
if (send(client_fd, rx_tx_file->md5sum, strlen(rx_tx_file->md5sum)+1, 0) == -1) {
perror("Failed to send file md5sum to client: ");
exit(-1);
}
Run Code Online (Sandbox Code Playgroud)
带你过去
ssize_t bytes_sent = send(client_fd, rx_tx_file->md5sum, strlen(rx_tx_file->md5sum)+1, 0);
if ( bytes_sent < 0 )
{
perror("Failed to send file md5sum to client: ");
exit(-1);
}
Run Code Online (Sandbox Code Playgroud)
将所有这些代码放入if子句中不会使您一无所获。如果strlen(rx_tx_file->md5sum)+1是87,send()呼叫返回15怎么办?这是您的代码无法处理的可能的返回值,因为它将所有内容填充到该if子句中。
ssize_t bytes_sent = send(client_fd, rx_tx_file->md5sum, strlen(rx_tx_file->md5sum)+1, 0);
if ( bytes_sent < 0 )
{
perror("Failed to send file md5sum to client: ");
exit(-1);
}
else if ( bytes_sent < strlen(rx_tx_file->md5sum)+1 )
{
// partial send...
}
Run Code Online (Sandbox Code Playgroud)
实际上,最好将其编码为循环。
您没有发布接收代码,但是如果使用相同的样式,则您不仅不会获得任何收益,而且将所有内容放入if子句中也将无法进行任何体面的错误检测或纠正。
如果您的文件名recv代码类似于
char filename[1024];
if (recv(fd, &filename, sizeof(filename), 0) < 0) {
perror("Failed to read file name: ");
exit(-1);
}
Run Code Online (Sandbox Code Playgroud)
您无法说出您刚刚收到的信息。您刚刚收到多少字节?您可能已经收到文件名。您可能只收到了一部分文件名。您可能已经收到文件名,md5和以及一些文件内容本身。
您不知道收到了什么,使用您的代码也无法分辨。如果将文件名清零并且md5接收缓冲区仅recv比缓冲区的大小小一个字节,则至少应避免未定义的行为。但是,如果您不将缓冲区归零,或者读取了缓冲区的最后一个字节,则文件名或md5总和也可以不使用以nul终止的字符串结束。然后,当您尝试将其视为以nul结尾的字符串时,会得到未定义的行为。
而且,如果确实recv在尝试读取文件数据之前在调用中获得了额外的字节,这说明了为什么代码卡住了-它在进入循环之前已经读取了一些文件内容,因此循环将永远看不到所有内容-其中一些不见了。