基于linux的實(shí)時(shí)通信軟件設(shè)計(jì)-資料下載頁(yè)
2025-07-17 10:05本頁(yè)面
【正文】 //最大的在線 用戶(hù)數(shù)量 void *get_client(void *)。 int sockfd,i。 static int maxi=0。 //maxi 表示當(dāng)前 client 數(shù)組中最大的用戶(hù)的 i 值 static int client[MAXFD]。 void recvandsend(void) //監(jiān)聽(tīng)轉(zhuǎn)發(fā)線程入口函數(shù) { int index=0。 int nbytes=0。 char buffer[1024]。 int len。 int outindex=0。 while(1) { if(maxi0) { memset(buffer,0,sizeof(buffer))。 nbytes=0。 index++。 nbytes=read(client[index++],buffer,sizeof(buffer))。 printf(%d,%d\n,index,client[index])。 if(nbytes0) { buffer[nbytes]=39。\039。 printf( %s\n,buffer)。 outindex=0。 while(outindexmaxi) if(write(client[outindex++],buffer,sizeof(buffer))=1) { fprintf(stderr,Write Error:%s\n,strerror(errno))。 exit(1)。 } } } if(index=maxi) index=0。 } 15 pthread_exit(NULL)。 } int main(int argc, char *argv[]) { int client_fd[LISTENQ],clientnum=0。 struct sockaddr_in server_addr。 struct sockaddr_in client_addr。 int sin_size,portnumber。 char hello[]=Hello! Are You Fine?\n。 int thr_id。 /* thread ID for the newly created thread */ pthread_t p_thread。 /* thread39。s structure */ int new_fd=0。 memset(client,0,sizeof(client))。 if(argc!=1) { fprintf(stderr,Usage:%s portnumber\a\n,argv[0])。 exit(1)。 } /* 服務(wù)器端開(kāi)始建立 socket 描述符 */ if((sockfd=socket(AF_INET,SOCK_STREAM,0))==1) { fprintf(stderr,Socket error:%s\n\a,strerror(errno))。 exit(1)。 } /* 服務(wù)器端填充 sockaddr 結(jié)構(gòu) */ bzero(amp。server_addr,sizeof(struct sockaddr_in))。 =AF_INET。 =htonl(INADDR_ANY)。 =htons(PORT)。 /* 捆綁 sockfd 描述符 */ if(bind(sockfd,(struct sockaddr *)(amp。server_addr),sizeof(struct sockaddr))==1) { fprintf(stderr,Bind error:%s\n\a,strerror(errno))。 exit(1)。 } printf(服務(wù)器監(jiān)聽(tīng)端口 %d...\n,PORT)。 /* 監(jiān)聽(tīng) sockfd 描述符 */ if(listen(sockfd,LISTENQ)==1) { fprintf(stderr,Listen error:%s\n\a,strerror(errno))。 exit(1)。 } thr_id = pthread_create(amp。p_thread, NULL, recvandsend, NULL)。 printf(歡迎來(lái)到本聊天室 \n)。 while(1) { /* 服務(wù)器 阻塞 ,直到客戶(hù)程序建立連接 */ if(maxi=20) { printf(以達(dá)到人數(shù)上線 \n)。 continue。 } 16 sin_size=sizeof(struct sockaddr_in)。 if((new_fd=accept(sockfd,(struct sockaddr *)(amp。client_addr),amp。sin_size))==1) { fprintf(stderr,Accept error:%s\n\a,strerror(errno))。 exit(1)。 } /*fprintf(stderr,Server get connection from %s\n,i_ntoa())。*/ client[maxi++]=new_fd。 printf(\n 新用戶(hù)進(jìn)入聊天室 %d\n,new_fd)。 } close(sockfd)。 exit(0)。 }
研究報(bào)告相關(guān)推薦
鄂ICP備17016276號(hào)-1