Welcome 微信登录
编程资源 图片资源库 蚂蚁家优选 PDF转换器 软件资源

软件开发、小程序制作、系统集成与运维、空间租用、硬件开发、视频监控、技术咨询与支持——联系电话：0311-88999002/88999003

首页 / 操作系统 / Linux / Linux下基于TCP的文件传输

服务器：
  1. #include <netinet/in.h>   
  2. #include <sys/types.h>   
  3. #include <sys/socket.h>   
  4. #include <stdio.h>   
  5. #include <stdlib.h>   
  6. #include <time.h>   
  7. #include <string.h>   
  8. #define SERVER_PORT 6666   
  9. #define LISTEN_QUEUE 20   
  10. #define BUFFER_SIZE 1024   
  11.   
  12. int main（int argc,char **argv）  
  13. {  
  14.   struct sockaddr_in server_addr;  
  15.   bzero（&server_addr,sizeof（server_addr））;//全部置零   
  16.   //设置地址相关的属性   
  17.   server_addr.sin_family=AF_INET;  
  18.   server_addr.sin_addr.s_addr=htons（INADDR_ANY）;  
  19.   server_addr.sin_port=htons（SERVER_PORT）;  
  20.   
  21.   
  22.   //创建套接字   
  23.   int server_socket=socket（AF_INET,SOCK_STREAM,0）;  
  24.   if（server_socket<0）   
  25.    {  
  26.      printf（"socket create error "）;  
  27.      exit（1）;  
  28.    }  
  29.   //绑定端口   
  30.   if（bind（server_socket,（struct sockaddr*）&server_addr,sizeof（server_addr）））  
  31.     {  
  32.       printf（"bind error "）;  
  33.       exit（1）;  
  34.     }  
  35.   //服务器端监听   
  36.    if（listen（server_socket,LISTEN_QUEUE））  
  37.     {  
  38.       printf（"Server listen error "）;  
  39.       exit（1）;  
  40.     }  
  41.   
  42.   //服务器端一直运行   
  43.   while（1）  
  44.    {  
  45.      pid_t pid;  
  46.      struct sockaddr_in client_addr;  
  47.      socklen_t length=sizeof（client_addr）;  
  48.      //accept返回一个新的套接字与www.linuxidc.com客户端进行通信   
  49.      int new_server_socket=accept（server_socket,（struct sockaddr*）&client_addr,&length）;  
  50. //1*begin******************************************************************************   
  51.      if（new_server_socket==-1）  
  52.       {  
  53.         printf（"accept error "）;  
  54.         continue;  
  55.       }  
  56.      else  
  57.       {  
  58.         printf（"客户端%s连接成功 ",inet_ntoa（client_addr.sin_addr））;  
  59.         pid=fork（）;  
  60.  //3*begin**运行子进程*************************************************************   
  61.         if（pid==0）  
  62.          {  
  63.            int data_len,flag=0;  
  64.            char buffer[BUFFER_SIZE];  
  65.            // 定义文件流   
  66.            FILE *stream;  
  67.            bzero（buffer,BUFFER_SIZE）;  
  68.            strcpy（buffer,"请输入要传输的文件的完整路径："）;  
  69.            strcat（buffer," "）;  
  70.              
  71.            send（new_server_socket,buffer,BUFFER_SIZE,0）;  
  72.            bzero（buffer,BUFFER_SIZE）;  
  73. //2*begin**服务器接受数据*********************************************              
  74.            if（（stream=fopen（"data","w"））==NULL）  
  75.             {  
  76.               printf（"file open error "）;  
  77.               exit（1）;  
  78.             }  
  79.            else  
  80.             {  
  81.               bzero（buffer,BUFFER_SIZE）;  
  82.             }  
  83.           // printf（"正在接收来自%s的文件.... ",inet_ntoa（client_addr.sin_addr））;   
  84.            //先将数据接受到缓冲区buffer中，再写入到新建的文件中   
  85.            while（data_len=recv（new_server_socket,buffer,BUFFER_SIZE,0））  
  86.             {  
  87.                flag++;  
  88.                if（flag==1）  
  89.                 {  
  90.                  printf（"正在接收来自%s的文件.... ",inet_ntoa（client_addr.sin_addr））;  
  91.                   
  92.                 }  
  93.               
  94.               if（data_len<0）  
  95.                {  
  96.                 printf（"接收错误 "）;  
  97.                 exit（1）;  
  98.                }  
  99.               //向文件中写入数据   
  100.               int write_len=fwrite（buffer,sizeof（char）,data_len,stream）;  
  101.               if（write_len>data_len）  
  102.                {  
  103.                  printf（"file write failed "）;  
  104.                  exit（1）;  
  105.                }  
  106.               bzero（buffer,BUFFER_SIZE）;  
  107.             }  
  108.           if（flag>0）  
  109.              printf（"%s的文件传送完毕 ",inet_ntoa（client_addr.sin_addr））;  
  110.            if（flag==0）  
  111.              printf（"%s的文件传输失败 ",inet_ntoa（client_addr.sin_addr））;  
  112. //2*end**服务器接受数据****************************************************    
  113.          // rename（"data",inet_ntoa（client_addr.sin_addr））;    
  114.           fclose（stream）;  
  115.           rename（"data",inet_ntoa（client_addr.sin_addr））;  
  116.           exit（1）;           
  117.          }  
  118. //3*end**运行子进程**********************************************************   
  119.         else  
  120.          {  
  121.            close（new_server_socket）;  
  122.          }  
  123.       }  
  124. //1*end**************************************************************************************   
  125.    close（new_server_socket）;  
  126.    }  
  127.  return 0;  
  128. }  
版权所有©石家庄振强科技有限公司2024 冀ICP备08103738号-5 网站地图