Lỗi ghi file bởi hàm fwrite từ luồng phụ

[svcntt]

Mình đang nghiên cứu về Winsock và viết 1 chương trình tải file đơn giản sau gồm 2 phần
FileClient: gửi yêu cầu đến máy server
FileServer: thực hiện các xử lý từ FileClient

FileClient: sẽ gửi dạng sau: GET <Ten file>
FileServer sẽ tách tên file và truy xuất vào file đó.

Dưới đây là code của 2 phần:
FileClient:

// FileClient.cpp : Defines the entry point for the console application.// #include "stdafx.h"#include <winsock2.h>#include <stdio.h>#include <conio.h>#include <stdlib.h>#pragma comment (lib,"ws2_32.lib"); FILE *fp;SOCKET client;char filename[10];int q = 0;int i = 0;int k = 0; DWORD WINAPI ReceiverThread(LPVOID lpParameter){    char buf[1024];    if(fopen_s(&fp,"Test1.txt","w+") != 0)        printf("File is not found.\n");    //fp = stdout;    while(1){         //Bắt đầu ghi ra file       int ret = recv(client,buf,strlen(buf),0);       if(ret > 0)       {               buf[ret] = 0;               q = strlen(buf);               fwrite(buf,sizeof(char),q,fp);            }        else           printf("Ham recv() bi loi %d",WSAGetLastError());    }    fclose(fp);    return 0;}  int _tmain(int argc, _TCHAR* argv[]){    SOCKADDR_IN clientAddr;    int size = sizeof(clientAddr);    int ret;    WSAData wsaData;    WSAStartup(MAKEWORD(2,2),&wsaData);    client = socket(AF_INET,SOCK_STREAM,0);    if(client == INVALID_SOCKET)        printf("\nSocket ko hop le va loi: %d\n",WSAGetLastError());     clientAddr.sin_family = AF_INET;    clientAddr.sin_port = htons(8888);    clientAddr.sin_addr.s_addr = inet_addr("127.0.0.1");        char buf[1024],buf_rec[100];       ret = connect(client,(sockaddr*)&clientAddr,size);    if(ret != 0)        printf("\nHam connect() bi loi %d",WSAGetLastError());    else        printf("Da ket noi thanh cong    [%s]:[%d]\n",inet_ntoa(clientAddr.sin_addr),ntohs(clientAddr.sin_port));            memset(buf,0,strlen(buf));    memset(buf_rec,0,strlen(buf_rec));    //while(1)    //{               //Gửi yêu cầu tải file Test1.txt        strcat(buf,"GET ");                strcat(buf, "Test1.txt\n");           ret = send(client,buf,strlen(buf),0);        //ret = (int)CreateThread(0,0,ReceiverThread,0,0,0);              if(ret > 0)                ret = (int)CreateThread(0,0,ReceiverThread,0,0,0);         while(1)         {          }             //}     closesocket(client);    WSACleanup();    _getch();    return 0;}

FileServer:

// FileServer.cpp : Defines the entry point for the console application.// #include "stdafx.h"#include <winsock2.h>#include <stdio.h>#include <conio.h>#include <string.h>#include <stdlib.h>#pragma comment (lib,"ws2_32.lib") SOCKET server,newconnection;FILE *fp,*fcapa;char filename[1024];int sizefile,count,ret;bool isFirst = TRUE;char tmp[6]; DWORD WINAPI SendThread(LPVOID lpParameter){    char buf[100] = "OK ";     char temp[100];    if((fopen_s(&fp,filename,"r"))!= 0)        printf("File %s is not found.",filename);    fopen_s(&fcapa,filename,"r");    fseek(fcapa,0L,SEEK_END);    sizefile = ftell(fcapa) - 1; //Lay kich thuoc file    strcat(buf,filename);    strcat(buf,"\n");    strcat(buf,"Size:");    strcat(buf,_itoa(sizefile,tmp,10));    strcat(buf,"\n\n");    while(!feof(fp))    {       count = fread(temp,sizeof(char),4,fp);//doc tu con trỏ file ra buffer       if(count != 0)       {           temp[count] = 0;           if(isFirst)           {              strcat(buf,temp);              ret = send(newconnection,buf,strlen(buf),0);           }           else               ret = send(newconnection,temp,strlen(temp),0);            if(ret == 0)               printf("Ham send() trong luong phu bi loi %d",WSAGetLastError());            isFirst = FALSE;       }    }            fclose(fp);       fclose(fcapa);       return 0;} int _tmain(int argc, _TCHAR* argv[]){    SOCKADDR_IN serverAddr,clientAddr;    int size = sizeof(clientAddr);    WSAData wsaData;    char buf[1024];    int ret,i;    argv[1] = "8888";    WSAStartup(MAKEWORD(2,2),&wsaData);    server = socket(AF_INET,SOCK_STREAM,0);    if(server == INVALID_SOCKET)        printf("Ham socket() loi %d",WSAGetLastError());     serverAddr.sin_family = AF_INET;    serverAddr.sin_port = htons(8888);    serverAddr.sin_addr.s_addr = htonl(0);         ret = bind(server,(sockaddr*)&serverAddr,sizeof(serverAddr));    if(ret != 0)        printf("Ham bind() loi %d\n",WSAGetLastError());     ret = listen(server,10);    if(ret != 0)        printf("Ham listen() loi %d\n",WSAGetLastError());     newconnection = accept(server,(sockaddr*)&clientAddr,&size);    if(newconnection == INVALID_SOCKET)        printf("Ham accept() loi %d\n",WSAGetLastError());     while(1)    {        ret = recv(newconnection,buf,strlen(buf),0);        if(ret > 0)        {            buf[ret] = 0;            int len = strlen(buf);            if(strncmp(buf,"GET",3) == 0)            {              //Lay ten file              for(i = 0; i < len - 5; i++)                   filename[i] = buf[i + 4];              filename[i] = 0;              //Goi luong gui              ret = (int)CreateThread(0,0,SendThread,0,0,0);            }            else            {                memset(buf,0,sizeof(buf));                strcpy(buf,"Unknown Command");                ret = send(newconnection,buf,strlen(buf),0);                if(ret == 0)                    printf("Ham send() bi loi: %d",WSAGetLastError());            }        }    }     closesocket(newconnection);    closesocket(server);    WSACleanup();    _getch();    return 0;}

