【正文】 } }39。 while(1) { scanf(%d, amp。 } return。 memset(amp。 memset(amp。 } memset(ucRcvBuf, 0, strlen(ucRcvBuf))。 = 0。 } i = 0。s not data package!\n)。 printf(imformation:\n\r%s, printf_buffer)。 offset += sprintf(printf_buffer+offset,weigh: %d \n, [3])。 offset += sprintf(printf_buffer+offset, age: %d \n, [1])。[8])。 } if( == 1) { int offset = 0。 //加結(jié)束符 //printf(name is %s \n, (char *)amp。 [] =39。[8], amp。\039。ucRcvBuf[i+12], 4)。 //weigh memcpy(amp。 //number [2] = ucRcvBuf[i+10]。 [0] = ucRcvBuf[i+8]。 = ucRcvBuf[i+6]。ucRcvBuf[i+1], 4)。 memcpy(amp。 break。 inLen。 else //接收成功 { /**/ //printf(2\n)。 return。 if(nLen 0) //接收失敗 { //disconnected printf(disconnected\n)。 */ int nLen =recv(sockfd,ucRcvBuf,sizeof(ucRcvBuf),MSG_NOSIGNAL)。 g8。 printf(send data:\n)。 send(sockfd, send_buffer, 8, MSG_NOSIGNAL)。 //控制信息 send_buffer[6] = 。package_lenth, 4)。 memcpy(amp。 } int package_lenth = 8。 sleep(2)。 break。 //每次循環(huán)等待1秒 if(input_flag == 0) //停止 { sleep(1)。 . fclose(file_fd)。 return。 file_fd = fopen(./,w+)。 sleep(1)。 Pro_package rcv_package。 unsigned char ucRcvBuf[60]。 return。input,NULL)0) { printf(create input thread fail!\n)。 if(pthread_create((pthread_t *)amp。 } sleep(1)。serverAddr, sizeof(serverAddr))==0) { printf(connected\n)。 return。)=0) { printf(input wrong server addr\n)。 =htons(atoi(argv[2]))。serverAddr,0x0,sizeof(struct sockaddr_in))。 } //connect struct sockaddr_in serverAddr。 if(sockfd0) { printf(socket create error\n)。 } //create socket int sockfd=1。void main(int argc, char** argv){ if(argc!=3) { printf(%s: dest ip address dest port\n, argv[0])。void input()。/*標(biāo)準(zhǔn)包*/Pro_package test_package={ .head = 0x7E, .lenth = 8, .flag = 0, .stop = 1,}。 char *name。 unsigned char weigh。 unsigned char age。 //數(shù)據(jù)部分 }Pro_package。 //0 stop 1:send 1 unsigned char num。 //包的數(shù)據(jù)部分長(zhǎng)度 4 unsigned char flag。 }}附錄二 客戶端程序/********************************************文件名: 文件描述: 嵌入式課程設(shè)計(jì)程序完成日期:2017年9月8日作者：陳凱聯(lián)系方式：975500487********************************************/include include sys/include sys/include arpa/include include include /****協(xié)議包結(jié)構(gòu)****/typedef struct pro_package{ char head。mutex)。 [j].name= information[j].name。 [j].time = 。 [j].high = information[j].high。 [j].age= information[j].age。 if(j == 1) j = 4。 //獲取互斥鎖 0 = ( + 1)%5。 } pthread_mutex_lock(amp。//獲取系統(tǒng)時(shí)間 if(ret 0) { printf(get sys time fail!\n)。 while(1) { ret = gettimeofday(amp。} /*生產(chǎn)函數(shù)*/void writer_function(void) { int j=0。nRetVal)。 } } } int nRetVal=1。 } verify_flag = 0。 } } } else printf(not cmd package!\n)。 memset(amp。 send(nRcvSock,send_buffer,sen_long,MSG_NOSIGNAL)。 memcpy(amp。send_buffer[12], amp。 send_buffer[11] = [k].weigh。 send_buffer[9] = [k].age。 send_buffer[7] = 。 //頭部為8個(gè)字節(jié) send_buffer[5] = 1。send_buffer[1], amp。 //包總長(zhǎng)度 //包頭部分 send_buffer[0] = 。k5。 if( == 0) { int k=0。 //不需要數(shù)據(jù) i = 0。 = ucRcvBuf[i+6]。ucRcvBuf[i+1], 4)。 memcpy(amp。 break。 inLen。 } else //對(duì)客戶端請(qǐng)求進(jìn)行組包 { int i。 } if(pTcpClientpNext!=NULL) { pTcpClientpNextpPre =pTcpClientpPre。 //del the client from list if(pTcpClientpPre!=NULL) { pTcpClientpPrepNext =pTcpClientpNext。allset)。 pTcpClientnClientSock =1。 if(nLen=0) //如果接收數(shù)據(jù)失敗 { //client disconnected if(nRcvSock!=1) { shutdown(nRcvSock,SHUT_RDWR)。 continue。 if(FD_ISSET(nRcvSock,amp。 } } else //對(duì)客戶端的服務(wù) { //find the client pTcpClient =pClientHead。allset)。 pTcpClientpPre =pTempClient。 while(pTempClientpNext!=NULL) { pTempClient =pTempClientpNext。 if(pClientHead==NULL) { pClientHead= pTcpClient。 pTcpClientpPre =NULL。 strcpy(pTcpClientszClientIp,inet_ntoa())。 pTcpClientnClientSock =nConnectSock。 continue。nAddrSize)。 int nConnectSock =accept(nListenSock,(stru