快捷導(dǎo)航

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

更新時(shí)間：2022年06月14日 15:00:57 作者：阿寧(xin)。

這篇文章主要為大家詳細(xì)介紹了C語(yǔ)言實(shí)現(xiàn)UDP通信，文中示例代碼介紹的非常詳細(xì)，具有一定的參考價(jià)值，感興趣的小伙伴們可以參考一下

UDP通信

UDP是一種無(wú)連接的盡最大努力交付的不可靠連接，通信之前無(wú)需先建立連接，自然而然，通信之后也就無(wú)需再釋放連接。

通信的套接字

UDP所采用的通信接口與前面講過的TCP通信接口相同，只是沒有建立連接這一步。

socket()用來(lái)創(chuàng)建套接字，使用 udp 協(xié)議時(shí)，選擇數(shù)據(jù)報(bào)服務(wù) SOCK_DGRAM。sendto()用來(lái)發(fā)送數(shù)據(jù)，由于 UDP 是無(wú)連接的，每次發(fā)送數(shù)據(jù)都需要指定對(duì)端的地址（IP 和端口）。recvfrom()接收數(shù)據(jù)，每次都需要傳給該方法一個(gè)地址結(jié)構(gòu)來(lái)存放發(fā)送端的地址。

recvfrom()可以接收所有客戶端發(fā)送給當(dāng)前應(yīng)用程序的數(shù)據(jù)，并不是只能接收某一個(gè)客戶端的數(shù)據(jù)

通信流程

通信過程

客戶端

#include <stdio.h>

#include <stdlib.h>
#include <unistd.h>
#include <string.h>
#include <assert.h>
#include <sys/socket.h>
#include <netinet/in.h>
#include <arpa/inet.h>

int main()
{
?? ?int sockfd = socket(AF_INET,SOCK_DGRAM,0);
?? ?assert( sockfd != -1 );

?? ?struct sockaddr_in saddr;
?? ?memset(&saddr,0,sizeof(saddr));
?? ?saddr.sin_family = AF_INET;
?? ?saddr.sin_port = htons(6000);
?? ?saddr.sin_addr.s_addr = inet_addr("127.0.0.1");

?? ?while( 1 )
?? ?{
?? ?char buff[128] = {0};
?? ?printf("input:\n");

?? ?fgets(buff,128,stdin);

?? ?if ( strncmp(buff,"end",3) == 0 )
?? ?{
?? ??? ?break;
?? ?}

?? ?sendto(sockfd,buff,strlen(buff),0,(struct ckaddr*)&saddr,sizeof(saddr));
?? ?memset(buff,0,128);

?? ?int len = sizeof(saddr);
?? ?recvfrom(sockfd,buff,127,0,(struct sockaddr*)&saddr,&len);

?? ?printf("buff=%s\n",buff);
?? ?}

?? ?close(sockfd);

}

服務(wù)器端

#include <stdio.h>
#include <stdlib.h>
#include <unistd.h>
#include <string.h>
#include <assert.h>
#include <sys/socket.h>
#include <netinet/in.h>
#include <arpa/inet.h>

int main()
{
?? ?int sockfd = socket(AF_INET,SOCK_DGRAM,0);
?? ?assert( sockfd != -1 );

?? ?struct sockaddr_in saddr,caddr;
?? ?memset(&saddr,0,sizeof(saddr));
?? ?saddr.sin_family = AF_INET;
?? ?saddr.sin_port = htons(6000);
?? ?saddr.sin_addr.s_addr = inet_addr("127.0.0.1");

?? ?int res = bind(sockfd,(struct sockaddr*)&saddr,sizeof(saddr));
?? ?assert( res != -1 );

?? ?while( 1 )
?? ?{
?? ??? ?int len = sizeof(caddr);
?? ??? ?char buff[128] = {0};
?? ??? ?recvfrom(sockfd,buff,127,0,(struct sockaddr*)&caddr,&len);
?? ??? ?printf("ip:%s,port:%d,buff=%s\n",inet_ntoa(caddr.sin_addr), ntohs(caddr.sin_port),buff );

?? ??? ?sendto(sockfd,"ok",2,0,(struct sockaddr*)&caddr,sizeof(caddr));
?? ?}

?? ?close(sockfd);
}