本文实例为大家分享了C语言实现网络聊天室的具体代码，供大家参考，具体内容如下
业务逻辑：
1、客户端注册名字
2、告诉所有在线的客户端，XXX进入聊天室
3、新建一个线程为该客户端服务，随时接收客户端发送来的消息
4、当接收到一个客户端的消息时，向每一个客户端转发一份（群聊）
5、同时在线人数最多50人
任何客户端可以随意随时进入或退出客户端
服务端代码server.c
|
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
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
|
#include <stdio.h>#include <stdlib.h>#include <string.h>#include <unistd.h>#include <signal.h>#include <pthread.h>#include <semaphore.h>#include <sys/socket.h>#include <netinet/in.h>#include <arpa/inet.h>#ifndef DEBUG #define debug(format,...) {}#else #define debug(format,...) \ {\ fprintf(stdout,"%s:%d:%s ",__func__,__LINE__,__TIME__);\ fprintf(stdout,format,##__VA_ARGS__);\ fprintf(stdout,"\n");\ }#endif//DEBUG#define error(format,...)\{\ fprintf(stdout,"%s:%d:%s ",__func__,__LINE__,__TIME__);\ fprintf(stdout,format,##__VA_ARGS__);\ fprintf(stdout,":%m\n");\ exit(EXIT_FAILURE);\}// 客户端最大连接数#define CLIENT_MAX 50// 服务器端口号#define PORT 5566// 缓冲区大小#define BUF_SIZE 4096// 重定义socket地址类型typedef struct sockaddr* SP;// 客户端结构体typedef struct Client{ int sock;//socket 标识符 pthread_t tid; //线程ID char name[20]; struct sockaddr_in addr;}Client;// 定义50个存储客户端的结构变量Client clients[50];// 定义信号量用于限制客户端的数量sem_t sem;// 信号处理函数void sigint(int num){ for(int i=0; i<10; i++) { if(clients[i].sock) { pthread_cancel(clients[i].tid);//销毁线程 } } debug("服务器退出！"); exit(EXIT_SUCCESS);}void client_eixt(Client* client){ sem_post(&sem); close(client->sock); client->sock = 0;}void client_send(Client* client,char* buf){ size_t len = strlen(buf)+1; for(int i=0; i<CLIENT_MAX; i++) { if(clients[i].sock && clients[i].sock != client->sock) { send(clients[i].sock,buf,len,0); } }}void* run(void* arg){ Client* client = arg; char buf[BUF_SIZE] = {}; // 接收昵称 int ret_size = recv(client->sock,client->name,20,0); if(0 >= ret_size) { client_eixt(client); return NULL; } // 通知其它客户端新人上线 sprintf(buf,"!!!欢迎%s进入聊天室!!!",client->name); client_send(client,buf); for(;;) { // 接收消息 ret_size = recv(client->sock,buf,BUF_SIZE,0); if(0 >= ret_size || 0 == strcmp("quit",buf)) { // 通知其它客户端退出 sprintf(buf,"!!!%s退出聊天室!!!",client->name); client_send(client,buf); client_eixt(client); return NULL; } strcat(buf,":"); strcat(buf,client->name); client_send(client,buf); debug(buf); }}int main(int argc,const char* argv[]){ signal(SIGINT,sigint); debug("注册信号处理函数成功!"); sem_init(&sem,0,CLIENT_MAX); debug("初始化信号量成功!"); int svr_sock = socket(AF_INET,SOCK_STREAM,0); if(0 > svr_sock) { error("socket"); } debug("创建socket对象成功!"); struct sockaddr_in svr_addr = {}; svr_addr.sin_family = AF_INET; svr_addr.sin_port = htons(PORT); svr_addr.sin_addr.s_addr = INADDR_ANY; socklen_t addrlen = sizeof(svr_addr); debug("准备通信地址成功!"); if(bind(svr_sock,(SP)&svr_addr,addrlen)) { error("bind"); } debug("绑定socket对象和通信地址成功!"); if(listen(svr_sock,10)) { error("listen"); } debug("设置监听socket监听成功!"); for(;;) { debug("等待客户端连接..."); sem_wait(&sem); int index = 0; while(clients[index].sock) { index++; } clients[index].sock = accept(svr_sock,(SP)&clients[index].addr,&addrlen); if(0 > clients[index].sock) { kill(getpid(),SIGINT); } debug("有新的客户端连接,from ip:%s",inet_ntoa(clients[index].addr.sin_addr)); pthread_create(&clients[index].tid,NULL,run,&clients[index]); }} |
客户端代码client.c
|
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
|
#include <stdio.h>#include <stdlib.h>#include <string.h>#include <unistd.h>#include <signal.h>#include <pthread.h>#include <semaphore.h>#include <sys/socket.h>#include <netinet/in.h>#include <arpa/inet.h>#ifndef DEBUG #define debug(format,...) {}#else #define debug(format,...) \ {\ fprintf(stdout,"%s:%d:%s ",__func__,__LINE__,__TIME__);\ fprintf(stdout,format,##__VA_ARGS__);\ fprintf(stdout,"\n");\ }#endif//DEBUG#define error(format,...)\{\ fprintf(stdout,"%s:%d:%s ",__func__,__LINE__,__TIME__);\ fprintf(stdout,format,##__VA_ARGS__);\ fprintf(stdout,":%m\n");\ exit(EXIT_FAILURE);\}#define BUF_SIZE 4096#define SERVER_PORT 5566#define SERVER_IP "192.168.0.125"typedef struct sockaddr* SP;void* run(void* arg){ int cli_sock = *(int*)arg; char buf[BUF_SIZE] = {}; for(;;) { int ret_size = recv(cli_sock,buf,BUF_SIZE,0); if(0 >= ret_size) { printf("服务器正在升级，请稍候登录！\n"); exit(EXIT_SUCCESS); } printf("\r%30s\n>>>",buf); fflush(stdout); }}int main(int argc,const char* argv[]){ int cli_sock = socket(AF_INET,SOCK_STREAM,0); if(0 > cli_sock) { error("socket"); } struct sockaddr_in cli_addr = {}; cli_addr.sin_family = AF_INET; cli_addr.sin_port = htons(SERVER_PORT); cli_addr.sin_addr.s_addr = inet_addr(SERVER_IP); socklen_t addrlen = sizeof(cli_addr); if(connect(cli_sock,(SP)&cli_addr,addrlen)) { printf("服务器正在升级，请稍候登录！\n"); return EXIT_SUCCESS; } char buf[BUF_SIZE] = {}; printf("请输入你的眤称："); gets(buf); send(cli_sock,buf,strlen(buf)+1,0); pthread_t tid; pthread_create(&tid,NULL,run,&cli_sock); for(;;) { printf(">>>"); gets(buf); send(cli_sock,buf,strlen(buf)+1,0); if(0 == strcmp("quit",buf)) { printf("退出聊天室！\n"); return EXIT_SUCCESS; } }} |
以上就是本文的全部内容，希望对大家的学习有所帮助，也希望大家多多支持服务器之家。
原文链接：https://blog.csdn.net/qq_48135964/article/details/108934463
