c語(yǔ)言socket實(shí)現(xiàn)主機(jī)與客戶(hù)端異步通信

服務(wù)器端代碼編寫(xiě)#iiiclude<stdio.h>#iiiclude<wmdows.h>/***定義端口**/#definePORT8888/***定義最大傳輸數(shù)據(jù)量**/#defineMAXDATA100/****在入11函數(shù)中輸入主機(jī)IP地址****/hitaigc,chai**argv){/*定義標(biāo)志，接收到第一個(gè)client時(shí)，不在接收其他client*/intflag=1;/*得到socket嵌套字*/SOCKETserver;/*定義發(fā)送消息的長(zhǎng)度*/intsdMsgLen;/*啟動(dòng)windows的socket服務(wù)*/WSADATAwsaData;WSAStaitup(0x101,&wsaData);chai-*CloseClient=”bve”；chai*CloseC.S="byebye”；/*定義receive數(shù)據(jù)長(zhǎng)度*/intreceive;intlen;/*創(chuàng)建服務(wù)器*/stmctsockaddi_iiiserveraddi;/*創(chuàng)建客戶(hù)端〃stmctsockaddi_iiiaddiClient;/*將serveraddr置零*/meniset((void*)&senreraddi\0,sizeof(senTeraddr));/*定義家族協(xié)議*/senTeraddr.sm_family=AF_INET;/*定義主機(jī)地址*/serveraddr.sin_addr.s_addr=inet_addr(aig\r[1 192.168.1.100"/*定義主機(jī)端口*/senTeraddr.siii_port=htons(PORT);/*得到socket嵌套字*/server=socket(AF_INET,SOCK_STREAM,0);/*返回值為-1,未啟動(dòng)windows的socket服務(wù)*/iRserver==-l)penor(Hsocketerror!");/*綁定成功返回o*/iRbind(server,(structsockaddr*)&seiveraddi\sizeof(servreiaddi))=-1)jperror(”不能進(jìn)行綁定!”)；exit(l);}/*定義客戶(hù)端嵌套字*/SOCKETclient;/*進(jìn)入監(jiān)聽(tīng)客戶(hù)端連接和監(jiān)聽(tīng)客戶(hù)端發(fā)送的消息*/while(l)/*定義并初始化接收數(shù)據(jù)的存儲(chǔ)*/clwieceiveBuffei[MAXDATA]=”\iT;/*定義并初始化發(fā)送數(shù)據(jù)存儲(chǔ)*/chai-sendBuffer[MAXDATA]=七”；/*采用異步發(fā)送消息*/boolsendFlag=false;/*監(jiān)聽(tīng)客戶(hù)端*/if(listen(seiver,20)==-1)(pens(”不能進(jìn)行監(jiān)聽(tīng)!”)；exit⑴；)/*接收到第一個(gè)用戶(hù)后將其鎖定，不在接收其他用戶(hù)*/iRflag)(leu=sizeoRstructsockaddi_m);/*得到客戶(hù)端的嵌套字*/client=accept(seiver,(SOCKADDR*)&addiClient,&len);if(client==-1)(perroi("accepterror");contmue;)prmtf("新連接：%s\iT.inet_ntoa(adckCliEt.sin_addr));/*創(chuàng)建一個(gè)消息*/chai*nisg=HHello,ConnectedSuccessfully!\nK;mtlen=strlen(nisg);/*得到send的返回值，返回為發(fā)送消息的長(zhǎng)度.若發(fā)送失敗則返回-1*/mtsendLen=send(clientjiisgJen.O);if(sendLen==?1)pmor(”消息發(fā)送失敗!\n”);closesocket(client);

)nisg=O;/*接收到第一個(gè)客戶(hù)端，將其鎖定*/flag=0；)/*得到接收到消息的長(zhǎng)度*/receive=recv(clieiit,receiveBufiei;MAXDATA,O);/*若消息長(zhǎng)度為-1,則接收數(shù)據(jù)失敗*/if(receive==-1)(perror(”接收出錯(cuò)!\n”)；/*關(guān)閉客戶(hù)端*/closesocket(client);)pimtf("%s\ii",receiveBuffer);/*測(cè)試客戶(hù)端發(fā)送的結(jié)束通話(huà)標(biāo)志*/if(strcmp(ieceiveBuffer,CloseClient)=0)(piuitf("失去客戶(hù)端:%s\ii,',uiet_ntoa(addiClient.sm_addr));flag=1;closesocket(client);)elseif(sticmp(receiveBufier,CloseC_S)==0)(closesocket(seiver);exit⑴；)else(sendpimtf("Client %ssendmessage:%s\n,,,inet_ntoa(addiClieiit.sm_adclr),ieceiveBuffer);/*當(dāng)接收到消息后，服務(wù)器才可以發(fā)送消息*/sendFlag=tine;)while(sendFlag)(prmtf(HYourMessage:H);/*得到服務(wù)器輸入的字符串*/scanf(n%s,\sendBuffer);sdMsgLen=stilen(sendBuffer);/*得到服務(wù)器發(fā)送消息的長(zhǎng)度*/mtsendLen=send(client,sendBuffei\sdMsgLen,O);if(sendLen==?1)peuor(”消息發(fā)送失敗!”)；closesocket(client);)/*結(jié)束服務(wù)器發(fā)送消息模式，改為接收模式*/sendFlag=false;)}return0;}客戶(hù)端代碼編寫(xiě)#iiiclude<wiiidows.h>#iiiclude<stdio.h>#iiiclude<errno.h>/*定義與主機(jī)連接的端11*/#definePORT8888/*定義最大傳輸數(shù)據(jù)量*/#defineMAXDATA100/*由入11函數(shù)得到需要連接主機(jī)的IP地址*/hitais.chai**arg){/*開(kāi)啟windows的socket*/WSADATAwsaData;WSAStaitup(0x101,&wsaData);/*定義服務(wù)器*/stmctsockaddr_inserveraddr;/*將serveraddr清零*/meniset((void*)&senreraddi\0,sizeof(senTeraddr));/*定義家族協(xié)議*/senTeraddr.siii_family=AF_INET;/*得到主機(jī)IP地址*/serveraddr.sin_addr.s_adck=inet_addr(aig[1])；//)；//)n192.168.1.100H;/*得到端口*/serveraddr.sin_port=htons(PORT);/*得到socket嵌套字*/SOCKETs=socket(AF_INET,SOCK_STREAM,0);*建立TCP連接*參數(shù)1：socket返回的描述符?參數(shù)2：主機(jī)IP地址和端II號(hào)指針?參數(shù)3：遠(yuǎn)端地質(zhì)借II長(zhǎng)度*/if(comiect(s,(stiuctsockaddr*)&serveraddr,sizeof(serveraddi))=-1)/Ipmor(”連接錯(cuò)誤!)exit。)；}/*進(jìn)入監(jiān)聽(tīng)服務(wù)器發(fā)送消息，采取異步通信*/while(l)/*初始化接收和發(fā)送數(shù)據(jù)的存儲(chǔ)*/chai-ieceiveBufIei[MAXDATA]=七”；chai-sendBuffer[MAXDATA]=七“；/*定發(fā)送模式*/boolsendFlag=false;/*如果接收數(shù)據(jù)位-1則接收錯(cuò)誤，正確是recv返回接收到數(shù)據(jù)的長(zhǎng)度*/if(recv(sjeceiveBiifferNIAXDATA,0)==-1)(pen-or("接收數(shù)據(jù)錯(cuò)誤!”)；exit(l);)piintff'server%ssendmessage:%s\ii",uiet_iitoa(servreiacldi.sni_addr),ieceiveBuffer);/*發(fā)送模式*/sendFlag=true;while(sendFlag)(char*CloseClient=HbyeH;char*CloseC_S="byebye”；/*得到輸入的數(shù)據(jù)*/piiiitf(HYourMessage:”)；scanf(,t%s,\sendBufifer);if(strcmp(sendBuffei;CloseClient)==0)(send(s,CloseClient,stilen(CloseClient),0);closesocket(s