2012-02-06 31 views
1

我正試圖將音頻文件從一臺計算機發送到其他使用套接字編程的c。當我發送簡單的字符串時,沒有任何成幀信息,例如標題或報尾,它會完美髮送。但是,當我嘗試發送相同的信息與一些頭信息,如socket_data或packet_no的大小。它沒有得到正確發送。即使兩臺機器上的終端輸出都是相同的,但創建的文件完全不同且無法播放。我已經使用序列化概念來發送數據包。我附上了代碼。請評論最新的錯誤。使用c套接字傳輸音頻文件

Server.c

#include <stdio.h> 
#include <stdlib.h> 
#include <string.h> 
#include <sys/types.h> 
#include <sys/socket.h> 
#include <netinet/in.h> 
#include <fcntl.h> 

void set_socket(struct sockaddr_in *socket, int type, int host_short, int addr_type) 
{ 
    socket -> sin_family = type; 
    socket -> sin_port = htons(host_short); 
    socket -> sin_addr.s_addr = htonl(addr_type); 
} 

void serialize(char *buffer, int count, char *data) 
{ 
    int i=0, j=0; 
    char temp1[20]; 

    sprintf(temp1, "%d", count); 
    while(temp1[i] != '\0') 
    { 
     buffer[j++] = temp1[i++]; 
    } 
    buffer[j++]=' '; 

    for(i=0; data[i] != '\0'; i++) 
    { 
     buffer[j++] = data[i]; 
    } 
    buffer[j] = '\0'; 
    printf("BUFFER =%ld\n", sizeof(buffer)); 
} 

int main() 
{ 
    int sid = 0, bid = 0, fp; 
    char *send_data = (char *)malloc(1024*sizeof(char)); 
    char temp[1024]; 
    char *receive_data = (char *)malloc(1024*sizeof(char)); 
    int fd, count, cnt=0; 
    struct sockaddr_in server_socket, client_socket; 
    int size = sizeof(client_socket); 

    if((sid = socket(AF_INET, SOCK_DGRAM, IPPROTO_UDP)) == -1) 
    { 
     printf("Connection error..\n"); 
     exit(1); 
    } 

    set_socket(&server_socket, AF_INET, 6000, INADDR_ANY); 

    if((bid = bind(sid, (struct sockaddr *)&server_socket, sizeof(struct sockaddr))) == -1) 
    { 
     printf("Binding error..\n"); 
     exit(1); 
    } 

    printf("I am waiting for client..\n"); 

    recvfrom(sid, receive_data, 1024, 0,(struct sockaddr *)&client_socket, &size); 
    printf("received data is : %s\n", receive_data); 
    fd = open(receive_data, O_RDONLY); 
    printf("size = %ld\n", sizeof(send_data)); 

    while((count=read(fd, temp, 500)) != 0) 
    { 
     printf("I am inside the loop : %d\n", cnt++); 
     serialize(send_data, count, temp); 
     printf("Serialized : %s\n", send_data); 
     sendto(sid, send_data, 1024, 0, (struct sockaddr *)&client_socket, size); 
    } 
    printf("I am outside the loop : %d\n", count); 
    strcpy(temp, "ENDOFFILE"); 
    serialize(send_data, sizeof(temp), temp); 
    sendto(sid, send_data, 1024, 0, (struct sockaddr *)&client_socket, size); 

    fcloseall(); 
    close(sid); 
    close(fd); 
    return 0; 
} 

Client.c

#include <stdio.h> 
#include <stdlib.h> 
#include <string.h> 
#include <sys/types.h> 
#include <sys/socket.h> 
#include <netinet/in.h> 
#include <netdb.h> 
#include <fcntl.h> 

void set_socket(struct sockaddr_in *socket, int type, int host_short) 
{ 
    socket -> sin_family = type; 
    socket -> sin_port = htons(host_short); 
} 

void deserialize(char *buffer, int *size, char *data) 
{ 
    int i=0, j=0; 
    char temp1[20]; 

    while(buffer[i] != ' ') 
    { 
     temp1[j++] = buffer[i++]; 
    } 
    temp1[j] = '\0'; 
    printf("\nINT : %s\n", temp1); 
    *size = atoi(temp1); 

    i++; 
    j=0; 

    while(buffer[i] != '\0') 
    { 
     data[j++] = buffer[i++]; 
    } 
    data[j++] = '\0'; 
} 

