C中的多線程TCP服務器

int sock, connected, bytes_received, true = 1; 
struct sockaddr_in server_addr, client_addr; 
int sin_size; 

if ((sock = socket(AF_INET, SOCK_STREAM, 0)) == -1) { 
    perror("Socket"); 
    exit(1); 
} 

if (setsockopt(sock, SOL_SOCKET, SO_REUSEADDR, &true, sizeof (int)) == -1) { 
    perror("Setsockopt"); 
    exit(1); 
} 

server_addr.sin_family = AF_INET; 
server_addr.sin_port = htons(atoi(argv[1])); 
server_addr.sin_addr.s_addr = INADDR_ANY; 
bzero(&(server_addr.sin_zero), 8); 

if (bind(sock, (struct sockaddr *) &server_addr, sizeof (struct sockaddr)) 
     == -1) { 
    perror("Unable to bind"); 
    exit(1); 
} 

if (listen(sock, 5) == -1) { 
    perror("Listen"); 
    exit(1); 
} 

printf("\nTCPServer Waiting for client on port 5003"); 
fflush(stdout); 

while (1) 
{ 
    pthread_t *child = (pthread_t *)malloc(sizeof(pthread_t)); 

    sin_size = sizeof (struct sockaddr_in); 
    connected = accept(sock, (struct sockaddr *) &client_addr, &sin_size); 
    printf("\n I got a connection from (%s , %d)\n", inet_ntoa(client_addr.sin_addr), ntohs(client_addr.sin_port)); 

    pthread_create(child, NULL, interpretMessage, NULL); 
    free(child); 
}

我的TCP服務器偵聽端口5003.當建立連接時，我想產生一個線程並運行函數interpretMessage。我有幾個關於這個問題...C中的多線程TCP服務器

1）我在調用malloc並在正確的地方免費嗎？

2）pthread_create被調用後，我的代碼是否立即跳轉到「free（child）;」然後回到while循環的開始？

3）如果5人在同一確切的時間（如何運行的代碼產卵5個螺紋連接，會發生什麼？）

來源

2011-02-22 Eddie

您的代碼不正確使用malloc和free，但你做的方式因此使實現比必要的更復雜。 pthread_create函數通過將新線程的ID寫入其第一個參數所指向的內存來工作。在你的情況下，你已經動態分配這個緩衝區，然後立即釋放它。因此，內存被限制在while循環的一次迭代中。如果這是你想要的，你可能會更好過剛剛製作pthread_t堆棧分配和指針傳遞到它變成pthread_create：

while (1) 
{ 
    pthread_t child; 

    /* ... */ 

    pthread_create(&child, NULL, interpretMessage, NULL); 
}

現在child本地作用域的循環中，內存管理將自動處理，無需致電malloc或free。

至於你的第二個問題，關於控制是否繼續到free (child)，然後在撥打pthread_create後回到循環頂部，是的，這是正確的。第二個線程將被創建，運行interpretMessage，所以如果原始進程延遲，可能會有一些延遲，但是控制從此處恢復。

對於你的最後一個問題，如果五個人都完全同時連接，那麼在接下來的五次你呼叫accept該函數將爲下一個傳入連接提供一個套接字。也就是說，操作系統會自動將傳入的連接按照某種順序排隊，並且在循環的每次迭代中，代碼都會注意到有一個連接，爲它獲取一個套接字，然後產生一個線程來處理該消息。

我在代碼中注意到的一件事情 - 當您產生一個線程來調用interpretMessage時，您沒有提供任何參數給該函數，因此每個線程將在沒有任何上下文的情況下操作以創建它。這是故意的嗎？

來源

2011-02-22 23:09:01 templatetypedef

嗨，非常感謝您的回覆。爲簡單起見，我刪除了參數，因爲我將一個結構傳遞給了interpretMessage函數，我不想將任何人與結構的內容混淆。我明白我現在需要做什麼，非常感謝你！ – Eddie 2011-02-22 23:33:17

C中的多線程TCP服務器

回答

相關問題