【正文】 input_flag)。rcv_data, 0, sizeof(rcv_data))。 memset(send_buffer, 0, strlen(send_buffer))。 verify_flag = 0。 } else { printf(It39。 offset += sprintf(printf_buffer+offset,high: %d \n, [2])。 offset+=sprintf(printf_buffer+offset,name:%s\n,(char*)amp。\039。 //加結束符 memcpy(amp。[4], amp。 //age [1] = ucRcvBuf[i+9]。 = ucRcvBuf[i+5]。 } } if(verify_flag == 1) { /**組包**/ = ucRcvBuf[i]。 for(i=0。 close(sockfd)。 g++) printf(%x , send_buffer[g])。 /*打印發(fā)送的數據*/ /*int g。 //頭部為8個字節(jié) send_buffer[5] = 。 send_buffer[0] = 。 } if(input_flag 5) //非法輸入 { printf(input number false, please reinput!\n)。 //保存文件 sleep(1)。 if(file_fd == NULL) { printf(open file fail!\n)。 Datatype rcv_data。 } unsigned char send_buffer[8]。ipt_id,NULL,(void*)amp。 break。 close(sockfd)。 =AF_INET。 return。 return。//globalint input_flag = 6。 long time。/******接收數據結構體******/typedef struct datatype { unsigned char number。 //0 : cmd 1:data 1 unsigned char stop。 //釋放互斥鎖 usleep(1000)。 //printf(%x\n, [j].time)。 //往buffuer里面放入數據 [j].number = information[j].number。 //入隊列 j = 。 continue。 int ret。 pthread_exit((void*)amp。 } else { printf(false package!\n)。 int g=0。[k].time, 4)。 send_buffer[10] = [k].high。 //data send_buffer[6] = 。 memcpy(amp。 //查找數據,組包 for(k=0。 = ucRcvBuf[i+7]。, amp。 i++) //尋找包頭 { if(ucRcvBuf[i] == 0x7E) { verify_flag = 1。 } //free free(pTcpClient)。 printf(client disconnected,ip:%s,port:%d\n, pTcpClientszClientIp, pTcpClientnClientPort)。 close(nRcvSock)。rset)==0) { pTcpClient =pTcpClientpNext。 if(nConnectSocknMaxFd) { nMaxFd =nConnectSock。 } pTempClientpNext =pTcpClient。 printf(client connected,ip:%s,port:%d\n, pTcpClientszClientIp, pTcpClientnClientPort)。 pTcpClientnClientPort =ntohs()。 if(nConnectSock==1) { printf(nConnectSock 1\n)。rset)) // 檢查nListenSock是否在套接字集合中 { printf(accept client!\n)。timeOut)。 //發(fā)送緩存 int verify_flag = 0。 unsigned char ucRcvBuf[100]。 CLIENT_INFO *pTcpClient。allset)。 } } }/*處理客戶端函數*/void serverThreadProc(void *pPram){ int nMaxFd。serverThreadProc,NULL)0) { printf(create server thread fail!\n)。 } //創(chuàng)建客戶端的線程 int nSrvThreadId =1。 return。 =htons(10000)。 memset(amp。nValue,sizeof(int))0) { printf(set option SO_REUSEADDR fail!\n)。 if(nListenSock0) { printf(create listen socket error\n)。 } /*創(chuàng)建線程,產生數據*/ pthread_create(amp。 information[i].age = AGE[i]。 //初始化 互斥鎖 /*初始化數據*/ int i = 0。int buffer_has_item=0。 //server lisen socketint nThreadFlag =0。unsigned char HIGH[5] = {175,174,173,175,165}。 /*初始化隊列*/queue Queue = { .b_tail = 0, .b_head = 0,}。/*創(chuàng)建緩存區(qū)*/typedef struct queue{ Datatype buffer[5]。 //0 : cmd 1:data 1 unsigned char stop。}Datatype。 unsigned char high。 struct _CLIENT_INFO_ *pPre。//鏈表結點結構體typedef struct _CLIENT_INFO_{ char szClientIp[16]。通過本次課程設計，我們創(chuàng)建TCP服務器線程，響應多個客戶端的連接，讀取隊列/數組，向客戶端發(fā)送指定“學號”的數據；創(chuàng)建TCP客戶端接收線程，連接服務器并請求指定“學號”的數據，接收數據并存儲在文件中；在實現的這個過程中，利用數據結構中的隊列構造了數據表，方便程序訪問，同時，也方便服務器端對數據的管理。圖 413 生成文件，內部為請求的信息。 return。 if(pthread_create((pthread_t *)amp。serverAddr, sizeof(serverAddr))==0) { printf(connected\n)。 sockfd =socket(AF_INET,SOCK_STREAM,IPPROTO_TCP)。 return。 if(pthread_create((pthread_t*)amp。 close(nListenSock)。localAddr,sizeof(struct sockaddr))0) { printf(bind liste sock fail!\n)。 =AF_INET。 return。 } //設置socket選項 int nValue=1。writer_function,NULL)。 information[i].high = HIGH[i]。 i5。 //read進程的進程號 pthread_mutex_init(amp。，響應多個客戶端的連接，讀取隊列/數組，向客戶端發(fā)送指定“學號”的數據。源IP地址和目的IP地址以及源端口號和目的端口號的組合稱為套接字。當信號量sem的值大于等于零時，該進程（或線程）具有公共資源的訪問權限；相反，當信號量sem的值小于零時，該進程（或線程）就將阻塞直到信號量sem的值大于等于0為止。信號量本質上是一個非負的整數計數器，它被用來控制對公共資源的訪問。這三種鎖的區(qū)別主要在于其他未占有互斥鎖的線程在希望得到互斥鎖時是否需要阻塞等待。在同一時刻只能有一個線程掌握某個互斥鎖，擁有上鎖狀態(tài)的線程能夠對共享資源進行操作。一個進程可以有多個線程，也就是有多個線程控制表及堆棧寄存器，但卻共享一個用戶地址空間。它是進程內獨立的一條運行路線，處理器調度的最小單元，也可以稱為輕量級進程。此時，連接已經建立完畢，可以相互發(fā)送發(fā)送消息。不過可以通過動態(tài)主機配置協議（DHCP），給客戶端自動分配一個IP地址，這樣避免了出錯也簡化了TCP/IP協議的設置。如果傳輸過程中出現數據丟失、數據失真等情況，TCP協議會自動要求數據重新傳輸并重新組包。，修改PATH環(huán)境變量：sudo vim NFS安裝，可以用于Linux和Linux之間傳遞文件，實現數據共享。最終的目的是熟練掌握網絡編程的編程方法，理解常用的數據結構的基本思想，掌握編程語言，理解多線程編程在實際工程中的應用。創(chuàng)建TCP服務器線程，響應多個客戶端的連接，讀取隊列/數