通过网络中的套接字进行文件传输时,该程序中的文件传输错误是什么

What is the file transfer error in this program while doing a file transfer via Socket in the network?

本文关键字:文件 是什么 程序 传输错误 网络 套接字 传输      更新时间:2023-10-16

我写了一个C++演示示例。它将文件从服务器传输到客户端。当我在本地主机中运行此程序时,它工作正常。但是,当我通过网络运行此程序时,文件传输不正确。收到的图像大小大于发送的图像大小。另外,为什么在本地主机上同样有效?我也尝试更改端口号。

这是程序 -

服务器

/** man 2 socket **/
#include <sys/types.h>
#include <sys/socket.h>
#include <stdio.h>
#include <string.h>
#include <stdlib.h>
#include <errno.h>
#include <netinet/in.h>
#include <arpa/inet.h>
#include <unistd.h>
#include <iostream>
using namespace std;
int main(int argc, char *argv[])
{
 char msg[] = "Shreyas..first socket prog";
 int sock , sock_active;
 struct sockaddr_in server, client;
 int sent,ret;
 unsigned int len;
 char buffer[1024];

   FILE *fp;
   if ( (sock = socket(AF_INET,SOCK_STREAM,0))  == -1 )
   //if ( (sock = socket(AF_INET,SOCK_DGRAM ,0))  == -1 )
   {
    perror("Sock:");
   }
  server.sin_family = AF_INET;
  server.sin_port = htons(15000);
  //server.sin_addr.s_addr = INADDR_ANY;
  inet_aton("136.170.195.17",  &(server.sin_addr));
  bzero(&server.sin_zero, 8);
  len = sizeof(struct sockaddr_in);
  if( ret = (bind( sock, (struct sockaddr *)&server, len)) == -1 )
  {
     perror("bind :");
  }
  ret = listen(sock, 0);

 while(1)
  {
 if( (sock_active = accept(sock, (struct sockaddr *)&client, &len)) == -1 )
    {
      perror("Problem in active socket:");
    }

  fp = fopen("./Tiger.JPG","rb");
  if( fp == NULL )
  {
     cout<<"Error open file";
     return -1;
  }

  memset(buffer, 1024,0);
  int packets = 0;
  int count;
 //while ( fgets(buffer,1024,fp ) != NULL )
  while( ! feof(fp) )
    {
       packets++;
      cout<<"Client IP address is "<<inet_ntoa(client.sin_addr)<<endl;
      cout<<"Client Port address is "<<ntohs(client.sin_port)<<endl;
      /** Fread is reliable when using to find out the EOF , in feof(fp **/
       count = fread(buffer,1,sizeof(buffer),fp);
      /** fgets doesn't move the FP correctly */
      //fgets(buffer,sizeof(buffer),fp);
      cout<<"Read number of bytes ="<<count;
      sent = send(sock_active, buffer, sizeof(buffer),0);
      cout<<"The number of bytes sent ="<<sent<<"packet number = "<<packets<<endl;
      memset(buffer, 1024,0);
     }
    cout<<"CLose current socket"<<endl;
    close(sock_active);
    fclose(fp);
}
  cout<<"CLosing socket now" <<endl;
  close(sock);
  return 0;
}

客户端套接字程序 -

/** man 2 socket **/
#include <sys/types.h>
#include <sys/socket.h>
#include <stdio.h>
#include <string.h>
#include <stdlib.h>
#include <errno.h>
#include <netinet/in.h>
#include <arpa/inet.h>
#include <iostream>
#include <unistd.h>

using namespace std;
int main(int argc, char *argv[])
{
   struct sockaddr_in server;
   int ret; 
   int sock;
   int read_val = 1;
   unsigned int len;
   if ( (sock = socket(AF_INET,SOCK_STREAM,0))  == -1 )
   {
    perror("Sock:");
   }
   if( argc != 2 )
     {
       cout<<"Pass the Server IP "<<endl;
       exit(EXIT_FAILURE);
     }
  server.sin_family = AF_INET;
  server.sin_port = htons(15000);
  inet_aton(argv[1],  &(server.sin_addr));
  bzero(&server.sin_zero, 8);
  len = sizeof(server);

  if ( (ret = connect(sock, (struct sockaddr *)&server,sizeof(server))) == -1)
  {
     perror("Connect failed:"); 
     exit(-1); 
  }
  char msg[1024];
  memset(msg,0,1024);
  FILE *fp_w;
  fp_w = fopen("./try.JPG","wb");
  while( read_val)
   {
     read_val = recv(sock,(char *)msg,sizeof(msg),0);
     fwrite(msg,1,sizeof(msg),fp_w);
   }
     cout<<"Read is complete"<<endl;
     fclose(fp_w);
     close(sock);
     return 0;
}

也许你应该在客户端中修改这个代码块。

while( read_val)
{
  read_val = recv(sock,(char *)msg,sizeof(msg),0);
  fwrite(msg,1,sizeof(msg),fp_w);
}

recv函数不会始终接收您想要接收的字节数。您必须使用 recv 的返回值来了解实际读取的字节数,并使用该计数写入文件。

我会把这个块写成,

while( read_val)
{
  read_val = recv(sock,(char *)msg,sizeof(msg),0);
  if ( read_val > 0)
  {
     fwrite(msg,1,read_val,fp_w); // I am using `read_val` while writing.
  }
}

在使用文件/套接字 io API 时,假设它读取/写入您要求的确切字节数是不好的。

你犯了一个常见的错误,假设 recv()、fread() 等填充缓冲区。他们不需要这样做。它们返回实际接收的字节数的计数。发送时,您必须使用该计数作为长度参数,

您必须发送读取的实际字节数:

count = fread(buffer,1,sizeof(buffer),fp);
cout<<"Read number of bytes ="<<count;
if ( count > 0)
sent = send(sock_active, buffer, count,0);

读取时客户端也是如此:

while( read_val)
{
  read_val = recv(sock,(char *)msg,sizeof(msg),0);
  if ( read_val > 0) {
      fwrite(msg,1,read_val,fp_w)
  } else if ( red_val == -1) {
      // an error has occured
      break;
  } else {
      // peer has closed the connection
      break;
  {
}