檔案傳送與效能分析(2)-基本的檔案傳送

因為有太多人不知道怎麼寫檔案傳送..(汗)
在這邊弄一個簡單的範例給各位，不過請別忘了將以下程式修改達到以下目的
------------------------------------------------

1. 將作業一改成用 select, 不需使用http, 只需傳一個大檔, 譬如 1G 的 zip 檔
2. 設計 client, 不需顯示UI, 只需存檔, 只需用 zip 驗證正確性
3. 請不要用 sendfile 來處理, 這是練習
4. 當1個client 連線, 仍夠正確傳完, 分析您的處理過程
5. 當1個client 連線,  但是您的網路頻寬有限, 仍夠正確傳完.
6. 當多個(2個以上)client 連線, 仍夠正確傳完
7. 當接收端 (client), 程式異常終止, 製造SIGPIPE, 參考 man 7 siganl, 與範例
8. 處理 SIGPIPE
9. Server 與  Client 網路速度不匹配, 或bandwidth 不夠, 發生 send 這 system call, block 現象
10. 同時使用 Wireshark 分析TCP 現象
11. 不穩定網路續傳, 這需處理續傳問題, 如同http partial get 的問題
12. 連續傳送過程中, 設計 recv 或 read 回傳值 與期望大小不同的現象
13. 使用pthread 處理多工傳送
14. man 7 socket , SO_SNDTIMEO, 處理  send blocking 問題
15. 不要太相信 SO_LINGER 是好方法

16. pthread如果傳入參數時，會有什麼bug!
17. thread 中的結果如何用一般 stdout/stdin 或透過 unix domain socket  取代 (請參考http/cgi 程式), 這是下份作業

------------------------------------------------
以下附上"簡單"的檔案傳送接收範例，這只是參考的範例架構並不是本次實驗的目的...!!如果你拿這份來交作業...那我真不知道要說什麼了...
請不要直接複製下面程式碼，因為裡面會包含亂碼唷~ 請盡量自己打

common.h

#include <stdio.h>  
#include <stdlib.h>  
#include <unistd.h>  
#include <string.h>  
#include <sys/types.h>  
#include <sys/stat.h>  
#include <sys/socket.h>  
#include <netinet/in.h>  
  
#define PORT 6000  
#define LISTENQ 20  
#define BUFFSIZE 4096  
#define FILE_NAME_MAX_SIZE 512 

fileclient.c

#include "common.h"  
  
int main(int argc, char **argv[])  
{  
    int clientfd;  
  
    if(argc!=2)  
    {  
        fprintf(stderr,"Usage:./fileclient <IP_Address>\n");  
        exit(1);  
    }  
    struct sockaddr_in clientaddr;  
    bzero(&clientaddr,sizeof(clientaddr));    
  
    clientaddr.sin_family=AF_INET;  
    clientaddr.sin_addr.s_addr=htons(INADDR_ANY);  
    clientaddr.sin_port=htons(0);  
      
    clientfd=socket(AF_INET,SOCK_STREAM,0);  
      
    if(clientfd<0)     
    {  
        perror("socket");  
        exit(1);  
    }  
  
    if(bind(clientfd,(struct sockaddr*)&clientaddr,sizeof(clientaddr))<0)  
    {  
        perror("bind");  
        exit(1);  
    }  
  
    struct sockaddr_in svraddr;  
    bzero(&svraddr,sizeof(svraddr));  
    if(inet_aton(argv[1],&svraddr.sin_addr)==0)  
    {  
        perror("inet_aton");  
        exit(1);  
    }  
    svraddr.sin_family=AF_INET;  
    svraddr.sin_port=htons(PORT);  
      
    socklen_t svraddrlen=sizeof(svraddr);  
    if(connect(clientfd,(struct sockaddr*)&svraddr,svraddrlen)<0)      
    {  
        perror("connect");  
        exit(1);  
    }  
      
    //recv file imformation  
    char buff[BUFFSIZE];  
    char filename[FILE_NAME_MAX_SIZE];  
    int count;  
    bzero(buff,BUFFSIZE);  
  
    count=recv(clientfd,buff,BUFFSIZE,0);  
    if(count<0)  
    {  
        perror("recv");  
        exit(1);  
    }  
    strncpy(filename,buff,strlen(buff)>FILE_NAME_MAX_SIZE?FILE_NAME_MAX_SIZE:strlen(buff));  
  
    printf("Preparing recv file : %s from %s \n",filename,argv[1]);   
  
    //recv file  
    FILE *fd=fopen(filename,"wb+");  
    if(NULL==fd)  
    {  
        perror("open");  
        exit(1);  
    }  
    bzero(buff,BUFFSIZE);  
  
    int length=0;  
    while(length=recv(clientfd,buff,BUFFSIZE,0))  
    {  
        if(length<0)  
        {  
            perror("recv");  
            exit(1);  
        }  
        int writelen=fwrite(buff,sizeof(char),length,fd);  
        if(writelen<length)  
        {  
            perror("write");  
            exit(1);  
        }  
        bzero(buff,BUFFSIZE);  
    }  
    printf("Receieved file:%s from %s finished!\n",filename,argv[1]);  
    fclose(fd);  
    close(clientfd);  
    return 0;  
}  

