c - pthread_join 在处理多个客户端时无法分叉 TCP 服务器
问题描述
我必须创建一个多线程 TCP/IP 服务器,其中包含一个变量来计算连接的客户端数量(以及断开连接的客户端数量),并在客户端连接到服务器时打印连接的客户端数量。
这是我的client.c文件:
#define PORT 4444
int main ()
{
int clientSocket;
struct sockaddr_in serverAddress;
char buffer[1024];
ssize_t nread;
clientSocket = socket(AF_INET, SOCK_STREAM, 0);
if (clientSocket == -1) {
perror("[-]Errore durante la creazione della socket\n");
exit(-1);
}
printf("[+]Client socket has been created\n");
memset(&serverAddress, '\0', sizeof(serverAddress));
serverAddress.sin_family = AF_INET;
serverAddress.sin_port = htons(PORT);
serverAddress.sin_addr.s_addr = INADDR_ANY;
if (connect(clientSocket, (struct sockaddr*)&serverAddress, sizeof(serverAddress)) == -1) {
perror("Errore con la connessione\n");
exit(-1);
}
while (1) {
printf("> ");
fflush(stdin);
scanf("%s", buffer);
if (nread != -1)
buffer[nread] = '\0';*/
if (send(clientSocket, buffer, strlen(buffer), 0) == -1) {
perror("Errore con l'invio");
exit(1);
}
if(strcmp(buffer, ":exit") == 0) {
close(clientSocket);
printf("[-]Disconnected from Server\n");
exit(0);
}
if ( (nread=recv(clientSocket, buffer, sizeof buffer - 1, 0)) <= 0) {
perror("[-]Error in receiving data from server\n");
}
else {
buffer[nread] = '\0';
printf("Server received: %s\n", buffer);
}
}
close(clientSocket);
return 0;
}
这是我的server.c文件:
#define PORT 4444
#define MAX_CONNESSIONI 100
typedef struct myStruct {
int clientCollegati;
int clientCheSiSonoScollegati;
pthread_mutex_t mutex; // Creazione del mutex per sincronizzare la struttura
} myStruct;
myStruct *test;
myStruct *initStruct();
void *incrementa(void*);
int main ()
{
int serverSocket, bindStatus;
struct sockaddr_in serverAddress;
int clientSocket;
struct sockaddr_in newAddress;
char buffer[1024];
pid_t child;
socklen_t addrSize;
ssize_t nread;
pthread_t tid;
test = initStruct();
if (pthread_create(&tid, NULL, incrementa, NULL) != 0) {
perror("Errore nella creazione del thread t1\n");
exit(1);
}
serverSocket = socket(AF_INET, SOCK_STREAM, 0);
if (serverSocket == -1) {
perror("[-]Errore durante la creazione della socket\n");
exit(-1);
}
memset(&serverAddress, '\0', sizeof(serverAddress));
serverAddress.sin_family = AF_INET;
serverAddress.sin_port = htons(PORT);
serverAddress.sin_addr.s_addr = INADDR_ANY;
bindStatus = bind(serverSocket, (struct sockaddr*)&serverAddress, sizeof(serverAddress));
if (bindStatus == -1) {
perror("[-]Errore durante il binding\n");
exit(1);
}
printf("[+]Bind to port %d\n", PORT);
if (listen(serverSocket, MAX_CONNESSIONI) != -1) {
printf("Listening . . .\n\n");
}
else {
perror("[-]Error during listening\n");
exit(1);
}
while (1) {
clientSocket = accept(serverSocket, (struct sockaddr*)&newAddress, &addrSize);
if (clientSocket == -1) {
exit(-1);
}
printf("%s:%d joined\n", inet_ntoa(newAddress.sin_addr), ntohs(newAddress.sin_port));
if (pthread_join(tid, NULL)) { // returns 3
perror("pthread_join error\n");
exit(1);
}
printf("There is/are %d client(s) connected\n", test->clientCollegati);
child = fork();
if (child == 0) {
close(serverSocket);
while (1) {
if ( (nread=recv(clientSocket, buffer, sizeof buffer - 1, 0)) <= 0) {
perror("[-]Error in receiving data from server\n");
}
else {
buffer[nread] = '\0';
}
if (strcmp(buffer, ":exit") == 0) {
printf("%s:%d left\n", inet_ntoa(newAddress.sin_addr), ntohs(newAddress.sin_port));
break;
}
else {
printf("%s:%d wrote: %s\n", inet_ntoa(newAddress.sin_addr), ntohs(newAddress.sin_port), buffer);
send(clientSocket, buffer, strlen(buffer), 0);
bzero(buffer, sizeof(buffer));
}
}
}
}
close(clientSocket);
return 0;
}
myStruct *initStruct()
{
struct myStruct *ptr = malloc(sizeof(myStruct));
ptr->clientCollegati = 0;
ptr->clientCheSiSonoScollegati = 0;
pthread_mutex_init(&ptr->mutex, NULL); // inizializzazione dinamica del mutex
return ptr;
}
void *incrementa(void *ptr)
{
pthread_mutex_lock(&test->mutex);
test->clientCollegati++;
pthread_mutex_unlock(&test->mutex);
pthread_exit(0);
}
不幸的是,这似乎无法正常工作,因为您可以看到服务器输出以及此处的client1和此处的client2 输出
- 哪里错了?我想问题是当 tid 完成并且对
pthread_join
不存在的线程调用第二次调用时(因为只有一个线程)
解决方案
你的代码逻辑是错误的。您正在做一个pthread_create()
,然后是多个pthread_join()
. 如果您想为每个连接的客户端增加值,您必须pthread_create()
在每次成功后执行一次accept()
,然后再执行一次pthread_join()
。注意:所有这些都必须在调用fork()
.
哪里错了?我想问题是当
tid
完成时,第二次调用pthread_join
被调用到一个不存在的线程(因为有一个线程)
这正是发生的事情。在您当前的程序中,第一个pthread_join()
是成功的,并且任何后续调用都失败并显示 errno 3(没有这样的进程),因为线程不再存在。所以你已经想通了。如果您知道这是错误的,为什么要创建一个线程但多次加入它?
您的程序的编写方式(增量后分叉)也意味着根本没有理由使用线程来执行增量,您甚至不需要互斥锁,因为只有一个线程可以访问值任何给定的时间。换句话说,您的服务器根本不是多线程的。如果您只想将其作为实验进行,那没关系,但这没有多大意义。
您可能想要做的(拥有一个多线程服务器)是每个客户端都有一个线程,而不是每次都分叉,客户端代码在线程函数中(在这种情况下,有一个互斥锁是有意义的)。请注意,尽管这不适用于大量客户端(通常,经典fork()
方法更好,在这种情况下您真的不需要任何线程)。
推荐阅读
- laravel - 在会话开始前 10 分钟显示按钮
- symfony - 由于使用 parent() 和块结构,Twig 在我调用 form_row() 之前输出 Symfony 表单元素
- javascript - 使用 Google Apps 脚本访问亚马逊 MWS
- authentication - Kafka 客户端应用程序的瞬时 kerberos 身份验证失败
- python - 使用 PEP 563 检查.signature
- c# - 在 C# WebBrowser 组件中加载 html 文件
- c# - MsBuild 命令忽略发布配置文件中的位置
- amazon-web-services - 如何从微服务管理 AWS 粘合作业需要建议
- javascript - 如何在 Javascript 正则表达式中将字符串变量与几个特殊字符匹配?
- c# - C#:在文件更新 IRTime 时仅打印 .txt 文件中的最后一行