Linuxネットワークプログラミングの使用UDP転送ファイル


オリジナル作品は、転載時に必ずハイパーリンク形式で文章の元の出所を明記してください.http://blog.csdn.net/gqb666/article/details/8970207,著者:gqb 666
         前編の博文LinuxネットワークプログラミングのTCPを使用してファイルを転送します.最近Linuxネットワークを書くdemoでは、UDPで簡単なファイル転送プログラムを実現し、NICデバイスやTCP/IPプロトコルスタック、ネットワーク環境テストで使用するのに適しています.もちろん、ここでは、一般的にネットワークを介してファイルを転送する場合、UDPプロトコルは選択されません.UPDは信頼性の低い転送を提供するため、ファイル転送中にパケット損失現象が発生し、ファイル転送エラーが発生します.ここでUDP転送ファイルを実現する目的は、NICのパケット損失率をテストし、通常のネットワークのパケット損失率と比較することで、NICおよびネットワーク環境の品質を検証することができる.本文はその雛形だけを書く.UDPプロトコルを使用してクライアント側からサーバ側にファイルを転送する機能です.
     コンパイル:
           client:gcc -o client client.c
           server:gcc -o server server.c
     実行:
           クライアント側:./client<ポート番号><アップロードファイル名>
           server側:./server<ポート番号><ファイル名として保存>
ここで、server側が先に実行され、client側とserver側のポート番号が一致し、既知のポートと衝突できない必要があります(例えば8888でよい).
コードを貼り付けます.
serverエンドコード:server.c
#include <stdio.h>
#include <string.h>
#include <stdlib.h>
#include <string.h>
#include <unistd.h>
#include <sys/types.h>
#include <sys/socket.h>
#include <netinet/in.h>
#include <arpa/inet.h>

#define    FINISH_FLAG    "FILE_TRANSPORT_FINISH"
#define    MAXLINE        1024 

void usage(char *command)
{
    printf("usage :%s portnum filename
", command); exit(0); } int main(int argc,char **argv) { struct sockaddr_in serv_addr; struct sockaddr_in clie_addr; char buf[MAXLINE]; int sock_id; int recv_len; int clie_addr_len; FILE *fp; if (argc != 3) { usage(argv[0]); } /* Create the the file commented by guoqingbo*/ if ((fp = fopen(argv[2], "w")) == NULL) { perror("Creat file failed"); exit(0); } if ((sock_id = socket(AF_INET,SOCK_DGRAM,0)) < 0) { perror("Create socket failed
"); exit(0); } /*fill the server sockaddr_in struct commented by guoqingbo*/ memset(&serv_addr,0,sizeof(serv_addr)); serv_addr.sin_family = AF_INET; serv_addr.sin_port = htons(atoi(argv[1])); serv_addr.sin_addr.s_addr = htonl(INADDR_ANY); if (bind(sock_id,(struct sockaddr *)&serv_addr,sizeof(serv_addr)) < 0 ) { perror("Bind socket faild
"); exit(0); } /* server part commented by guoqingbo*/ clie_addr_len = sizeof(clie_addr); bzero(buf, MAXLINE); while (recv_len = recvfrom(sock_id, buf, MAXLINE, 0,(struct sockaddr *)&clie_addr, &clie_addr_len)) { if(recv_len < 0) { printf("Recieve data from client failed!
"); break; } printf("#"); if ( strstr(buf, FINISH_FLAG) != NULL ) { printf("
Finish receiver finish_flag
"); break; } int write_length = fwrite(buf, sizeof(char), recv_len, fp); if (write_length < recv_len) { printf("File write failed
"); break; } bzero(buf, MAXLINE); } printf("Finish recieve
"); fclose(fp); close(sock_id); return 0; }
clientエンドコード:client.c
#include <stdio.h>
#include <string.h>
#include <stdlib.h>
#include <string.h>
#include <unistd.h>
#include <fcntl.h>
#include <sys/types.h>
#include <sys/socket.h>
#include <netinet/in.h>
#include <arpa/inet.h>

#define    FINISH_FLAG    "FILE_TRANSPORT_FINISH"
#define    MAXLINE        1024

void usage(char *command)
{
    printf("usage :%s ipaddr portnum filename
", command); exit(0); } int main(int argc,char **argv) { FILE *fp; struct sockaddr_in serv_addr; char buf[MAXLINE]; int sock_id; int read_len; int send_len; int serv_addr_len; int i_ret; int i; if (argc != 4) { usage(argv[0]); } /* open the file to be transported commanted by guoqingbo*/ if ((fp = fopen(argv[3],"r")) == NULL) { perror("Open file failed
"); exit(0); } /* create the socket commanted by guoqingbo*/ if ((sock_id = socket(AF_INET, SOCK_DGRAM, 0)) < 0) { perror("Create socket failed"); exit(0); } memset(&serv_addr,0,sizeof(serv_addr)); serv_addr.sin_family = AF_INET; serv_addr.sin_port = htons(atoi(argv[2])); inet_pton(AF_INET, argv[1], &serv_addr.sin_addr); serv_addr_len = sizeof(serv_addr); /* connect the server commanted by guoqingbo*/ i_ret = connect(sock_id, (struct sockaddr *)&serv_addr, sizeof(struct sockaddr)); if (-1 == i_ret) { perror("Connect socket failed!
"); exit(0); } /* transport the file commented by guoqingbo*/ bzero(buf, MAXLINE); while ( (read_len = fread(buf, sizeof(char), MAXLINE, fp)) > 0 ) { send_len = send(sock_id, buf, read_len, 0); if ( send_len < 0 ) { perror("Send data failed
"); exit(0); } bzero(buf, MAXLINE); } fclose(fp); /* send the end_flag commented by guoqingbo*/ bzero(buf, MAXLINE); strcpy(buf, FINISH_FLAG); buf[strlen(buf)] = '\0'; for (i = 1000; i>0; i--) { send_len = send(sock_id, buf, strlen(buf)+1, 0); if ( send_len < 0 ) { printf("Finish send the end string
"); break; } } close(sock_id); printf("Send finish
"); return 0; }

上接博文: Linuxネットワークプログラミングの使用TCP転送ファイル