fileserver.c

#include "common.h"  
  
int main(int argc, char **argv[])  
{  
    //Input the file name  
    char filename[FILE_NAME_MAX_SIZE];  
    bzero(filename,FILE_NAME_MAX_SIZE);  
    printf("Please input the file name you wana to send:");  
    scanf("%s",&filename);  
    getchar();  
  
    //Create socket  
    int sockfd,connfd;  
    struct sockaddr_in svraddr,clientaddr;  
    bzero(&svraddr,sizeof(svraddr));  
      
    svraddr.sin_family=AF_INET;  
    svraddr.sin_addr.s_addr=htonl(INADDR_ANY);  
    svraddr.sin_port=htons(PORT);  
  
    sockfd=socket(AF_INET,SOCK_STREAM,0);  
    if(sockfd<0)  
    {  
        perror("socket");  
        exit(1);  
    }  
  
    //bind    
    if(bind(sockfd,(struct sockaddr*)&svraddr,sizeof(svraddr))<0)  
    {  
        perror("bind");  
        exit(1);  
    }  
  
    //listen  
    if(listen(sockfd,LISTENQ)<0)  
    {  
        perror("listen");  
        exit(1);  
    }  
  
    while(1)  
    {  
        socklen_t length=sizeof(clientaddr);  
  
        //accept  
        connfd=accept(sockfd,(struct sockaddr*)&clientaddr,&length);  
        if(connfd<0)  
        {  
            perror("connect");  
            exit(1);  
        }  
      
        //send file imformation  
        char buff[BUFFSIZE];  
        int count;  
        bzero(buff,BUFFSIZE);  
        strncpy(buff,filename,strlen(filename)>FILE_NAME_MAX_SIZE?FILE_NAME_MAX_SIZE:strlen(filename));  
        count=send(connfd,buff,BUFFSIZE,0);  
        if(count<0)  
        {  
            perror("Send file information");  
            exit(1);  
        }  
          
        //read file   
        FILE *fd=fopen(filename,"rb");  
        if(fd==NULL)  
        {  
            printf("File :%s not found!\n",filename);  
        }  
        else   
        {  
            bzero(buff,BUFFSIZE);  
            int file_block_length=0;  
            while((file_block_length=fread(buff,sizeof(char),BUFFSIZE,fd))>0)  
            {  
                printf("file_block_length:%d\n",file_block_length);  
                if(send(connfd,buff,file_block_length,0)<0)  
                {  
                    perror("Send");  
                    exit(1);  
                }  
                bzero(buff,BUFFSIZE);     
            }  
            fclose(fd);  
            printf("Transfer file finished !\n");  
        }  
        close(connfd);  
    }  
    close(sockfd);  
    return 0;  
}  

Makefile

SOURCE=$(wildcard *.c)  
PROGS=$(patsubst %.c,%,$(SOURCE))  
temp = $(wildcard *~)  
all:$(PROGS)  
  
clean:  
        rm $(temp) $(PROGS)  

相關文章
檔案傳送與效能分析(1)-實驗過程與結果
檔案傳送與效能分析(2)-基本的檔案傳送
檔案傳送與效能分析(3)-斷線分析
檔案傳送與效能分析(4)-程式下載