Vấn đề phát sinh ở luồng nhận ReceiverThread bên Client.
Trường hợp 1: mình cho fp trỏ vào file
Nếu mình debug từng dòng trong luồng thì toàn bộ nội dung của buf sẽ được ghi vào file.
Nhưng nếu mình chạy ở chế độ Running thì chỉ có OK <tenfile>\n Size: <kich thuoc file> được ghi ra file.
Trường hợp 2:( ở dòng 23) mình cho fp trỏ vào dòng stdout(mục đích là để test dữ liệu nhận đến thôi vì trường hợp 1 mình ko ghi hết được ra file)
thì ghi ra được hết lên console.

Mình ko rõ lỗi phát sinh do đâu. Debug thì chạy đúng nhưng khi Running thì ko ghi được hết.

Link tới project của mình: Chương trình tải file

[quangnh89]

Rất có thể lỗi bên phía server bạn ạ, nó không mở được file nên không gửi được, mà đã không gửi được thì chả có gì để nhận cả

Mà mình thấy bạn thiết kế cái message gửi file như thế là không hợp lý
1 bên cắm cúi gửi, một bên cứ nhắm mắt nhận

Giao thức nên theo kiểu sau: Có tên file, offset của vị trí muốn nhận dữ liệu trong file, size của dữ liệu cần nhận

như thế khi Client request 1 đoạn dữ liệu thì bên server gửi đúng yêu cầu thế thôi, nếu chết giữa chừng còn có thể resume được, và chỉ tải phần đã thiếu

 int ret = recv(client,buf,strlen(buf),0);
       if(ret > 0)
       {
               buf[ret] = 0;
               q = strlen(buf);
               fwrite(buf,sizeof(char),q,fp);
            }
        else
           printf("Ham recv() bi loi %d",WSAGetLastError());

ghi file thế này, chỉ dùng được nếu là file văn bản thôi , trường hợp file nhị phân thì chắc chắn lỗi nặng, khi truyền file nhị phân, nhất định trong đoạn dữ liệu sẽ có byte 0, như thế size bên gửi và bên nhận sẽ khác nhau, để giải quyết vấn đề này, bạn có thể encode trước khi gửi thành dạng Base64 trước khi gửi.

trông cái cổng 8888, buffer size là 1024, mình đoán bạn đang học lập trình mạng, kì hè, bkhn ???

[svcntt]

Mình sẽ chú ý tới 2 vấn đề sau:
+, Thiết kế lại message yêu cầu gửi file
+, Gửi file nhị phân trong trường hợp client y/cầu file nhị phân.

Nhưng trước hết , phải làm để chạy được chương trình trên với file văn bản đã. Sau đó, mới mở rộng cho 2 vấn đề như bạn nêu trên.
Cái chương trình FileServer ko chạy sai đâu. Mình chạy FileServer, rồi debug FileClient( ở chỗ luồng ReceiverThread ấy), sau khi debug qua hàm recv, thì buf chứa đầy đủ nội dung của file mà.( Như vậy bên server đã mở được file Test1.txt và lấy dữ liệu gửi về được rồi, thì hàm recv của client mới lấy được dữ liệu cho vào buf chứ). Cái mình quan tâm là ở hàm fwrite, mình debug qua nó, toàn bộ dữ liệu của buf được ghi ra file. Sau đó, xóa cái file Test1.txt trong thư mục project FileClient, chạy FileClient thì Test1.txt được tạo lại và nội dung chỉ có dòng OK <tenfile> Size:<kt file> còn lại nội dung file được yêu cầu thì ko thấy.

P/S: Mình ngồi nghe nhờ lớp Lập trình mạng thôi, thấy thiết thực nên mình muốn tìm hiểu luôn. Vì đằng nào, năm sau cũng phải học môn này mà.