多线程客户端 linux,【linux下c语言服务器开发系列1】多线程处理多客户端的连接...

川长思鸟来 2023-01-21 08:21 168阅读 0赞

在上文中，提供了一个十分简单的回射服务器的demo，但是，这个demo的作用十分有限，只能接收一个客户端的连接，然后和其建立联系，进行通讯。等这个客户端断开连接后，才能处理另外的连接。功能太弱了。因为我们之前学过多进程程序设计，所以，这里提供一个回射服务器的多进程版本，使之能够同时处理多个客户端的连接。

多进程主要是靠fork函数来完成的，他是一个特殊函数，一次调用，两次返回。如果返回大于0，表示是父进程，同时返回值表示了他的子进程的pid。返回值如果等于0，表示他是一个子进程。子进程是父进程的一个拷贝，保留了父进程的所有东西。但是，我们往往需要让子进程执行别的函数。这个函数，你可以在程序里写，然后在子进程调用；也可以是已经存在的文件，你可以用exec族的函数，对子进程的内容进行复写。这部分具体怎么处理，完全看你的业务需求。在本例中，就是对已经接受的连接，进行读写操作。

在返回的父进程中，往往需要继续处理程序的主框架的内容。而且，需要对子进程的资源进行回收，即等待子进程执行完成，用wait和waitpid函数回收子进程，避免其成为僵尸进程而占用资源。wait可以返回子进程的退出状态，waipid可以非阻塞的处理。是wait的加强版。

下面是这个版本的回射服务器的demo代码，贴一下。注意，因为代码没有重构，看起来比较乱。尤其是读写函数，目前还处于一个零散的状态，没有抽出来。此外，没有进行wait，否则容易卡住，这个接下来会提供解决的方法。

\#include"head.h"

\#define MAX\_USER 1024

\#define BUF\_SIZE 1024

typedef struct user //yon \{

int conn; //表示客户与服务器的连接

sockaddr\_in client\_addr; //用户的地址

char bufread\[BUF\_SIZE\]; // 用户的读缓存

char bufwrite\[BUF\_SIZE\]; //用户的写缓存

\} user;

int main(int argc, char \*\*argv)

if(argc<3)

printf("usage: %s ip port\\n",basename(argv\[0\]));

exit(0);

printf("start echoback server...\\n");

char \* ip=(char \* ) argv\[1\];

int port =atoi(argv\[2\]);

/\*构造服务器端的地址，主要是填充sockaddr\_in 结构体\*/

struct sockaddr\_in server\_address;

bzero(&server\_address,sizeof(server\_address));

server\_address.sin\_family=AF\_INET;

inet\_pton(AF\_INET,ip,&server\_address.sin\_addr);

server\_address.sin\_port=htons(port);

int listenfd=socket(AF\_INET,SOCK\_STREAM,0);

assert(listenfd>=0);

int reuse=1;

setsockopt(listenfd,SOL\_SOCKET,SO\_REUSEADDR,&reuse,sizeof(reuse));

setnonblock(listenfd);

int ret=bind(listenfd,(struct sockaddr \*) &server\_address, sizeof(server\_address));

assert(ret==0);

ret=listen(listenfd,5);

assert(ret==0);

/\*服务器服务启动，等待客户端的链接的到来\*/

int run\_flag=1;

char buf\[1024\];

int conn=-1;

user users\[MAX\_USER\];

int stop\[MAX\_USER\];

for(int i=0;i

stop\[i\]=0;

int user\_number=0;

while(run\_flag)

int acfd=accept(listenfd,NULL,NULL);

if(acfd>=0)

printf("acfd>0,hhahahaha");

user\_number++;

/\*users\[user\_number\] 表示一个conn，唯一标识这个用户链接\*/

users\[user\_number\].conn=acfd;

pid\_t pid=fork();

if(pid<0)

printf("fork error\\n");

exit(0);

else if (pid==0) /\*这里进入子进程\*/

close(listenfd); //关闭无用的监听套接字，由父进程继续监听

setnonblock(users\[user\_number\].conn);

//while(!stop\[ users\[user\_number\].conn\] )

while(1)

int readn=read(users\[user\_number\].conn,users\[user\_number\].bufread,BUF\_SIZE);

// printf("readn=%d\\n",readn);

//printf("errno=%d\\n",errno);

if( (readn<0) && (errno!=EAGAIN))

printf("a\\n");

printf("read fail, client %d\\n",users\[user\_number\].conn);

close(users\[user\_number\].conn);

//stop\[ users\[user\_number\].conn \]=1;

//break;

exit(0);

else if (readn==0)

printf("b\\n");

close(users\[user\_number\].conn);

//stop\[ users\[user\_number\].conn \]=1;

//break;

exit(0);

\} else if (readn>0)

printf("pid= %d\\n",getpid());

users\[user\_number\].bufread\[readn\]='\\0';

memcpy(users\[user\_number\].bufwrite,users\[user\_number\].bufread,sizeof(users\[user\_number\].bufread));

int writen=write(users\[user\_number\].conn,users\[user\_number\].bufwrite,sizeof(users\[user\_number\].bufwrite));

memset(users\[user\_number\].bufread,0,sizeof(users\[user\_number\].bufread));

printf("write %d bytes to %d\\n",writen,users\[user\_number\].conn);

/\*parent process\*/

else

close(users\[user\_number\].conn);

int stat\_loc;

/\*如果想要多个进程共同服务的话，就不能在这里阻塞的等待，可以通过sigchld信号进行捕获\*/

// wait((int \*)&stat\_loc);

printf("parent, finished wait\\n");

这段代码，运行起来后，可以用多个telnet连接服务器，发现服务器能为多个客户端服务啦。代码中存在的缺点如读写逻辑差、未进行子进程回收等内容，将在下一个版本中改掉。而且，多进程一般是用进程池，后面的版本也会实现。敬请期待。

多线程客户端 linux,【linux下c语言服务器开发系列1】多线程处理多客户端的连接...

发表评论取消回复

还没有评论，来说两句吧...

相关阅读

相关网络编程——阻塞TCP多线程多客户端

相关多线程客户端 linux,【linux下c语言服务器开发系列1】多线程处理多客户端的连接...

相关 TCP服务器连接多客户端（C语言实现）

相关 jav服务端-客户端Socket通信改进(多线程)

相关使用libevent和多线程构建高性能服务器（客户端）

相关 Socket编程——使用多线程实现多客户端的通信

相关 windows客户端开发--实现一个多线程定时器

相关多线程实现多客户端通信

相关 python多线程SocketServer模块--实现多客户端接入

相关 Android客户端开发—Java多线程实现与应用