Linux IPC udp/ip socket 編程

模型

#include #include #include #include #include //服務(wù)器: socket() //創(chuàng)建socket struct sockaddr_in //準(zhǔn)備通信地址bind() //綁定socket和addr sendto()/recvfrom //進(jìn)行通信close() //關(guān)閉socket//客戶(hù)端:socket() //創(chuàng)建socket://準(zhǔn)備通信地址:服務(wù)器的地址sendto()/recv() //進(jìn)行通信:close() //關(guān)閉socket:

socket()

//創(chuàng)建網(wǎng)絡(luò)端點(diǎn)，返回socket文件描述符，失敗返回-1設(shè)errnoint socket(int domain, int type, int protocol);

domain?:協(xié)議族(protocol family)(網(wǎng)絡(luò)通訊(IP)還是本地通訊(xxx.socket))

• AF_INET用于實(shí)現(xiàn)給予ipv4網(wǎng)絡(luò)協(xié)議的網(wǎng)絡(luò)協(xié)議
  type?:協(xié)議(TCP還是UDP)
• SOCK_DGRAM?//數(shù)據(jù)報(bào)套接字, 實(shí)現(xiàn)包括但不限于UDP協(xié)議, which is不可靠,無(wú)連接的數(shù)據(jù)報(bào)通信方
  protocol: 特殊協(xié)議, 一般給0

準(zhǔn)備通信地址:

struct sockaddr{ //主要用于函數(shù)的形參類(lèi)型, 很少定義結(jié)構(gòu)體變量使用, 叫做通用的通信地址類(lèi)型//$man bind sa_family_t sa_family; char sa_data[14];}struct sockaddr_in{ //準(zhǔn)備網(wǎng)絡(luò)通信的通信地址 //$man in.h sa_family_t sin_family; //協(xié)議族, 就是socket()的domain的AF_INET in_port_t sin_port; //端口號(hào) struct in_addr sin_addr; //IP地址， //當(dāng)前網(wǎng)段的最大ip地址是廣播地址，即，xxx.xxx.xxx.255。 //255.255.255.255在所有網(wǎng)段都是廣播地址}struct in_addr{ in_addr_t s_addr; //整數(shù)類(lèi)型的IP地址}

bind()

//把通信地址和socket文件描述符綁定，用在服務(wù)器端，成功返回0,失敗返回-1設(shè)errnoint bind(int sockfd, const struct sockaddr *addr, socklen_t addrlen);

sockfd: socket文件的fd(returned by socket())
addr: 需要強(qiáng)制類(lèi)型轉(zhuǎn)換成socketaddr_un或soketaddr_in, 參見(jiàn)上
addrlen: 通信地址的大小, 使用sizeof();

sendto()

//向指定的socket和相應(yīng)的地址發(fā)送消息，成功返回實(shí)際發(fā)送數(shù)據(jù)的大小，失敗返回-1設(shè)errnossize_t sendto(int sockfd, const void *buf, size_t len, int flags, const struct sockaddr *dest_addr, socklen_t addrlen);

dest_addr:目標(biāo)地址(收件人信息)
addrlen: 目標(biāo)地址的大小

ANote

• send(sockfd, buf, len, flags);等價(jià)于 sendto(sockfd, buf, len, flags, NULL, 0);
• recv()/ send()表示通過(guò)sockfd收發(fā)數(shù)據(jù), 因?yàn)閠cp下, 收發(fā)之前sockfd已經(jīng)和相應(yīng)的地址連接了,所以不需要指定收發(fā)誰(shuí)的/給誰(shuí), 但是udp因?yàn)槭瞻l(fā)時(shí)沒(méi)有連接, 所以需要指定

recvfrom()

//從指定的socket和相應(yīng)的地址接受消息，并提供來(lái)電顯示的功能，成功返回實(shí)際接收的數(shù)據(jù)大小，失敗返回-1設(shè)errnossize_t recvfrom(int sockfd, void *buf, size_t len, int flags, struct sockaddr *src_addr, socklen_t *addrlen);

