准备开始写一些Linux 下网络编程以及多线程的blog,就从这个简单的echo程序开始吧。
在echo的服务端使用多线程与客户进行通信,可以实现一个服务端程序同时连接多个客户的功能。那么,到底在服务端要有多少个线程呢?
答案是:1+1+n。一个主线程,一个监听(listen)线程,与n个客户进行通信的n个线程。
服务端代码:
#include "../unp.h"#include <pthread.h> void* str_echo(void* argv){ int *pcommu = (int*)argv; int sockfd =*pcommu; ssize_t n; char buf[MAXLINE]; while ( (n = read(sockfd,buf,MAXLINE)) > 0) { write(sockfd,buf,n); }} void* listen_func(void* argv){ int* plistenfd = (int*)argv; int listenfd = *plistenfd; listen(listenfd,LISTENQ); for (;;) { struct sockaddr_in cliaddr; socklen_t clilen = sizeof(cliaddr); int connfd = accept(listenfd,(SA*)&cliaddr,&clilen); pthread_t communication;//通信线程 pthread_create(&communication,NULL,&str_echo,&connfd); }} int main(){ int listenfd; struct sockaddr_in servaddr; listenfd = socket(AF_INET,SOCK_STREAM,0); bzero(&servaddr,sizeof(servaddr)); servaddr.sin_family = AF_INET; servaddr.sin_addr.s_addr = htonl(INADDR_ANY); servaddr.sin_port = htons(SERV_PORT); bind(listenfd,(SA*)&servaddr,sizeof(servaddr)); pthread_t listenPthread;//监听线程 pthread_create(&listenPthread,NULL,&listen_func,&listenfd); while(1); return 0;}
客户端代码:
#include "../unp.h" void str_cli(FILE *fp, int sockfd);int main(int argc, char **argv){ int sockfd; struct sockaddr_in servaddr,cliaddr; if (argc != 2) { printf("no IPaddressn"); return 0; } sockfd = socket(AF_INET, SOCK_STREAM, 0); bzero(&servaddr, sizeof(servaddr)); servaddr.sin_family = AF_INET; servaddr.sin_port = htons(SERV_PORT); inet_pton(AF_INET, argv[1],&servaddr.sin_addr); connect(sockfd, (SA*) &servaddr, sizeof(servaddr)); str_cli(stdin,sockfd); exit(0);} void str_cli(FILE *fp, int sockfd){ char sendline[MAXLINE],recvline[MAXLINE]; int n; while (fgets(sendline,MAXLINE,fp) != NULL) { write(sockfd, sendline, strlen(sendline)); if(n = read(sockfd, recvline, MAXLINE) ) { recvline[n] = 0; fputs(recvline, stdout); } }}
ps,之前在看UNP,客户端代码是UNP里面的。我主要是把UNP里面的服务端的程序改成了多线程的,在原书里是基于多进程的,这样的话服务端一旦运行就堵塞在监听那,改成多线程,单独拿出一个线程来监听可以解决这种情况,主线程可以去做其他的操作,而不会阻塞在listen :)。