int main() 
{ 
    int sid = 0, bid = 0, con = 0; 
    char *send_data = (char *)malloc(1024*sizeof(char)); 
    char *receive_data = (char *)malloc(1024*sizeof(char)); 
    char *temp = (char *)malloc(1024*sizeof(char)); 
    struct hostent *host; 
    struct sockaddr_in server_socket; 
    int size = sizeof(server_socket); 

    if((sid = socket(AF_INET, SOCK_DGRAM, IPPROTO_UDP)) == -1) 
    { 
     printf("Connection error at client side..\n"); 
     exit(1); 
    } 

    set_socket(&server_socket, AF_INET, 6000); 

    if (inet_aton("127.0.0.1", &server_socket.sin_addr)==0) 
    { 
     fprintf(stderr, "inet_aton() failed\n"); 
     exit(1); 
    } 

    printf("Enter the name of the file you want to see : "); 
    scanf("%s", send_data); 
    int fd = open("sanket.mp3", O_CREAT | O_RDWR, S_IRUSR | S_IWUSR | S_IXUSR); 
    sendto(sid, send_data, 1024, 0, (struct sockaddr *)&server_socket, size); 
    printf("================= Contents of the File =====================\n"); 
    while(1) 
    { 
     int size; 
     recvfrom(sid, temp, 1024, 0, (struct sockaddr *)&server_socket, &size); 
     printf("Deserialize it : %s\n",temp); 
     deserialize(temp, &size, receive_data); 
     if(!strcmp(receive_data, "ENDOFFILE")) 
     { 
      printf("============================================================\n"); 
      break; 
     } 
     else 
      write(fd, receive_data, size); 
    } 
    fcloseall(); 
    close(sid); 

    return 0; 
} 

當我檢查了發送和接收的文件的大小,尺寸是相同的,但內容不同,因此我無法播放收到的音頻文件。

+0

可能與字節順序有關。您的編碼在機器之間有沒有可能不同? – 2012-02-06 20:50:05

+0

它看起來像通過UDP而不是TCP發送文件。那是故意的嗎? – grieve 2012-02-06 21:06:02

+0

如果您選擇使用TCP而不是UDP,本文來自另一則文章的答案可能會對您有所幫助:http://stackoverflow.com/a/666788/34329 – grieve 2012-02-06 21:46:29

回答

4

您似乎是從二進制數據文件中讀取數據,但在serialize函數中,您將數據視爲 - 如果它是以空值終止的字符串數據。例如,這個循環在serialize之內:

for(i=0; data[i] != '\0'; i++) 
{ 
    buffer[j++] = data[i]; 
} 

將終止它遇到的第一個零值。如果這是來自音頻文件的二進制數據,那麼我相信你會得到0值,它們是實際的音頻數據,而不是指示緩衝區的結尾。您應該終止於您傳遞給serialize的緩衝區的大小,而不是在NULL值上終止,而這是在您在while循環中調用read時讀取的。通過這種方式,您可以確保您獲取從您的發送緩衝區打包的read調用中讀取的所有數據。

其次,打印sizeof(buffer),當buffer是一個指針時,將只打印一個指針類型的大小,而不是指針指向的實際緩衝區的大小。同樣,你將不得不明確地將該值傳遞給你的serialize函數。

第三,你用一個空值終止緩衝區......這不是一個好主意,根據關於這是原始二進制數據而不是以空值終止的字符串的第一點爲基礎。您應該想出一些類型的字符串來指示緩衝區中的傳輸結束,這將是一組不可能成爲數據一部分的值,或者您應該明確地讀取字節數在你已經嵌入到分組數據中的「計數」中。

最後,你並沒有真正序列化數據......序列化的概念通常意味着以獨立於平臺的方式傳輸數據。假設接收端具有相同的字節順序等,您只需將讀取的字節打包並通過網絡發送即可。一個相當簡單的序列化方法將執行類似於從所有數據值創建ASCII字符串的操作,而下行方向這會造成相當多的數據膨脹。還有其他用於序列化數據的跨平臺標準,如JSON,SOAP等。

+0

非常感謝..它像一個魅力.. – curiousMind 2012-02-07 20:28:30