1

これはclient.cのスニペットです:

size_t fsize;
int total_bytes_read = 0, ret_val;

hp = gethostbyname(argv[1]);
DescrittoreClient = socket(AF_INET, SOCK_STREAM, 0);
    connect(DescrittoreClient, (struct sockaddr *) &serv_addr, sizeof(serv_addr));
strcpy(Buffer, filename);
send(DescrittoreClient, Buffer, strlen(Buffer), 0);
ret_val = read(DescrittoreClient, &fsize, sizeof(fsize));
if(ret_val == -1){
    printf("Errore durante ricezione grandezza file\n");
    close(DescrittoreClient);
    exit(1);
}

fd = open(filename, O_CREAT | O_WRONLY,0644);
if (fd  < 0) {
    perror("open");
    exit(1);
}

while(total_bytes_read < fsize){
    while ((nread = read(DescrittoreClient, Buffer, sizeof(Buffer))) > 0){
        write(fd, Buffer, nread);
        total_bytes_read += nread;
    }
}
printf("File ricevuto\n");

そして、これはserver.cのスニペットです:

int DescrittoreServer, DescrittoreClient, LunghezzaClient;
int NumPorta = atoi(argv[1]);
char Buffer[1024] = {};
int rc, fd;
off_t offset = 0;
struct stat stat_buf;
char filename[1024] = {};
int fsize[10240] = {};

DescrittoreServer = socket(AF_INET, SOCK_STREAM, 0);

if(bind(DescrittoreServer, (struct sockaddr *) &serv_addr, sizeof(serv_addr)) < 0){
    perror("Errore di bind\n");
    close(DescrittoreServer);
    exit(1);
}
listen(DescrittoreServer, 5);
LunghezzaClient = sizeof(cli_addr);
while(1){
    DescrittoreClient = accept(DescrittoreServer, (struct sockaddr *) &cli_addr, &LunghezzaClient);

rc = recv(DescrittoreClient, filename, sizeof(filename), 0);

fprintf(stderr, "Ricevuta richiesta di inviare il file: '%s'\n", filename);

/* open the file to be sent */
fd = open(filename, O_RDONLY);

/* get the size of the file to be sent */
fstat(fd, &stat_buf);
*fsize = stat_buf.st_size;
send(DescrittoreClient, fsize, sizeof(fsize), 0);

/* copy file using sendfile */
offset = 0;
rc = sendfile(DescrittoreClient, fd, &offset, stat_buf.st_size);
if (rc != stat_buf.st_size) {
    fprintf(stderr, "Trasferimento incompleto: %d di %d bytes\n", rc, (int)stat_buf.st_size);
    exit(1);
}   

    close(DescrittoreClient);
    close(fd);
}

このコードは何をしますか:
1) クライアントがファイルの名前を送信する
2) サーバーがファイルの長さ (バイト単位) を送信する
3) クライアントがファイルの長さを受信する
4) サーバーがファイルを送信する
5) クライアントがファイルを受信
する問題は、ファイルが完全に受信されず、その一部のみがクライアントによって書き込まれることです (たとえば、2143 バイトのファイルがサーバーによって送信され、95 バイトのみがクライアントによって受信されます)。 !
PS: コードが読みやすくなるように、一部のエラー処理が削除されました。

4

2 に答える 2

2

ループで recv() を呼び出し、その戻り値を合計する必要があります。

while (read_bytes < filesize) {
    read_bytes += recv(socket, buffer + read_bytes, filesize-read_bytes, flags)
}

もちろん、エラー処理も追加する必要があります。つまり、0 バイトを読み取って接続が閉じられたかどうかを確認します。

于 2012-06-25T20:34:07.703 に答える
0

問題は、クライアントではchar nread=0なく宣言int nread=0したため、読み取ることができる最大値charは 127 です... char を int に変更すると、問題が解決しました!

于 2012-06-25T20:54:06.407 に答える