linux文件傳輸

joey.xiang

最近一直在學(xué)習(xí)unix網(wǎng)絡(luò)編程，在最開始傳輸圖片的文件老是會(huì)出現(xiàn)多出些字節(jié)，后面經(jīng)過(guò)測(cè)試和參考網(wǎng)上的文章發(fā)現(xiàn)是在處理文件的讀和寫的最后沒有處理好出現(xiàn)了這些問(wèn)題�，F(xiàn)在把程序改進(jìn)了下，測(cè)試了可以傳輸其它類型的文件。下面一步就是編寫視頻傳輸?shù)某绦颉?br /> server.c

#include
#include
#include
#include
#include
#include
#define MAXSIZE 100
int main(int argc,char **argv)
{
  int server_sockfd,client_sockfd;
  int server_len,client_len;
  char ch[MAXSIZE];
  struct sockaddr_in server_address;
  struct sockaddr_in client_address;
  if (argc != 2)
   {
      printf("server:file name\n");
      exit(1);
   }
  server_sockfd = socket(AF_INET,SOCK_STREAM,0);
  if(server_sockfd
    bzero(&server_address,sizeof(struct sockaddr_in));
    server_address.sin_family = AF_INET;
    server_address.sin_addr.s_addr = htonl(INADDR_ANY);
    server_address.sin_port = htons(5000);
    server_len = sizeof(server_address);
    int opt = 1;
    setsockopt(server_sockfd,SOL_SOCKET,SO_REUSEADDR,&opt,sizeof(opt));
    if(bind(server_sockfd,(struct sockaddr *)&server_address,server_len)
     if(listen(server_sockfd,5) == -1)
       {
         printf("listen error!\n");
         exit(1);
         }
     
     client_len = sizeof(client_address);
     client_sockfd = accept(server_sockfd,(struct sockaddr *)&client_address, &client_len);
     if(client_sockfd == -1)
       {
         printf("accept error!\n");
         exit(1);
        }
  
      FILE *fd = fopen(argv[1],"rb");
      if (fd == NULL)
      {
        printf("file open error!\n");
        exit(2);
      }
       while(!feof(fd))
        {
          int len = fread(ch,1,MAXSIZE,fd);
          write(client_sockfd,ch,len);
         }
      close(client_sockfd);
      fclose(fd);
       return 0;
}

client.c

#include
#include
#include
#include
#include
#include
#include
#include
#include
#define MAXSIZE 100
int main(int argc,char **argv)
{
  int sockfd,len;
  int result,count;
  char recvs[MAXSIZE];
  struct sockaddr_in address;
  struct hostent *host;
  
  if (argc != 3)
  {
   printf("client ip filename\n");
   exit(1);
  }
  
  host = gethostbyname(argv[1]) ;
if(( sockfd = socket(AF_INET,SOCK_STREAM,0))== -1)
{
  printf("socket create error!\n");
  exit(1);
}
  
  bzero(&address,sizeof(address));
  address.sin_family = AF_INET;
  address.sin_addr = *((struct in_addr *)host->h_addr);
  address.sin_port = htons(5000);
  int opt = 1;
  setsockopt(sockfd,SOL_SOCKET,SO_REUSEADDR,&opt,sizeof(opt));
  
  len = sizeof(address);
  result = connect(sockfd,(struct sockaddr *)&address,len);
  if (result == -1)
   {
     perror("client");
     exit(1);
    }
  
  
   FILE *fd = fopen(argv[2],"wb");
   if (fd == NULL)
   {
    printf("create file error!\n");
    exit(1);
   }
   
   while(1){
   count = read(sockfd,recvs,MAXSIZE);
   if (count ==0)
    break;
   
   fwrite(recvs,1,count,fd);
  }
   
   close(sockfd);
   fclose(fd);
   return 0;
}

本文來(lái)自ChinaUnix博客，如果查看原文請(qǐng)點(diǎn)：http://blog.chinaunix.net/u1/34267/showart_1973090.html