【正文】 socklen_t server_addr_length = sizeof(server_addr)。 close(client_socket)。 ftl(client_socket, F_SETFL, flags|O_NONBLOCK)。 char receiver_user_ID[BUFFER_SIZE]。 scanf(%s,password)。 break。 《網(wǎng)絡(luò)編程》課程設(shè)計(jì) 21 int response。 } 《網(wǎng)絡(luò)編程》課程設(shè)計(jì) 22 程序測(cè)試 圖 11 編譯服務(wù)端并運(yùn)行 圖 11 服務(wù)端編譯運(yùn)行 圖 12 編譯客戶(hù)端并運(yùn)行 圖 12 客戶(hù)端編譯運(yùn)行 程序界面功能包括： 注冊(cè)； 登陸； 獲取在線(xiàn)用戶(hù)名單； 聊天； 退出； 獲取他人對(duì)你的聊天信息 。在客戶(hù)方呼叫之前，服務(wù)方必須處于偵聽(tīng)狀態(tài)，偵聽(tīng)是否有客戶(hù)要求建立連接。 【 8】 （美）科默（ Comer， .） ， 《用 TCP/IP 進(jìn)行網(wǎng)際互連第一卷 —— 原理、協(xié)議與結(jié)構(gòu)（英文版）》 ， 電子工業(yè)出版社 ， 202081。 【 4】 （美） Stevens.《 UNIX 網(wǎng)絡(luò)編程（第一卷）》 ， 楊繼張譯 ， 清華大學(xué)出版社 ， 2020?？蛻?hù)方和服務(wù)方是相對(duì)的，同一個(gè)應(yīng)用可以是客戶(hù)方，也可以是服務(wù)方。 } bzero(user_ID,BUFFER_SIZE)。 char message_from[ID_SIZE+1]。 scanf(%s,receiver_user_ID)。mand_option)。 user_id+=ID_SIZE+1 ) printf(%s\t, user_id)。 } 《網(wǎng)絡(luò)編程》課程設(shè)計(jì) 18 /************************************************************ *函數(shù)名稱(chēng) : receive_result_from_server_noblock *正常返回值 : 服務(wù)器發(fā)回的響應(yīng)類(lèi)型 * option 被存放入響應(yīng)的選項(xiàng) * message 被存放入響應(yīng)的信息 *函數(shù)執(zhí)行失敗 : 接收數(shù)據(jù)失敗返回值為 1 *參數(shù)要求 : option 被預(yù)先分配 OPTION_SIZE+1 大小的空間 * message 被預(yù)先分配 MESSAGE_SIZE+1 大小的空間 *參數(shù)說(shuō)明 : 當(dāng)不使用 option 時(shí) , option 應(yīng)當(dāng)是 NULL * 當(dāng)不使用 message 時(shí) , message 應(yīng)當(dāng)是 NULL *依賴(lài)自定義數(shù)據(jù)結(jié)構(gòu) : chat_package *************************************************************/ int receive_result_from_server_noblock(char * option, char * from, char * message) { chat_package buffer。 if(to) memcpy(, to, ID_SIZE)。 if(i_aton(server_IP_addr,amp。 /************************************************************ *函數(shù)名稱(chēng) : connect_to_server *正常返回值 : 連接到服務(wù)器的 socket *函數(shù)執(zhí)行失敗 : 連接失敗返回值 為 1,向控制臺(tái)輸出錯(cuò)誤信息 *依賴(lài)自定義數(shù)據(jù)結(jié)構(gòu) : 無(wú) 《網(wǎng)絡(luò)編程》課程設(shè)計(jì) 15 *************************************************************/ int connect_to_server(char * server_IP_addr) { //設(shè)置一個(gè) socket 地址結(jié)構(gòu) client_addr,代表客戶(hù)機(jī) inter 地址 , 端口 struct sockaddr_in client_addr。length)。 } close(new_server_socket)。send_buffer,BUFFER_SIZE,0)。 = get_active_user_list()。 exit(1)。user_table_mutex)。 } } pthread_mutex_unlock(amp。i++) { if(strcmp(user_table[i].user_ID,receiver)==0) { if(user_table[i].client_socket=0) { socket = user_table[i].client_socket。iUSER_AMOUNT_MAX。 for(i=0。 for(i=0。 char password[PASSWORD_SIZE]。 開(kāi)發(fā)原理 服務(wù)器 ： 使用 ServerSocket 監(jiān)聽(tīng)指定的端口，端口可以隨意指定（由于 1024 以下的端口通常屬于保留端口，在一些操作系統(tǒng)中不可以隨意使用，所以使用大于 1024 的端口），等待客戶(hù)連接請(qǐng)求，客戶(hù)連接后，會(huì)話(huà)產(chǎn)生； 在完成會(huì)話(huà)后，關(guān)閉連接。 程序具有簡(jiǎn)單易用性。 /************************************************************ *函數(shù)名稱(chēng) : init_user_table *函數(shù)執(zhí)行失敗 : 當(dāng)一個(gè)報(bào)文不能容納全部用戶(hù)名稱(chēng)列表時(shí) ,給出錯(cuò)誤提示信息 ,結(jié)束程序 *依賴(lài)自定義數(shù)據(jù)結(jié)構(gòu) : struct user 本文件 *依賴(lài)全局變量 : user_table 本文件 *************************************************************/ int init_user_table() { if(USER_ID_SIZE*USER_AMOUNT_MAXMESSAGE_SIZE) { 《網(wǎng)絡(luò)編程》課程設(shè)計(jì) 5 printf(USER_ID_SIZE*USER_AMOUNT_MAXMESSAGE_SIZE\n)。 pthread_mutex_unlock(amp。user_table_mutex)。user_table_mutex)。user_table_mutex)。 int i=0。 } /************************************************************ *函數(shù)名稱(chēng) : init_server_socket *功能說(shuō)明 : 初始化服務(wù)器用于監(jiān)聽(tīng)的的 socket *正常返回值 : 已經(jīng)初始化的服務(wù)器用于監(jiān)聽(tīng)的的 socket *函數(shù)執(zhí)行失敗 : 輸出錯(cuò)誤信息 ,退出程序 *************************************************************/ int init_server_socket() { struct sockaddr_in server_addr。 bzero((char*)amp。 《網(wǎng)絡(luò)編程》課程設(shè)計(jì) 12 client_socket = look_up_socket(receiver)。 bzero((char*)amp。 int server_socket = init_server_socket()。child_thread_attr,talk_to_client, (void *)new_server_socket) 0 ) printf(pthread_create Failed : %s\n,strerror(errno))。 //INADDR_ANY 表示自動(dòng)獲取本機(jī)地址 = htons(0)。 //向服務(wù)器發(fā)起連接 ,連接成功后 client_socket 代表了客戶(hù)機(jī)和服務(wù)器的一個(gè) socket 連接 if(connect(client_socket,(struct sockaddr*)amp。 exit(0)。 int length = recv(client_socket,(char*)amp。 // 一個(gè)很大的緩沖區(qū) , 實(shí)際ID_SIZE 內(nèi)有效 bzero(receiver_user_ID,BUFFER_SIZE)。 send_request_to_server(mand_option, 0, 0, 0)。 case EXIT: send_request_to_server(mand_option, 0, 0, 0)。 if(GET_MESSAGE==mand_option) response=receive_result_from_server_noblock(option, message_from, message)。 圖 13 查詢(xún)?cè)诰€(xiàn)人數(shù) 圖 13 查詢(xún)?cè)诰€(xiàn)人數(shù) （左側(cè) server 端，右側(cè) client 端） 初次運(yùn)行 系統(tǒng)顯示無(wú)人在線(xiàn)。一旦接到連接請(qǐng)求，服務(wù)方可以根據(jù)情況建立或拒絕連接。 《網(wǎng)絡(luò)編程》課程設(shè)計(jì) 26 【 9】 (英 )馬修 //(英 )斯通斯 |譯者 :陳健 ， 《 Linux 程序設(shè)計(jì) (第 3 版 )》 ， 人民郵電出版社 ，20200701。 【 3】 常志文 ， 《 TCP/IP 網(wǎng)絡(luò)互連第 3 卷 :客戶(hù) /服務(wù)器編程及應(yīng)用 :Linux/POSIX Socket》 ，人民郵電出版社 ， 2020 年 1 月第一版。當(dāng)兩個(gè)應(yīng)用之間需要采用 SOCKET 通信時(shí)，首先需要在兩個(gè)應(yīng)用之間（可《網(wǎng)絡(luò)編程》課程設(shè)計(jì) 25 能位于同一臺(tái)機(jī)器，也可能位于不同的機(jī)器）建立 SOCKET 連接，發(fā)起呼叫連接請(qǐng)求的一方為客戶(hù)方，接受呼叫連接請(qǐng)求的一方成為服務(wù)方。 exit(1)。 bzero(option,OPTION_SIZE+1)。 case TALK_TO: printf(Input Receiver User_ID:)。 scanf(%d,amp。 user_iduser_list_buffer+MESSAGE_SIZE。 return 。 if(option) memcpy(, option, OPTION_SIZE)。 = AF_INET。 // 一個(gè)很大的緩沖區(qū) , 實(shí)際PASSWORD_SIZEE 內(nèi)有效 static int client_socket。client_addr,amp。buffer)。 send(client_socket, (chat_package *)amp。 case GET_USER_LIST: memcpy(, USER_LIST, OPTION_SIZE)。server_addr,sizeof(server_addr))) { printf(Server Bind Port : %d Failed!, CHAT_SERVER_PORT)。 pthread_mutex_unlock(amp。 return SUCCEED。iUSER_AMOUNT_MAX。 } } for(i=0。 int i=0。 int i=0。 《網(wǎng)絡(luò)編程》課程設(shè)計(jì) 4 *關(guān)鍵問(wèn)題 ： * 客戶(hù)機(jī)和服務(wù)器之間協(xié)議制訂 * 多線(xiàn)程訪(fǎng)問(wèn)同一個(gè)用戶(hù)列表的互斥問(wèn)題 *************************************************************/ include include sys/ include define LENGTH_OF_LISTEN_QUEUE (20) define USER_AMOUNT_MAX (50)