轉載：http://blog.csdn.net/robot__man/article/details/52460733

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

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

額外功能：可以考慮實現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;//服務器socket
int fds[100];//客戶端的socketfd,100個元素，fds[0]~fds[99]
int size =100 ;//用來控制進入聊天室的人數為100以內
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("創建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("設置監聽失敗");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);}//把服務器接受到的信息發給所有的客戶端SendMsgToAll(buf);}
}void service(){printf("服務器啟動\n");while(1){struct sockaddr_in fromaddr;socklen_t len = sizeof(fromaddr);int fd = accept(sockfd,(SA*)&fromaddr,&len);if (fd == -1){printf("客戶端連接出錯...\n");continue;}int i = 0;for (i = 0;i < size;i++){if (fds[i] == 0){//記錄客戶端的socketfds[i] = fd;printf("fd = %d\n",fd);//有客戶端連接之后，啟動線程給此客戶服務pthread_t tid;pthread_create(&tid,0,service_thread,&fd);break;}if (size == i){//發送給客戶端說聊天室滿了char* str = "對不起，聊天室已經滿了!";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";//服務器的IP
short PORT = 10222;//服務器服務端口
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("無法連接到服務器");exit(-1);}printf("客戶端啟動成功\n");
}void start(){pthread_t id;void* recv_thread(void*);pthread_create(&id,0,recv_thread,0);char buf2[100] = {};sprintf(buf2,"%s進入了聊天室",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("請輸入您的名字：");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

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