...
 17 #include <mysql.h>//用于mysql连接...
 24
 25 struct user
 26 {...  29 };
 30
 31 int MAX(int a,int b)...  37
 38 void print_time(char * ch,time_t *now)
 39 {...  43 }
 44
 45
 46 int mysql_check_login(struct user su)
 47 {...  91     return 0;
 92 }
 93
 94 //根据用户名返回该用户名在fd_A中的位置
 95 //fd=-1,表示没有该用户 //fd>0 正常返回
 96 int fd_ctoa(char fd_C[][32],char *ch)
 97 {
 98     int i,j;
 99     int fd=-1;
100     for(i=0;i<BACKLOG;i++)
101     {
102         if(strcmp(fd_C[i],ch)==0)
103         {
104             fd=i;
105             break;
106         }
107     }
108     return fd;
109 }
110
111 int main(int argc,char *argv[])
112 {...
187     while(1)
188     {
189         FD_ZERO(&servfd);//清空所有server的fd
190         FD_ZERO(&recvfd);//清空所有client的fd
191         FD_SET(sockfd,&servfd);
192         //timeout.tv_sec=30;//可以减少判断的次数
193         switch(select(max_servfd+1,&servfd,NULL,NULL,&timeout))
194         {　　　　　　　　... ...242         }
243         //FD_COPY(recvfd,servfd);
244         for(i=0;i<MAX_CON_NO;i++)//最大队列进行判断，优化的话，可以使用链表
245         {...250         }
251
252         switch(select(max_recvfd+1,&recvfd,NULL,NULL,&timeout))
253         {
254             case -1:
255                 //select error
256                 break;
257             case 0:
258                 //timeout
259                 break;
260             default:
261                 for(i=0;i<conn_amount;i++)
262                 {
263                     if(FD_ISSET(fd_A[i],&recvfd))
264                     {
265                         /*receive datas from client*/
266                         if((recvSize=recv(fd_A[i],recvBuf,MAX_DATA_SIZE,0))==-1 || recvSize==0)
267                         {...273                         }
274                         else//客户端发送数据过来，然后这里进行转发
275                         {
276                             /*send datas to client*/
277                             /*下面是私聊代码,为了方便讲解所以写在这里*/
278                             sscanf(recvBuf,"%s%s",ch,username);
279                             if(strcmp(ch,"simple")==0)//判断第一个单词是不是simple私聊的标识符
280                             {
281                                 printf("私聊信息处理:  %s\n",recvBuf);
282                                 for(j=0;j<strlen(recvBuf);j++)//为了方便我规定聊天信息中以#符号后面为发送的聊天文本前面为标识符号（一切都是为了方便 ^v^）
283                                 {
284                                     if(recvBuf[j]=='#')
285                                     {
286                                         j++;
287                                         break;
288                                     }
289                                 }
290                                 if(j<strlen(recvBuf))
291                                 {
292                                     printf("%s对%s私聊说:%s\n",fd_C[i],username,&recvBuf[j]);//打印在服务器控制台方便调试
293                                     fd=fd_ctoa(fd_C,username);//根据用户名得到该用户名所对应的fd_A中的位置
294                                     printf("fd=%d\n",fd);//打印描述符号，用于调试
295                                     if(fd>=0)//表示找到对应的用户名
296                                     {
297                                         strcpy(sendBuf,fd_C[i]);
298                                         strcat(sendBuf," 对您私聊  ");
299                                         print_time(ch,&now);
300                                         strcat(sendBuf,ch);//加个时间戳
301                                         strcat(sendBuf,"\t\t");
302                                         strcat(sendBuf,&recvBuf[j]);
303                                         //sendSize=send(fd_A[fd],&recvBuf[j],strlen(recvBuf)-j,0);
304                                         sendSize=send(fd_A[fd],sendBuf,strlen(sendBuf),0);//发往指定的客户端
305                                     }
306                                     else
307                                     {
308                                         strcpy(ch,"私聊信息发送失败，可能是没有该用户");
309                                         sendSize=send(fd_A[i],ch,strlen(ch),0);
310
311                                     }
312                                 }
313                                 else
314                                 {
315                                     strcpy(ch,"私聊信息发送失败，可能是没有 # 符号");
316                                     sendSize=send(fd_A[i],ch,strlen(ch),0);
317
318                                 }
319                                 break;
320                             }
321                             else
322                             {
323                             }
324                             //其他else就是其他命令了，为了方便就不支持其他命令了
325                               ...352                         }
353                     }
354                 }
355                 break;
356         }//end-switch
357     }//end-while(1)
358     return 0;
359 }

//上一节忘了说mysql怎么设置开机启动了，指令如下，root用户执行
chkconfig mysqld on
service mysqld start

 1 [myuser@localhost client-server]$ ./server ser
 2 username:ser
 3 Success to establish a socket...
 4 Success to bind the socket...
 5 Success to accpet a connection request...
 6 >>>>>> 127.0.0.1:54880 join in! ID(fd):4
 7 加入的时间是:06:39:04
 8
 9 客户端发来的用户名是:user3,密码:123456
10 查询的sql:select * from clients where username="user3" and password="123456";
11 验证成功！
12 Success to accpet a connection request...
13 >>>>>> 127.0.0.1:54881 join in! ID(fd):6
14 加入的时间是:06:39:04
15
16 客户端发来的用户名是:user1,密码:123456
17 查询的sql:select * from clients where username="user1" and password="123456";
18 验证成功！
19 Success to accpet a connection request...
20 >>>>>> 127.0.0.1:54882 join in! ID(fd):8
21 加入的时间是:06:39:04
22
23 客户端发来的用户名是:user2,密码:123456
24 查询的sql:select * from clients where username="user2" and password="123456";
25 验证成功！
26 数据是:user2 06:39:04