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服务器

回答

相关问题