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 回答