轉(zhuǎn)載：http://blog.csdn.net/robot__man/article/details/52460733

要求：基于TCP編寫，一個(gè)聊天室最多100人。?
客戶端：?
　　1、用戶需要登錄，登錄時(shí)只需要輸入一個(gè)昵稱即可無(wú)需判斷昵稱是否重復(fù)（如果其他功能都o(jì)k考慮）?
　　2、用戶登錄后連接服務(wù)器端，進(jìn)入聊天室?
　　3、用戶可以輸入聊天信息，也可以收到別人的聊天信息。?
　　4、用戶可以用某個(gè)特殊單詞代表退出聊天室。

服務(wù)器端：?
　　1、啟動(dòng)服務(wù)器，開放端口?
　　2、等待客戶端的連接，每連接上一個(gè)客戶端，啟動(dòng)一個(gè)線程?
　　3、在線程中與客戶端交互，交互過(guò)程：如果有客戶端登錄、退出、提交聊天，都應(yīng)該發(fā)給所有的客戶端。需要　　　保存所有客戶端。

額外功能：可以考慮實(shí)現(xiàn)TCP的文件傳輸。

server.c#include <stdio.h> #include <string.h> #include <stdlib.h> #include <unistd.h> #include <netinet/in.h> #include <arpa/inet.h> #include <sys/socket.h> #include <pthread.h>int sockfd;//服務(wù)器socket int fds[100];//客戶端的socketfd,100個(gè)元素，fds[0]~fds[99] int size =100 ;//用來(lái)控制進(jìn)入聊天室的人數(shù)為100以內(nèi) char* IP = "192.168.10.143"; short PORT = 10222; typedef struct sockaddr SA;void init(){sockfd = socket(PF_INET,SOCK_STREAM,0);if (sockfd == -1){perror("創(chuàng)建socket失敗");exit(-1);}struct sockaddr_in addr;addr.sin_family = PF_INET;addr.sin_port = htons(PORT);addr.sin_addr.s_addr = inet_addr(IP);if (bind(sockfd,(SA*)&addr,sizeof(addr)) == -1){perror("綁定失敗");exit(-1);}if (listen(sockfd,100) == -1){perror("設(shè)置監(jiān)聽失敗");exit(-1);} }void SendMsgToAll(char* msg){int i;for (i = 0;i < size;i++){if (fds[i] != 0){printf("sendto%d\n",fds[i]);send(fds[i],msg,strlen(msg),0);}} }void* service_thread(void* p){int fd = *(int*)p;printf("pthread = %d\n",fd);while(1){char buf[100] = {};if (recv(fd,buf,sizeof(buf),0) <= 0){int i;for (i = 0;i < size;i++){if (fd == fds[i]){fds[i] = 0;break;}}printf("退出：fd = %dquit\n",fd);pthread_exit((void*)i);}//把服務(wù)器接受到的信息發(fā)給所有的客戶端SendMsgToAll(buf);} }void service(){printf("服務(wù)器啟動(dòng)\n");while(1){struct sockaddr_in fromaddr;socklen_t len = sizeof(fromaddr);int fd = accept(sockfd,(SA*)&fromaddr,&len);if (fd == -1){printf("客戶端連接出錯(cuò)...\n");continue;}int i = 0;for (i = 0;i < size;i++){if (fds[i] == 0){//記錄客戶端的socketfds[i] = fd;printf("fd = %d\n",fd);//有客戶端連接之后，啟動(dòng)線程給此客戶服務(wù)pthread_t tid;pthread_create(&tid,0,service_thread,&fd);break;}if (size == i){//發(fā)送給客戶端說(shuō)聊天室滿了char* str = "對(duì)不起，聊天室已經(jīng)滿了!";send(fd,str,strlen(str),0); close(fd);}}} }int main(){init();service(); }

• 1
• 2
• 3
• 4
• 5
• 6
• 7
• 8
• 9
• 10
• 11
• 12
• 13
• 14
• 15
• 16
• 17
• 18
• 19
• 20
• 21
• 22
• 23
• 24
• 25
• 26
• 27
• 28
• 29
• 30
• 31
• 32
• 33
• 34
• 35
• 36
• 37
• 38
• 39
• 40
• 41
• 42
• 43
• 44
• 45
• 46
• 47
• 48
• 49
• 50
• 51
• 52
• 53
• 54
• 55
• 56
• 57
• 58
• 59
• 60
• 61
• 62
• 63
• 64
• 65
• 66
• 67
• 68
• 69
• 70
• 71
• 72
• 73
• 74
• 75
• 76
• 77
• 78
• 79
• 80
• 81
• 82
• 83
• 84
• 85
• 86
• 87
• 88
• 89
• 90
• 91
• 92
• 93
• 94
• 95
• 96
• 97
• 98
• 99
• 100
• 101
• 102
• 103
• 104

