【正文】 { printf(accept client!\n)。clientAddr,amp。 if(nConnectSock==1) { printf(nConnectSock 1\n)。 } //保存客戶端的信息 pTcpClient =(CLIENT_INFO*)malloc(sizeof(CLIENT_INFO))。 pTcpClientnClientPort =ntohs()。 pTcpClientpNext =NULL。 printf(client connected,ip:%s,port:%d\n, pTcpClientszClientIp, pTcpClientnClientPort)。 } else { pTempClient =pClientHead。 } pTempClientpNext =pTcpClient。 } //update fd set FD_SET(nConnectSock,amp。 if(nConnectSocknMaxFd) { nMaxFd =nConnectSock。 while(pTcpClient!=NULL) { int nRcvSock =pTcpClientnClientSock。rset)==0) { pTcpClient =pTcpClientpNext。 } //從客戶端接收數(shù)據(jù),需要修改 int nLen =recv(nRcvSock,ucRcvBuf,sizeof(ucRcvBuf),MSG_NOSIGNAL)。 close(nRcvSock)。 } //del this client info FD_CLR(nRcvSock,amp。 printf(client disconnected,ip:%s,port:%d\n, pTcpClientszClientIp, pTcpClientnClientPort)。 } else { pClientHead =pTcpClientpNext。 } //free free(pTcpClient)。 for(i=0。 i++) //尋找包頭 { if(ucRcvBuf[i] == 0x7E) { verify_flag = 1。 } } if(verify_flag == 1) { /**組包**/ = ucRcvBuf[i]。, amp。 = ucRcvBuf[i+5]。 = ucRcvBuf[i+7]。 //i清0 int g。 //查找數(shù)據(jù),組包 for(k=0。k++) { if([k].number == ) //如果數(shù)字匹配 { int sen_long = 8+8+strlen([k].name)。 memcpy(amp。sen_long, 4)。 //data send_buffer[6] = 。 //數(shù)據(jù)部分 send_buffer[8] = [k].number。 send_buffer[10] = [k].high。 memcpy(amp。[k].time, 4)。send_buffer[16],[k].name,strlen([k].name))。 int g=0。[k], 0, sizeof([k]))。 } else { printf(false package!\n)。 } pTcpClient =pTcpClientpNext。 pthread_exit((void*)amp。 return。 int ret。sys_time,NULL)。 continue。mutex)。 //入隊列 j = 。 //printf(生產(chǎn)者： 生產(chǎn)一件產(chǎn)品！\n)。 //往buffuer里面放入數(shù)據(jù) [j].number = information[j].number。 [j].weigh = information[j].weigh。 //printf(%x\n, [j].time)。 pthread_mutex_unlock(amp。 //釋放互斥鎖 usleep(1000)。 //開始標志為 設定為0x7E 1 int lenth。 //0 : cmd 1:data 1 unsigned char stop。 //標明發(fā)送信息 1 unsigned char data[40]。/******接收數(shù)據(jù)結構體******/typedef struct datatype { unsigned char number。 unsigned char high。 long time。}Datatype。//globalint input_flag = 6。char printf_buffer[300]。 return。 sockfd =socket(AF_INET,SOCK_STREAM,IPPROTO_TCP)。 return。 memset(amp。 =AF_INET。 if(inet_pton(AF_INET,argv[1], amp。 close(sockfd)。 } while(1) //建立鏈接 { if(connect(sockfd, (struct sockaddr*)amp。 break。 } //創(chuàng)建交互線程 pthread_t ipt_id。ipt_id,NULL,(void*)amp。 close(ipt_id)。 } unsigned char send_buffer[8]。 int i,verify_flag。 Datatype rcv_data。 while(1) { //打開文本文件 FILE* file_fd。 if(file_fd == NULL) { printf(open file fail!\n)。 } int count = fprintf(file_fd, %s, (char *)printf_buffer)。 //保存文件 sleep(1)。 printf(client stop recv!\n)。 } if(input_flag 5) //非法輸入 { printf(input number false, please reinput!\n)。 continue。 send_buffer[0] = 。send_buffer[1], amp。 //頭部為8個字節(jié) send_buffer[5] = 。 send_buffer[7] = (char)input_flag。 /*打印發(fā)送的數(shù)據(jù)*/ /*int g。 for(g=0。 g++) printf(%x , send_buffer[g])。 //printf(len :%d\n, nLen)。 close(sockfd)。 } else if (nLen == 0) // continue。 for(i=0。 i++) //尋找包頭 { if(ucRcvBuf[i] == 0x7E) { verify_flag = 1。 } } if(verify_flag == 1) { /**組包**/ = ucRcvBuf[i]。, amp。 = ucRcvBuf[i+5]。 = ucRcvBuf[i+7]。 //age [1] = ucRcvBuf[i+9]。 //high [3] = ucRcvBuf[i+11]。[4], amp。 //printf(time ls %d ) //[8] =39。 //加結束符 memcpy(amp。ucRcvBuf[i+16], )。\039。[4])。 offset+=sprintf(printf_buffer+offset,name:%s\n,(char*)amp。 offset += sprintf(printf_buffer+offset, number: %d \n, [0])。 offset += sprintf(printf_buffer+offset,high: %d \n, [2])。 offset += sprintf(printf_buffer+offset, time: %ld \n, / (long)([4] | [5]8 | / [6]16 | [7]24))。 } else { printf(It39。 continue。 verify_flag = 0。 nLen = 0。 memset(send_buffer, 0, strlen(send_buffer))。rcv_package, 0, sizeof(rcv_package))。rcv_data, 0, sizeof(rcv_data))。}/*等待用戶按鍵輸入線程*/void input(){ int cmd。input_f