基于linux的實(shí)時(shí)通信軟件設(shè)計(jì)(參考版)
2025-07-22 10:05本頁面
【正文】 } 。 } close(sockfd)。*/ client[maxi++]=new_fd。 exit(1)。client_addr),amp。 } 16 sin_size=sizeof(struct sockaddr_in)。 while(1) { /* 服務(wù)器 阻塞 ,直到客戶程序建立連接 */ if(maxi=20) { printf(以達(dá)到人數(shù)上線 \n)。p_thread, NULL, recvandsend, NULL)。 exit(1)。 } printf(服務(wù)器監(jiān)聽端口 %d...\n,PORT)。server_addr),sizeof(struct sockaddr))==1) { fprintf(stderr,Bind error:%s\n\a,strerror(errno))。 =htons(PORT)。 =AF_INET。 } /* 服務(wù)器端填充 sockaddr 結(jié)構(gòu) */ bzero(amp。 } /* 服務(wù)器端開始建立 socket 描述符 */ if((sockfd=socket(AF_INET,SOCK_STREAM,0))==1) { fprintf(stderr,Socket error:%s\n\a,strerror(errno))。 if(argc!=1) { fprintf(stderr,Usage:%s portnumber\a\n,argv[0])。s structure */ int new_fd=0。 /* thread ID for the newly created thread */ pthread_t p_thread。 char hello[]=Hello! Are You Fine?\n。 struct sockaddr_in client_addr。 } int main(int argc, char *argv[]) { int client_fd[LISTENQ],clientnum=0。 } } } if(index=maxi) index=0。 while(outindexmaxi) if(write(client[outindex++],buffer,sizeof(buffer))=1) { fprintf(stderr,Write Error:%s\n,strerror(errno))。 printf( %s\n,buffer)。 if(nbytes0) { buffer[nbytes]=39。 nbytes=read(client[index++],buffer,sizeof(buffer))。 nbytes=0。 int outindex=0。 char buffer[1024]。 void recvandsend(void) //監(jiān)聽轉(zhuǎn)發(fā)線程入口函數(shù) { int index=0。 static int maxi=0。 } 14 /******* 服務(wù)器程序 () ************/ include include include include include include sys/ include i/ include sys/ define MAXLINE 1000 //在一條消息中最大的輸出字符數(shù) define LISTENQ 20 //最大監(jiān)聽隊(duì)列 define PORT 5000 //監(jiān)聽端口 define MAXFD 20 //最大的在線 用戶數(shù)量 void *get_client(void *)。 } } /* 結(jié)束通訊 */ close(sockfd)。 exit(1)。 // printf(main thread %s\n,mes)。 strcat(mes,:)。 scanf(%s,buffer)。 while(1) { memset(buffer,0,sizeof(buffer))。 thr_id = pthread_create(amp。 // write(sockfd,clientname,sizeof(clientname))。 Printf (請(qǐng)輸入你的用戶昵稱 \n)。 exit(1)。 /* 客戶程序發(fā)起連接請(qǐng)求 */ if(connect(sockfd,(struct sockaddr *)(amp。 =*((struct in_addr *)hosth_addr)。 =AF_INET。 } /* 客戶程序填充服務(wù)端的資料 */ bzero(amp。 if((sockfd=socket(AF_INET,SOCK_STREAM,0))==1) { fprintf(stderr,Socket Error:%s\a\n,strerror(errno))。 exit(1)。 13 scanf(%s,strhost)。 exit(1)。 /* thread39。 int thr_id。 char clientname[20]。 int portnumber,nbytes。 struct sockaddr_in se
研究報(bào)告相關(guān)推薦
鄂ICP備17016276號(hào)-1