src_addr: 結(jié)構(gòu)體指針, 用于保存數(shù)據(jù)發(fā)送方的通信地址
addrlen: 指針類(lèi)型, 用于保存發(fā)送方的地址大小

Note:

• recv(sockfd, buf, len, flags); 等價(jià)于 recvfrom(sockfd, buf, len, flags, NULL, 0);
• accept() and recvfrom() 后面的參數(shù)是用來(lái)提供來(lái)電顯示的
• 一個(gè)server對(duì)應(yīng)多個(gè)client
• server可以不知道client的地址, 但是client得知道server的地址
• send data 一定要知道對(duì)方地址
• receive data不需要知道對(duì)方地址
• TCP/IP的socket都是SOCK_STREAM的，全程連接，通過(guò)socket就能找到對(duì)方地址， send data的話(huà)，直接丟給socket就行
• UDP/IP的socket是SOCK_DGRAM的，不全程連接，不能通過(guò)socket找到對(duì)方，send data的話(huà)，server中需要使用recvfrom()來(lái)知道client的地址, 所以肯定要sendto()；client本來(lái)就知道server的地址, 直接sendto()
• recvfrom()的唯一意義就是在udp-server中配合sendto()使用
• 因?yàn)椴荒芡ㄟ^(guò)socket找到對(duì)方, 只要是udp發(fā)消息, 就得通過(guò)sendto()

例子-一對(duì)一的upd/ip協(xié)議的服務(wù)器模型

//udp/ip server 五步走#include#include#include#include#include#include#includeint main(){ //1. 創(chuàng)建socket int sockfd=socket(AF_INET,SOCK_DGRAM,0); if(-1==sockfd) perror("socket"),exit(-1); //2. 準(zhǔn)備通信地址 struct sockaddr_in addr; addr.sin_family=AF_INET; addr.sin_port=htons(8888); addr.sin_addr.s_addr=inet_addr("176.43.11.211"); //3. 綁定socket和通信地址 int res=bind(sockfd,(struct sockaddr*)&addr,sizeof(addr)); if(-1==res) perror("bind"),exit(-1); printf("bind success\n"); //4. 進(jìn)行通信 char buf[100]={0}; struct sockaddr_in recv_addr; //為使用recvfrom得到client地址做準(zhǔn)備, 最終為sendto()做準(zhǔn)備 socklen_t len=sizeof(recv_addr); res=recvfrom(sockfd,buf,sizeof(buf),0,(struct sockaddr*)&recv_addr,&len); if(-1==res) perror("recvfrom"),exit(-1); char* ip=inet_ntoa(recv_addr.sin_addr); //將recvfrom獲得client地址轉(zhuǎn)換成點(diǎn)分十進(jìn)制字符串 printf("data received from client :%s is:%d\n",ip,res); res=sendto(sockfd,"I received",sizeof("I received"),0,(struct sockaddr*)&recv_addr,len);//使用recvfrom獲得的client地址 if(-1==res) perror("sendto"),exit(-1); //5. 關(guān)閉socket res=close(sockfd); if(-1==res) perror("close"),exit(-1); printf("close success\n"); return 0;}

//udp/ip client#include#include#include //close()#include#include#include#includeint main(){ int sockfd=socket(AF_INET,SOCK_DGRAM,0); if(-1==sockfd) perror("socket"),exit(-1); printf("create socket succesfully\n"); struct sockaddr_in addr; addr.sin_family=AF_INET; addr.sin_port=htons(8888); addr.sin_addr.s_addr=inet_addr("176.43.11.211"); //這個(gè)是server的地址, 雖然沒(méi)有connect, which means 不能通過(guò)socket找到這個(gè)地址, 但是我們還是知道這個(gè)地址的, sendto()是可以直接用的 int res=sendto(sockfd,"hello",sizeof("hello"),0,(struct sockaddr*)&addr,sizeof(addr)); if(-1==res) perror("sendto"),exit(-1); printf("data sent size:%d\n",res); char buf[100]={0}; res=recv(sockfd,buf,sizeof(buf),0); if(-1==res) perror("recv"),exit(-1); printf("data received from server:%s\n",buf); res=close(sockfd); if(-1==res) perror("close"),exit(-1); return 0;}