c - Socket多线程实现C

Question

我正致力于在 C 中实现多线程多客户端单服务器套接字。但是，无论出于何种原因，当前程序在使用 pthread_create() 创建新线程时，都不会超过该行代码。我已经在这行代码之前和之后放置了打印行，并且在手打印之前的所有打印行都很好，但是在打印之后没有一个。这让我相信 pthread_create() 在某种程度上是错误的。奇怪的是，我可以让 1 个客户端连接并成功地从服务器发送/接收数据，但是因为 listen() 命令所在的循环没有推进，所以我无法接收其他客户端。我感谢你在这件事上的帮助。

服务器代码

#include <stdio.h>
#include <stdlib.h> //for IOs
#include <string.h>
#include <unistd.h>
#include <sys/types.h> //for system calls
#include <sys/socket.h> //for sockets
#include <netinet/in.h> //for internet
#include <pthread.h>

void error(const char *msg)
{
    perror(msg);
    exit(1);
}
void *threadFunc(int mySockFd)
{
    int n;
    char buffer[256];
    do
    {
        bzero(buffer,256);
        n = read(mySockFd,buffer,255);
        if (n < 0) 
        {
            error("ERROR reading from socket");
        }
        else if(strcmp(buffer, "EXIT\n") == 0)
    {
        printf("Exit by user\n");
        pthread_exit(NULL);
    }
    else
    {
        printf("Here is the message: %s\n",buffer);
            n = write(mySockFd,"I got your message",18);            
            if (n < 0) 
            {
                error("ERROR writing to socket");
            }
        }
    }while(n >= 0);


}    

int main(int argc, char *argv[])
{
    int sockfd;
    int newsockfd;
    int portno;
    pthread_t pth;
    int n; /*n is the return value for the read() and write() calls; i.e. it contains     the number of characters read or written.*/
    int i = 0;
    printf("after var decl");
socklen_t clilen; /*clilen stores the size of the address of the client. This is     needed for the accept system call.*/
    char buffer[256]; /*The server reads characters from the socket connection into     this buffer.*/
    struct sockaddr_in serv_addr;
    struct sockaddr_in cli_addr;
if (argc < 2) 
    {
        fprintf(stderr,"ERROR, no port provided\n");
        exit(1);
    }
sockfd = socket(AF_INET, SOCK_STREAM, 0);
if (sockfd < 0)
    {
        error("ERROR opening socket");
    }
bzero((char *) &serv_addr, sizeof(serv_addr));
portno = atoi(argv[1]);
serv_addr.sin_family = AF_INET;
serv_addr.sin_addr.s_addr = INADDR_ANY;
serv_addr.sin_port = htons(portno);
if (bind(sockfd, (struct sockaddr *) &serv_addr, sizeof(serv_addr)) < 0)
    {
        error("ERROR on binding");
    }
do
    {       
        printf("before listen");
        listen(sockfd,5);
        printf("after listen");
                clilen = sizeof(cli_addr);
        printf("before accept");
        newsockfd = accept(sockfd,(struct sockaddr *) &cli_addr,&clilen);
        printf("after accept");
        pthread_create(&pth,NULL,threadFunc(newsockfd),(void*) &i);
        printf("after pthread create");
        if (newsockfd < 0)
        {
            error("ERROR on accept");
        }
    }while(1 == 1);
bzero(buffer,256);
    n = read(newsockfd,buffer,255);
    if (n < 0) 
    {
        error("ERROR reading from socket");
    }
    printf("Here is the message: %s\n",buffer);
if (n < 0) error("ERROR writing to socket");
close(newsockfd);
    close(sockfd);
    return 0;

这是客户端代码

#include <stdio.h>
#include <stdlib.h>
#include <unistd.h>
#include <string.h>
#include <sys/types.h>
#include <sys/socket.h>
#include <netinet/in.h>
#include <netdb.h> /*The file netdb.h defines the structure hostent, which will be     used below.*/
void error(const char *msg)
{
    perror(msg);
    exit(0);
}

int main(int argc, char *argv[])
{
int sockfd;
int portno;
int n;
struct sockaddr_in serv_addr;
struct hostent *server;
char buffer[256];
if (argc < 3) 
{
    fprintf(stderr,"usage %s hostname port\n", argv[0]);
    exit(0);
}
    portno = atoi(argv[2]);
    sockfd = socket(AF_INET, SOCK_STREAM, 0);
if (sockfd < 0)
{
    error("ERROR opening socket");  
}
server = gethostbyname(argv[1]);
if (server == NULL) 
{
    fprintf(stderr,"ERROR, no such host\n");
    exit(0);
}
bzero((char *) &serv_addr, sizeof(serv_addr));
serv_addr.sin_family = AF_INET;
bcopy((char *)server->h_addr,
(char *)&serv_addr.sin_addr.s_addr,
server->h_length);
serv_addr.sin_port = htons(portno);
if (connect(sockfd,(struct sockaddr *) &serv_addr,sizeof(serv_addr)) < 0)
{
    error("ERROR connecting");
}
do
{
    printf("Please enter the message: ");
    bzero(buffer,256);
    fgets(buffer,255,stdin);
    n = write(sockfd,buffer,strlen(buffer));
    if(strcmp(buffer,"EXIT\n") == 0)
    {
        printf("Connection Terminated\n");
        break;
    }
    if (n < 0)
    {
        error("ERROR writing to socket");
    }
    bzero(buffer,256);
    n = read(sockfd,buffer,255);
    printf("%s\n",buffer);
    if (n < 0)
    {
    error("ERROR reading from socket");
    printf("%s\n",buffer);
    }

}while(1 == 1);
close(sockfd);
return 0;
}

Answer 1

两个错误:

1. 你转换的太多了，这里唯一的地方应该是 inaddr 的东西。
2. 你没有听从你的编译器，提高警告级别。

现在，问题(或者可能只是一个？)实际上是这样的:

pthread_create(&pth,NULL,threadFunc(newsockfd),(void*) &i);

这将调用 threadFunc(newsockfd) 并将结果传递给 pthread_create。但是，第二部分永远不会发生，因为该函数调用 pthread_exit 或在没有返回任何内容的情况下退出结尾，这可能导致任何事情发生。