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

5947 ワード

オリジナル作品は、転載時に必ずハイパーリンク形式で文章の元の出所を明記してください.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転送ファイル

Struts 2の変更を解決するには、ページにフィールドが表示されない空振り方法

SSHフレームワークのStruts(1)――Strutsの運行フロー