【linux下c语言服务器开发系列6】客户端_多进程_压力测试

谁借莪１个温暖的怀抱￠ 2022-01-15 07:01 197阅读 0赞

[为什么80%的码农都做不了架构师？>>> ][80_] ![hot3.png][]

上篇博客写了一个聊天室的服务器。只能用telnet来测试是否好用。于是，写了一个客户端来进行压力测试。看看服务器能给多少client服务。

客户端的主要作用是，fork多个进程，给服务器随机发送文本内容，服务器收到客户端的内容后，转发给其他所有的客户端。

测试了一下，客户端开1000个进程，与服务器段进行交互，发现只有400个进程有发送和回复的内容，其余的进程都没有。目前还不知道原因。貌似是服务器过载了？

下面是这个客户端的部分代码：

创建指定数量的进程，每个进程都调用runchild()函数来与客户端通讯。其中的user参数保存了客户的一些信息，包括读写缓存等。

for(int w=0;w<PROCESS_NUMBER;w++)
            {
                    user_number++;
                    pid_t pid=fork();
                    //此时，我们创建一个子进程，专门负责这个客户端的一切事物
                    //为了方便知道哪个子进程的事件，我们用conn作为索引，即将之视为主键,对进程和链接进行索引和对照
                    if(pid<0)
                    {
                            printf("fork error\n");
                            break;
                    }
                    else if(pid==0) //子进程中，处理一切事物
                    {
                            connectfd=socket(AF_INET,SOCK_STREAM,0);
                            if(connect(connectfd,(struct sockaddr*)&server_address,sizeof(server_address))==0)
                            {
                                    printf("connect success\n");
                            }
                            users[user_number].conn=connectfd;
    
                            close(epollfd);
                            char * hello="hello, server\n";
                            send(connectfd,hello,strlen(hello),0);
                            runchild(&(users[user_number]));
                            exit(0);
                    }
                    else
                    {
                            close(connectfd);
                            users[user_number].pid=pid;
                            subprocess[pid].u=&users[user_number];
                    }
            }

下面是runchild（）函数的代码：主要逻辑是，对连接socket进行监听。如果发现有内容从服务器到达，则读取，然后该客户端再构造一段随机的串（调用ranText（）函数），发给服务器，表示这个客户要发言。

int runchild(user* curuser)
    {
            assert(curuser!=NULL);
    
            int child_epollfd=epoll_create(5);
            assert(child_epollfd!=-1);
    
            epoll_event events[MAX_EVENT_NUMBER];
    
            int conn=curuser->conn;
            addfd(child_epollfd,conn);
            addfd(child_epollfd,0);
    
            int stop_child=0;
            int ret=0;
    
            while(!stop_child)
            {
                    //printf("in child\n");
                    int number=epoll_wait(child_epollfd,events,MAX_EVENT_NUMBER,-1);
                    if(number<0 && errno!=EINTR)
                    {
                            printf("epoll error in child");
                            break;
                    }
                    
                    for(int i=0;i<number;i++)
                    {
                            int sockfd=events[i].data.fd;
    
                            if(sockfd ==conn && (events[i].events & EPOLLIN) )
                            {
                                    ret=recv(conn,curuser->bufread,BUF_SIZE,0);
                                    if(ret<0 && errno!=EAGAIN)
                                            stop_child=1;
                                    else if (ret==0)
                                            stop_child=1;
                                    else
                                    //通知父进程，有了数据啦，让父进程告诉别的子进程去读吧。哈哈
                                    {
                                            printf("%s\n",curuser->bufread);
                                            time_t curtime=time(NULL);
                                            srand(curtime);
                                            int ranTime=(rand()+getpid())%10+1;
                                            sleep(ranTime);
                                            randText(curuser->bufwrite);
    
                                            send(curuser->conn,curuser->bufwrite,strlen(curuser->bufwrite),0);
                                            
                                    }
    
                            }
                            else if (socket==0 && (events[i].events & EPOLLIN))
                            {
                                    scanf("%s",curuser->bufwrite);
                                    send(curuser->conn,curuser->bufwrite,strlen(curuser->bufwrite),0);
    
                            }
                    }
            }
    
            
    }

ranText()函数是客户端用来随机构造一个TEXT\_LEN长度的字符串，然后发给服务器。

int randText(char * buf)
    {
            assert(buf!=NULL);
            time_t curtime=time(NULL);
            srand(curtime);
            int ranLen=rand()%TEXT_LEN;
            for(int i=0;i<ranLen;i++)
            {
                    buf[i]='a'+rand()%26;
            }
            return 1;
    
    }

关于服务器和客户端之间的线程数量的设置，以致服务器过载等原因，还有待考证。

转载于:https://my.oschina.net/shewa/blog/173759

[80_]: https://my.oschina.net/u/2663968/blog/3051541
[hot3.png]: /images/20220115/1b8083dd55c142e2bb9dac2e65026a91.png