C語(yǔ)言詳解UDP通信的實(shí)現(xiàn)

第C語(yǔ)言詳解UDP通信的實(shí)現(xiàn)UDP通信

UDP服務(wù)端創(chuàng)建的socket是直接用來通信的套接字，沒有類似TCP一樣創(chuàng)建一個(gè)監(jiān)聽的socket。

UDP相關(guān)函數(shù)：

注意：send和recv用于TCP;sendto和recvfrom用于UDP。

ssize_tsendto(intsockfd,constvoid*buf,size_tlen,intflags,conststructsockaddr*dest_addr,socklen_taddrlen);

-參數(shù)：

-sockfd:通信的fd

-buf:要發(fā)送的數(shù)據(jù)

-len:發(fā)送數(shù)據(jù)的長(zhǎng)度

-flags:0--一般不會(huì)用它

-dest_addr:通信的另外一端的地址信息

-addrlen:地址的內(nèi)存大小

-返回值：

-成功:返回發(fā)送字節(jié)的數(shù)量

-失敗:-1,并設(shè)置錯(cuò)誤號(hào)

ssize_trecvfrom(intsockfd,void*buf,size_tlen,intflags,structsockaddr*src_addr,socklen_t*addrlen);

-參數(shù)：

-sockfd:通信的fd

-buf:接收數(shù)據(jù)的數(shù)組

-len:數(shù)組的大小

-flags:0

-src_addr:用來保存另外一端的地址信息，不需要可以指定為NULL

-addrlen:地址的內(nèi)存大小

-返回值：

-成功:返回發(fā)送字節(jié)的數(shù)量

-失敗:-1,并設(shè)置錯(cuò)誤號(hào)

UDP客戶端：

//UDP_Client

#includestdio.h

#includestdlib.h

#includeunistd.h

#includestring.h

#includearpa/inet.h

intmain(){

//1.創(chuàng)建一個(gè)通信的socket,注意第二個(gè)參數(shù)是：SOCK_DGRAM，數(shù)據(jù)報(bào)的協(xié)議。

intfd=socket(PF_INET,SOCK_DGRAM,0);

if(fd==-1){

perror("socket");

exit(-1);

//服務(wù)器的地址信息

structsockaddr_insaddr;

saddr.sin_family=AF_INET;

saddr.sin_port=htons(9999);

inet_pton(AF_INET,"127.0.0.1",saddr.sin_addr.s_addr);--地址為服務(wù)器的地址

intnum=0;

//3.通信

while(1){

//發(fā)送數(shù)據(jù)

charsendBuf[128];

sprintf(sendBuf,"hello,iamclient%d\n",num++);

sendto(fd,sendBuf,strlen(sendBuf)+1,0,(structsockaddr*)saddr,sizeof(saddr));

//接收數(shù)據(jù)

intnum=recvfrom(fd,sendBuf,sizeof(sendBuf),0,NULL,NULL);--服務(wù)端默認(rèn)是通過saddr回?cái)?shù)據(jù)，默認(rèn)NULL即可。

printf("serversay:%s\n",sendBuf);

sleep(1);

close(fd);

return0;

}

UDP服務(wù)端：

//UDP_Server

#includestdio.h

#includestdlib.h

#includeunistd.h

#includestring.h

#includearpa/inet.h

intmain(){

//1.創(chuàng)建一個(gè)通信的socket,注意第二個(gè)參數(shù)是：SOCK_DGRAM，數(shù)據(jù)報(bào)的協(xié)議。

intfd=socket(PF_INET,SOCK_DGRAM,0);

if(fd==-1){

perror("socket");

exit(-1);

structsockaddr_inaddr;

addr.sin_family=AF_INET;

addr.sin_port=htons(9999);

addr.sin_addr.s_addr=INADDR_ANY;--服務(wù)器綁定本機(jī)所有的網(wǎng)卡

//2.綁定

intret=bind(fd,(structsockaddr*)addr,sizeof(addr));

if(ret==-1){

perror("bind");

exit(-1);

//3.通信

while(1){

charrecvbuf[128];

charipbuf[16];

structsockaddr_incliaddr;

intlen=sizeof(cliaddr);--用來保存客戶端的地址

//接收數(shù)據(jù)

intnum=recvfrom(fd,recvbuf,sizeof(recvbuf),0,(structsockaddr*)cliaddr,len);

printf("clientIP:%s,Port:%d\n",

inet_ntop(AF_INET,cliaddr.sin_addr.s_addr,ipbuf,sizeof(ipbuf)),

ntohs(cliaddr.sin_port));--ip和端口號(hào),從網(wǎng)絡(luò)字節(jié)序轉(zhuǎn)換成主機(jī)字節(jié)序

//發(fā)送數(shù)據(jù)

sendto(fd,recvbuf,strlen(recvbuf)+1,0,(struct