client.c#include <stdio.h> #include <stdlib.h> #include <string.h> #include <unistd.h> #include <sys/socket.h> #include <netinet/in.h> #include <arpa/inet.h> #include <pthread.h>int sockfd;//客戶端socket char* IP = "192.168.10.143";//服務(wù)器的IP short PORT = 10222;//服務(wù)器服務(wù)端口 typedef struct sockaddr SA; char name[30];void init(){sockfd = socket(PF_INET,SOCK_STREAM,0);struct sockaddr_in addr;addr.sin_family = PF_INET;addr.sin_port = htons(PORT);addr.sin_addr.s_addr = inet_addr(IP);if (connect(sockfd,(SA*)&addr,sizeof(addr)) == -1){perror("無(wú)法連接到服務(wù)器");exit(-1);}printf("客戶端啟動(dòng)成功\n"); }void start(){pthread_t id;void* recv_thread(void*);pthread_create(&id,0,recv_thread,0);char buf2[100] = {};sprintf(buf2,"%s進(jìn)入了聊天室",name);send(sockfd,buf2,strlen(buf2),0);while(1){char buf[100] = {};scanf("%s",buf);char msg[131] = {};sprintf(msg,"%s:%s",name,buf);send(sockfd,msg,strlen(msg),0);if (strcmp(buf,"bye") == 0){memset(buf2,0,sizeof(buf2));sprintf(buf2,"%s退出了聊天室",name);send(sockfd,buf2,strlen(buf2),0);break;}}close(sockfd); }void* recv_thread(void* p){while(1){char buf[100] = {};if (recv(sockfd,buf,sizeof(buf),0) <= 0){return;}printf("%s\n",buf);} }int main(){init();printf("請(qǐng)輸入您的名字：");scanf("%s",name);start();return 0; }

• 1
• 2
• 3
• 4
• 5
• 6
• 7
• 8
• 9
• 10
• 11
• 12
• 13
• 14
• 15
• 16
• 17
• 18
• 19
• 20
• 21
• 22
• 23
• 24
• 25
• 26
• 27
• 28
• 29
• 30
• 31
• 32
• 33
• 34
• 35
• 36
• 37
• 38
• 39
• 40
• 41
• 42
• 43
• 44
• 45
• 46
• 47
• 48
• 49
• 50
• 51
• 52
• 53
• 54
• 55
• 56
• 57
• 58
• 59
• 60
• 61
• 62
• 63
• 64
• 65
• 66
• 67
• 68
• 69
• 70

　　剛開始，我聲明的那個(gè)全局?jǐn)?shù)組int fds[99],它是有99個(gè)元素，fds[0]~fds[98],我以為是到fds[99]，結(jié)果數(shù)組越界，向fds[99]指向的未知文件描述符發(fā)了個(gè)數(shù)據(jù)，而fds[99]指向的是監(jiān)視進(jìn)程的，向它發(fā)任何數(shù)據(jù)，進(jìn)程都會(huì)莫名奇妙的終止。于是，服務(wù)器莫名奇妙的掛掉了，朋友用gdb調(diào)試，才發(fā)現(xiàn)Program received signal SIGPIPE, Broken pipe.這個(gè)問(wèn)題我自己看了一天半也沒發(fā)現(xiàn)，最后還是在群里面，別人幫提出來(lái)的，感悟有以下幾點(diǎn)：?
1、Linux下寫程序，也有調(diào)試工具gdb，要學(xué)會(huì)使用，程序出錯(cuò)了，如果看不出來(lái)，就可以來(lái)調(diào)試；?
2、程序員不是一直埋頭寫程序就行了，還是要多和別人交流，一切以解決問(wèn)題為根本。

總結(jié)

以上是生活随笔為你收集整理的Linux下基于socket和多线程的聊天室小程序的全部?jī)?nèi)容，希望文章能夠幫你解決所遇到的問(wèn)題。

如果覺得生活随笔網(wǎng)站內(nèi)容還不錯(cuò)，歡迎將生活随笔推薦給好友。