#include #include #include #include #include #include #include #include #include #include #define LISTENQ 1000 //最大連接數(shù) #define MAXLINE 512 //發(fā)送消息的最長字節(jié) #define MAXMEM 1000 #define NAMELEN 20 //名字長度 struct socketcfd { char name[20]; int fd; }; int listenfd; //分別記錄服務(wù)器端的套接字與連接的多個(gè)客戶端的套接字 struct socketcfd connfd[MAXMEM]; void rcv_snd(void *arg) //服務(wù)器接受并轉(zhuǎn)發(fā)消息函數(shù) { char* ask="請輸入你的名字："; char* ask1="使用說明：\n1、群聊可以直接發(fā)送消息，\n2、私聊請先輸入@+人名+空格+內(nèi)容，\n3、退出直接輸入“bye”\n-------------------------------------------"; char* ch="此用戶不存在"; char* ch1="群聊"; char* ch2="私聊"; char buff[MAXLINE]; //用戶姓名 char buff1[MAXLINE]; //聊天內(nèi)容（包括私聊和群聊，然后對它進(jìn)行分析） char buff2[MAXLINE]; //發(fā)送消息的時(shí)間 char buff3[MAXLINE]; //私聊時(shí)接受用戶的姓名 char buff4[MAXLINE]; //私聊時(shí)發(fā)送的內(nèi)容 time_t ticks; int i=0; int retval; int len; int k=0,j=0,m=0; int p; int n=(int *)arg; //獲取此進(jìn)程對應(yīng)的套接字用戶的名字 write(connfd[n].fd,ask,strlen(ask)); len=read(connfd[n].fd,connfd[n].name,NAMELEN); if(len>0){ connfd[n].name[len]=0; } printf("用戶姓名：%s\n",connfd[n].name); //把當(dāng)前用戶的加入告知所有用戶 strcpy(buff,connfd[n].name); strcat(buff,"\t加入聊天"); for(i=0;i0) { buff1[len]=0; //當(dāng)前用戶的輸入信息為“bye”時(shí)，當(dāng)前用戶退出 if(strcmp("bye",buff1)==0){ printf("%s用戶已退出\n",connfd[n].name); close(connfd[n].fd); connfd[n].fd=-1; pthread_exit(&retval); } //通過分析發(fā)送的信息判斷是群聊還是私聊 if(buff1[0]=='@'){ j=0;m=0; for(k=1;kp){ buff4[m]=buff1[i]; m++; } else if(iMAXMEM){ write(connfd[n].fd,ch,strlen(ch)); } } }else{ ticks=time(NULL); sprintf(buff2,"%.24s\r\n",ctime(&ticks)); strcpy(buff,buff2); strcat(buff,ch1); strcat(buff,"\t"); strcat(buff,connfd[n].name); strcat(buff,"\n"); strcat(buff,buff1); for(i=0;i