多线程并发服务器编程

1、多线程并发服务器编程指针status：指向线程的退出状态。不能指向一个局部变量，由于线程终止时其全部的局部变量将被撤销。 还有其他两种办法可使线程终止： （1）启动线程的函数pthread_create()的第3个参数返回。其返回 便是线程的终止状态； （2）假如进程的main()函数返回，或者当前进程中，任一线程调用了exit()函数，将终止该进程中全部线程。 五、试验步骤 1、登陆进入ubuntu操作系统，新建一个文件，命名为mthread_server.c。 2、在mthread_server.c中编写相应代码并保存，作为服务器端程序。客户端程序代码同mproc_client.c全都。b

2、log: 3、打开一个“终端”，执行进入mthread_server.c和mproc_client.c所在名目。 4、执行指令gccomthread_servermthread_server.c-lpthread生成可执行文件mthread_server。 5、执行指令./mthread_server，运行服务器端。 6、打开第2个“终端”，执行指令进入mthread_server.c和mproc_client.c所在名目。 7、执行指令./mproc_client127.0.0.1，模拟客户1。 8、打开第3个“终端”，执行指令进入mthread_server.c和mproc_client.

3、c所在名目。 9、执行指令./mproc_client127.0.0.1，模拟客户2。 10、程序运行结果如下： 服务器端： 客户1： 客户2： 11、在客户端按下ctrl d，关闭客户衔接。 12、仔细分析源代码，体味多线程并发服务器程序的编写。 六、参考程序（mthread_server.c） include stdio.h include stdlib.h include string.h include unistd.h include sys/types.h include sys/socket.h include netinet/in.h include arpa/inet.h i

4、nclude pthread.h define port 1234 define backlog 5 define maxdatasize 1000 void process_cli(int connfd, struct sockar_in client); void *function(void* arg); struct arg int connfd; struct sockaddr_in client; ; main() int listenfd,connfd; pthread_t tid; struct arg *arg; struct sockaddr_in server; stru

5、ct sockaddr_in client; socklen_t len; if (listenfd =socket(af_inet, sock_stream, 0) = -1) perror( creatingsocket failed. exit(1); int opt =so_reuseaddr; sockopt(listenfd,sol_socket, so_reuseaddr, opt, sizeof(opt); bzero( server,sizeof(server); server.sin_family=af_inet; server.sin_port=htons(port);

6、server.sin_addr.s_addr= htonl (inaddr_any); if (bind(listenfd,(struct sockaddr *) server, sizeof(server) = -1) perror( bind()error. exit(1); if(listen(listenfd,backlog)= -1) perror( listen()errorn exit(1); len=sizeof(client); while(1) if (connfd =accept(listenfd,(struct sockaddr *) client, len)=-1)

7、perror( accept() errorn exit(1); arg = (struct arg *)malloc(sizeof(struct arg); arg- connfd =connfd; mepy(void*) arg- client, client, sizeof(client); if(pthread_create( tid, null, function, (void*)arg) perror( pthread_create() error exit(1); close(listenfd); void process_cli(int connfd, struct socka

8、ddr_in client) int num; char recvbufmaxdatasize, sendbufmaxdatasize, cli_namemaxdatasize; printf( yougot a connection from %s. n ,inet_ntoa(client.sin_addr) ); num = recv(connfd,cli_name, maxdatasize,0); if (num = 0) close(connfd); printf( clientdisconnected.n return; cli_namenum - 1 ='0' pr

9、intf( client'sname is %s.n ,cli_name); while (num =recv(connfd, recvbuf, maxdatasize,0) recvbufnum ='0' printf( receivedclient( %s ) message: %s ,cli_name, recvbuf); int i; for (i = 0; i num - 1; i ) if(recvbufi ='a' recvbufi ='z')|(recvbufi ='a' recvbufi ='z') recvbufi=recvbufi if(recvbufi 'z' recvbufi ='z' 3)|(recvbufi 'z') recvbufi=recvbufi- 26; sendbufi =recvbufi; sendbufnum -1 = '0' send(connfd,sendbuf,strlen(sendbuf),0); close(con