准备开始写一些Linux 下网络编程以及多线程的blog，就从这个简单的echo程序开始吧。
在echo的服务端使用多线程与客户进行通信，可以实现一个服务端程序同时连接多个客户的功能。那么，到底在服务端要有多少个线程呢？
答案是：1+1+n。一个主线程，一个监听（listen）线程，与n个客户进行通信的n个线程。
服务端代码：
1 #include "../unp.h" 2 #include <pthread.h> 3 4 void* str_echo(void* argv) 5 { 6 int *pcommu = (int*)argv; 7 int sockfd =*pcommu; 8 9 ssize_t n; 10 char buf[MAXLINE]; 11 12 while ( (n = read(sockfd,buf,MAXLINE)) > 0) { 13 write(sockfd,buf,n); 14 } 15 } 16 17 void* listen_func(void* argv) 18 { 19 int* plistenfd = (int*)argv; 20 int listenfd = *plistenfd; 21 22 listen(listenfd,LISTENQ); 23 for (;;) { 24 struct sockaddr_in cliaddr; 25 socklen_t clilen = sizeof(cliaddr); 26 int connfd = accept(listenfd,(SA*)&cliaddr,&clilen); 27 pthread_t communication;//通信线程 28 pthread_create(&communication,NULL,&str_echo,&connfd); 29 } 30 } 31 32 33 int main() 34 { 35 int listenfd; 36 37 struct sockaddr_in servaddr; 38 39 listenfd = socket(AF_INET,SOCK_STREAM,0); 40 41 bzero(&servaddr,sizeof(servaddr)); 42 servaddr.sin_family = AF_INET; 43 servaddr.sin_addr.s_addr = htonl(INADDR_ANY); 44 servaddr.sin_port = htons(SERV_PORT); 45 46 bind(listenfd,(SA*)&servaddr,sizeof(servaddr)); 47 48 pthread_t listenPthread;//监听线程 49 pthread_create(&listenPthread,NULL,&listen_func,&listenfd); 50 51 while(1); 52 53 return 0; 54 }
客户端代码：
1 #include "../unp.h" 2 3 void str_cli(FILE *fp, int sockfd); 4 int main(int argc, char **argv) 5 { 6 int sockfd; 7 struct sockaddr_in servaddr,cliaddr; 8 if (argc != 2) { 9 printf("no IPaddress\n"); 10 return 0; 11 } 12 13 sockfd = socket(AF_INET, SOCK_STREAM, 0); 14 15 bzero(&servaddr, sizeof(servaddr)); 16 servaddr.sin_family = AF_INET; 17 servaddr.sin_port = htons(SERV_PORT); 18 inet_pton(AF_INET, argv[1],&servaddr.sin_addr); 19 20 connect(sockfd, (SA*) &servaddr, sizeof(servaddr)); 21 22 str_cli(stdin,sockfd); 23 24 exit(0); 25 } 26 27 void str_cli(FILE *fp, int sockfd) 28 { 29 char sendline[MAXLINE],recvline[MAXLINE]; 30 int n; 31 while (fgets(sendline,MAXLINE,fp) != NULL) { 32 write(sockfd, sendline, strlen(sendline)); 33 34 if(n = read(sockfd, recvline, MAXLINE) ) { 35 recvline[n] = 0; 36 fputs(recvline, stdout); 37 } 38 } 39 }
ps，之前在看UNP，客户端代码是UNP里面的。我主要是把UNP里面的服务端的程序改成了多线程的，在原书里是基于多进程的，这样的话服务端一旦运行就堵塞在监听那，改成多线程，单独拿出一个线程来监听可以解决这种情况，主线程可以去做其他的操作，而不会阻塞在listen ：）。
pps，我在github上放了一个即时聊天的小程序，服务端也是基于多线程的，不过是window下的，而且用的原始的socket api，准备有时间改成linux+muduo库，感兴趣请戳：github地址