新聞中心
在互聯(lián)網(wǎng)時代,無論是數(shù)據(jù)傳輸還是通信都離不開網(wǎng)絡技術,而Linux操作系統(tǒng)作為一款廣泛應用的操作系統(tǒng),其UDP(User Datagram Protocol)數(shù)據(jù)傳輸也成為了網(wǎng)絡中不可缺少的一部分。本文將通過圖解的方式,讓讀者更好地了解Linux中UDP數(shù)據(jù)傳輸?shù)脑砗瓦^程。

成都創(chuàng)新互聯(lián)專注于三元網(wǎng)站建設服務及定制,我們擁有豐富的企業(yè)做網(wǎng)站經驗。 熱誠為您提供三元營銷型網(wǎng)站建設,三元網(wǎng)站制作、三元網(wǎng)頁設計、三元網(wǎng)站官網(wǎng)定制、成都微信小程序服務,打造三元網(wǎng)絡公司原創(chuàng)品牌,更為您提供三元網(wǎng)站排名全網(wǎng)營銷落地服務。
什么是UDP協(xié)議?
UDP協(xié)議是一種無連接的網(wǎng)絡傳輸協(xié)議,它不像TCP那樣需要建立連接,以鏈路為基礎直接進行數(shù)據(jù)傳遞。UDP協(xié)議的特點是傳輸速度快,但可靠性不如TCP協(xié)議,因為它不對傳輸過程進行嚴格控制,只是將數(shù)據(jù)報從源到目的地進行簡單傳輸。因此,很多需要快速傳輸數(shù)據(jù)而對可靠性要求不高的應用程序,如視頻、音頻等,都采用UDP協(xié)議進行傳輸。
UDP協(xié)議的傳輸方式
1. 發(fā)送端利用create_socket()函數(shù)創(chuàng)建套接字,設置套接字參數(shù)。
2. 發(fā)送端利用sendto()函數(shù)將UDP數(shù)據(jù)報發(fā)送給接收端。
3. 接收端利用recvfrom()函數(shù)接收UDP數(shù)據(jù)報。
4. 進程關閉套接字。
UDP數(shù)據(jù)報格式
UDP數(shù)據(jù)報頭部固定占用8個字節(jié),包含以下字段:
源端口:2個字節(jié),表示發(fā)送端口。
目標端口:2個字節(jié),表示接收端口。
總長度:2個字節(jié),表示UDP數(shù)據(jù)報總長度。
校驗和:2個字節(jié),為可選項,可用于驗證UDP數(shù)據(jù)報的完整性。
UDP數(shù)據(jù)報示意圖:
Linux中的UDP傳輸
在Linux中,UDP傳輸也是通過socket進行實現(xiàn)的,其具體過程如下:
1. 創(chuàng)建UDP套接字
首先需要調用socket()函數(shù)創(chuàng)建一個套接字,指定ADDRESS_FAMI為AF_INET(IP協(xié)議族),SOCK_DGRAM為IP協(xié)議類型,最后一個參數(shù)為0,該參數(shù)由系統(tǒng)自動選擇合適的協(xié)議。
2. 綁定套接字
創(chuàng)建好套接字后,需要使用bind()函數(shù)將套接字綁定到本機的IP地址和端口號上。綁定后,即可接收其他主機發(fā)送過來的UDP數(shù)據(jù)報。
3. 發(fā)送UDP數(shù)據(jù)報
使用sendto()函數(shù)向指定目標IP地址和端口號發(fā)送UDP數(shù)據(jù)報,該函數(shù)的參數(shù)包括發(fā)送端套接字、UDP數(shù)據(jù)報內容、UDP數(shù)據(jù)報長度、目標地址和端口號。
4. 接收UDP數(shù)據(jù)報
使用recvfrom()函數(shù)接收發(fā)送端發(fā)送過來的UDP數(shù)據(jù)報,該函數(shù)的參數(shù)包括接收端套接字、接收緩沖區(qū)、緩沖區(qū)長度、接收數(shù)據(jù)報來源的IP地址和端口號。
5. 關閉套接字
使用close()函數(shù)關閉套接字。
Linux UDP傳輸示意圖:
UDP協(xié)議雖然不太可靠,但是由于其傳輸速度快,因此在音視頻、實時游戲等應用場景中應用廣泛。在Linux中,UDP傳輸也是通過socket進行實現(xiàn)的,需要進行套接字的創(chuàng)建、綁定、發(fā)送和接收等操作。了解UDP數(shù)據(jù)報的格式和UDP傳輸過程,對于網(wǎng)絡通信和應用程序開發(fā)非常有幫助。
成都網(wǎng)站建設公司-創(chuàng)新互聯(lián),建站經驗豐富以策略為先導10多年以來專注數(shù)字化網(wǎng)站建設,提供企業(yè)網(wǎng)站建設,高端網(wǎng)站設計,響應式網(wǎng)站制作,設計師量身打造品牌風格,熱線:028-86922220UDP和Socket通信步驟
這是在網(wǎng)上找到的,希望對你有所幫助。
sockets(套接數(shù)神字)編程有三種,流式套接字(SOCK_STREAM),數(shù)據(jù)報套接字(SOCK_DGRAM),原始套接字(SOCK_RAW);
WINDOWS環(huán)境下TCP/UDP編程步驟:
1. 基于褲畢巖TCP的socket編程是采用的流式套接字。
在這個程序中,將兩個工程添加到一個工作區(qū)。要鏈接一個ws2_32.lib的庫文件。
服務器端編程的步驟:
1:加載套接字庫,創(chuàng)建套接字(WSAStartup()/socket());
2:綁定套接字到一個IP地址和一個端口上(bind());
3:將套接字設置為監(jiān)聽模式等待連接請求(listen());
4:請求到來后,接受連接請求,返回一個新的對應于此次連接的套接字(accept());
5:用返回的套接字和客戶端進行通信(send()/recv());
6:返回,等待另一連接請求;
7:關閉套接字,關閉加載的套接字庫(closesocket()/WSACleanup())。
服務器端代碼如下:
#include
#include
void main()
{
WORD wVersionRequested;
WSADATA wsaData;
int err;
wVersionRequested = MAKEWORD( 1, 1 );
err = WSAStartup( wVersionRequested, &wsaData );
if ( err != 0 ) {
return;
}
if ( LOBYTE( wsaData.wVersion ) != 1 ||
HIBYTE( wsaData.wVersion ) != 1 ) {
WSACleanup( );
return;
}
SOCKET sockSrv=socket(AF_INET,SOCK_STREAM,0);
SOCKADDR_IN addrSrv;
addrSrv.sin_addr.S_un.S_addr=htonl(INADDR_ANY);
addrSrv.sin_family=AF_INET;
addrSrv.sin_port=htons(6000);
bind(sockSrv,(SOCKADDR*)&addrSrv,sizeof(SOCKADDR));
listen(sockSrv,5);
SOCKADDR_IN addrClient;
int len=sizeof(SOCKADDR);
while(1)
{
SOCKET sockConn=accept(sockSrv,(SOCKADDR*)&addrClient,&len);
char sendBuf;
sprintf(sendBuf,”Welcome %s to here!”,inet_ntoa(addrClient.sin_addr));
send(sockConn,sendBuf,strlen(sendBuf)+1,0);
char recvBuf;
recv(sockConn,recvBuf,50,0);
printf(“%s\n”,recvBuf);
closesocket(sockConn);
}
}
客戶端編程的步驟:
1:加載套接字庫,創(chuàng)建套接字(WSAStartup()/socket());
2:向服務器發(fā)出胡御連接請求(connect());
3:和服務器端進行通信(send()/recv());
4:關閉套接字,關閉加載的套接字庫(closesocket()/WSACleanup())。
客戶端的代碼如下:
#include
#include
void main()
{
WORD wVersionRequested;
WSADATA wsaData;
int err;
wVersionRequested = MAKEWORD( 1, 1 );
err = WSAStartup( wVersionRequested, &wsaData );
if ( err != 0 ) {
return;
}
if ( LOBYTE( wsaData.wVersion ) != 1 ||
HIBYTE( wsaData.wVersion ) != 1 ) {
WSACleanup( );
return;
}
SOCKET sockClient=socket(AF_INET,SOCK_STREAM,0);
SOCKADDR_IN addrSrv;
addrSrv.sin_addr.S_un.S_addr=inet_addr(“127.0.0.1”);
addrSrv.sin_family=AF_INET;
addrSrv.sin_port=htons(6000);
connect(sockClient,(SOCKADDR*)&addrSrv,sizeof(SOCKADDR));
char recvBuf;
recv(sockClient,recvBuf,50,0);
printf(“%s\n”,recvBuf);
send(sockClient,”hello”,strlen(“hello”)+1,0);
closesocket(sockClient);
WSACleanup();
}
2.基于UDP的socket編程是采用的數(shù)據(jù)報套接字。
在這個程序中,將兩個工程添加到一個工作區(qū)。同時還要鏈接一個ws2_32.lib的庫文件。
服務器端編程的步驟:
1:加載套接字庫,創(chuàng)建套接字(WSAStartup()/socket());
2:綁定套接字到一個IP地址和一個端口上(bind());
3:等待和接收數(shù)據(jù)(sendto()/recvfrom());
4:關閉套接字,關閉加載的套接字庫(closesocket()/WSACleanup())。
服務器端代碼如下:
#include
#include
void main()
{
WORD wVersionRequested;
WSADATA wsaData;
int err;
wVersionRequested = MAKEWORD( 1, 1 );
err = WSAStartup( wVersionRequested, &wsaData );
if ( err != 0 )
{
return;
}
if ( LOBYTE( wsaData.wVersion ) != 1 ||
HIBYTE( wsaData.wVersion ) != 1 )
{
WSACleanup( );
return;
}
SOCKET sockSrv=socket(AF_INET,SOCK_DGRAM,0);
SOCKADDR_IN addrSrv;
addrSrv.sin_addr.S_un.S_addr=htonl(INADDR_ANY);
addrSrv.sin_family=AF_INET;
addrSrv.sin_port=htons(7003);
bind(sockSrv,(SOCKADDR*)&addrSrv,sizeof(SOCKADDR));
char recvBuf;
SOCKADDR addrClient;
int len=sizeof(SOCKADDR);
recvfrom(sockSrv,recvBuf,50,0,(SOCKADDR*)&addrClient,&len);
printf(“%s\n”,recvBuf);
closesocket(sockSrv);
WSACleanup();
}
對于基于UDP的socket客戶端來說,要進行如下步驟:
1:創(chuàng)建一個套接字(socket);
2:向服務器發(fā)送數(shù)據(jù)(sendto);
3:關閉套接字;
代碼如下:
#include
#include
void main()
{
WORD wVersionRequested;
WSADATA wsaData;
int err;
wVersionRequested = MAKEWORD( 2, 2 );
err = WSAStartup( wVersionRequested, &wsaData );
if ( err != 0 ) {
return;
}
if ( LOBYTE( wsaData.wVersion ) != 2 ||
HIBYTE( wsaData.wVersion ) != 2 ) {
WSACleanup( );
return;
}
SOCKET sockClient=socket(AF_INET,SOCK_DGRAM,0);
SOCKADDR_IN addrClient;
addrClient.sin_addr.S_un.S_addr=inet_addr(“127.0.0.1”);
addrClient.sin_family=AF_INET;
addrClient.sin_port=htons(8889);
SOCKADDR_IN addrSrv;
sendto(sockClient,”hi”,3,0,(SOCKADDR*)&addrClient,sizeof(SOCKADDR));
}
LINUX環(huán)境下TCP/UDP編程步驟:
TCP編程步驟:
一. 服務端:
1.socket(int domain,int type,int protocol):建立套接字;
2 .bind(int sockid,struct sockaddr *addrp,socklen_t addrlen):把本機地址和端口跟上一步建立的socket綁定在一起;
3.listen(int sockid,int qsize):監(jiān)聽某套接字;
4.fd=accept(int sockid,struct sockaddr *callerid,socklen_t *addrlenp):等待某套接字接收信息;
5.recv(int fd,void *buf,size_t nbytes,int flags):從套接字接收數(shù)據(jù);
6.close(fd) 和close(sockid)
二.客戶端:
1. socket():建立套接字;
2.connect(int sockid,struct sockaddr *serv_addrp,socklen_t addrlen):連接到服務器;
3. send(int sockfd,const void *buf,size_t nbytes,int flags):發(fā)送數(shù)據(jù)到服務器.
4. close(sockid);
UDP編程步驟:
一,服務端:
1. socket():同上;
2. bind():同上;
3. recvfrom(int sockfd,void*buff,size_t nbytes,int flags,struct sockaddr*from,socklen_t*addrlen):在套接字口接收數(shù)據(jù),并且記錄下接收到的數(shù)據(jù)來源;一定要注意這里的參數(shù)addrlen,它不僅是函數(shù)的輸出,也是函數(shù)的輸入!所以要在調用該函數(shù)之前對addrlen賦值sizeof(struct sockaddr)。否則返回的地址from將會出錯!
4. close(sockfd);
二. 客戶端:
1. socket();同上;
2. sendto(int sockfd,const void*buff,size_t nbytes,int flags,const struct sockaddr*to,socklen_t addrlen):往指定的地址發(fā)送數(shù)據(jù);
3. close(sockfd);
UDP Server程序
1、編寫UDP Server程序的步驟
(1)使用socket()來建立一個UDP socket,第二個參數(shù)為SOCK_DGRAM。
(2)初始化sockaddr_in結構的變量,并賦值。sockaddr_in結構定義:
struct sockaddr_in {
uint8_t sin_len;
sa_family_t sin_family;
in_port_t sin_port;
struct in_addr sin_addr;
char sin_zero;
};
這里使用“08”作為服務程序的端口,使用“INADDR_ANY”作為姿凱綁定的IP地址即任何主機上的地址。
(3)使用bind()把上面的socket和定義的IP地址和端口綁定。這里檢查bind()是否執(zhí)行成功,如果有錯誤就退出。這樣可以防止服務程序重復運行的問題。
(4)進入無限循環(huán)程序,使用recvfrom()進入等待狀態(tài),直到接收到客戶程序發(fā)送的數(shù)據(jù),就處理收到的數(shù)據(jù),并向客戶程序發(fā)送反饋。這里是直接把收到的數(shù)據(jù)發(fā)回給客戶程序。
2、udpserv.c程序內容:
#include
#include
#include
#include
#include
#include
#define MAXLINE 80
#define SERV_PORT 8888
void do_echo(int sockfd, struct sockaddr *pcliaddr, socklen_t clilen)
{
int n;
socklen_t len;
char mesg;
for(;;)
{
len = clilen;
/* waiting for receive data */
n = recvfrom(sockfd, mesg, MAXLINE, 0, pcliaddr, &len);
/* sent data back to client */
sendto(sockfd, mesg, n, 0, pcliaddr, len);
}
}
int main(void)
{
int sockfd;
struct sockaddr_in servaddr, cliaddr;
sockfd = socket(AF_INET, SOCK_DGRAM, 0); /* create a socket */
/* init servaddr */
bzero(&servaddr, sizeof(servaddr));
servaddr.sin_family = AF_INET;
servaddr.sin_addr.s_addr = htonl(INADDR_ANY);
servaddr.sin_port = htons(SERV_PORT);
/* bind address and port to socket */
if(bind(sockfd, (struct sockaddr *)&servaddr, sizeof(servaddr)) == -1)
{
perror(“bind error”);
exit(1);
}
do_echo(sockfd, (struct sockaddr *)&cliaddr, sizeof(cliaddr));
return 0;
}
UDP Client程序
1、編寫UDP Client程序的步驟
(1)初始化sockaddr_in結構舉冊伍的變量,并賦值。這里使用“8888”作為連接的服務程序的端口,從命令行參數(shù)讀取IP地址,并且判斷IP地址是否符合要求。
(2)使用socket()來建立一個UDP socket,第二個參數(shù)為SOCK_DGRAM。
(3)使用connect()來建立與服務程序的連接。與TCP協(xié)議不同,UDP的connect()并沒有與服務程序三次握手。上面我們說了UDP是非連接的,實際上也可以是連接的。使用連接的UDP,kernel可以直接返回錯誤信息給用戶程序,從而避免由于沒有接收到數(shù)據(jù)而導致調用recvfrom()一直等待下去,看上去好像客戶程序沒有反應一樣。
(4)向服務程序發(fā)送數(shù)據(jù),因為使用連接的UDP,所以使用write()來替代sendto()。這里的數(shù)據(jù)直接從標準輸入讀取用戶輸入。正或
(5)接收服務程序發(fā)回的數(shù)據(jù),同樣使用read()來替代recvfrom()。
(6)處理接收到的數(shù)據(jù),這里是直接輸出到標準輸出上。
2、udpclient.c程序內容:
#include
#include
#include
#include
#include
#include
#include
#include
#define MAXLINE 80
#define SERV_PORT 8888
void do_cli(FILE *fp, int sockfd, struct sockaddr *pservaddr, socklen_t servlen)
{
int n;
char sendline, recvline;
/* connect to server */
if(connect(sockfd, (struct sockaddr *)pservaddr, servlen) == -1)
{
perror(“connect error”);
exit(1);
}
while(fgets(sendline, MAXLINE, fp) != NULL)
{
/* read a line and send to server */
write(sockfd, sendline, strlen(sendline));
/* receive data from server */
n = read(sockfd, recvline, MAXLINE);
if(n == -1)
{
perror(“read error”);
exit(1);
}
recvline = 0; /* terminate string */
fputs(recvline, stdout);
}
}
int main(int argc, char **argv)
{
int sockfd;
struct sockaddr_in srvaddr;
/* check args */
if(argc != 2)
{
printf(“usage: udpclient \n”);
exit(1);
}
/* init servaddr */
bzero(&servaddr, sizeof(servaddr));
servaddr.sin_family = AF_INET;
servaddr.sin_port = htons(SERV_PORT);
if(inet_pton(AF_INET, argv, &servaddr.sin_addr)
{
printf(” is not a valid IPaddress\n”, argv);
exit(1);
}
sockfd = socket(AF_INET, SOCK_DGRAM, 0);
do_cli(stdin, sockfd, (struct sockaddr *)&servaddr, sizeof(servaddr));
return 0;
}
運行例子程序
1、編譯例子程序
使用如下命令來編譯例子程序:
gcc -Wall -o udpserv udpserv.c
gcc -Wall -o udpclient udpclient.c
編譯完成生成了udpserv和udpclient兩個可執(zhí)行程序。
2、運行UDP Server程序
執(zhí)行./udpserv &命令來啟動服務程序。我們可以使用netstat -ln命令來觀察服務程序綁定的IP地址和端口,部分輸出信息如下:
Active Internet connections (only servers)
Proto Recv-Q Send-Q Local Address Foreign Address State
tcp 0 0 0.0.0.0:.0.0.0:* LISTEN
tcp 0 0 0.0.0.0:111 0.0.0.0:* LISTEN
tcp 0 0 0.0.0.0:6000 0.0.0.0:* LISTEN
tcp.0.0.1:631 0.0.0.0:* LISTEN
udp 0 0 0.0.0.0:.0.0.0:*
udp 0 0 0.0.0.0:8888 0.0.0.0:*
udp 0 0 0.0.0.0:111 0.0.0.0:*
udp 0 0 0.0.0.0:882 0.0.0.0:*
可以看到udp處有“0.0.0.0:8888”的內容,說明服務程序已經正常運行,可以接收主機上任何IP地址且端口為8888的數(shù)據(jù)。
如果這時再執(zhí)行./udpserv &命令,就會看到如下信息:
bind error: Address already in use
說明已經有一個服務程序在運行了。
3、運行UDP Client程序
執(zhí)行./udpclient 127.0.0.1命令來啟動客戶程序,使用127.0.0.1來連接服務程序,執(zhí)行效果如下:
Hello, World!
Hello, World!
this is a test
this is a test
^d
輸入的數(shù)據(jù)都正確從服務程序返回了,按ctrl+d可以結束輸入,退出程序。
如果服務程序沒有啟動,而執(zhí)行客戶程序,就會看到如下信息:
$ ./udpclient 127.0.0.1
test
read error: Connection refused
說明指定的IP地址和端口沒有服務程序綁定,客戶程序就退出了。這就是使用connect()的好處,注意,這里錯誤信息是在向服務程序發(fā)送數(shù)據(jù)后收到的,而不是在調用connect()時。如果你使用tcpdump程序來抓包,會發(fā)現(xiàn)收到的是ICMP的錯誤信息。
成都創(chuàng)新互聯(lián)科技公司主營:網(wǎng)站設計、網(wǎng)站建設、小程序制作、成都軟件開發(fā)、網(wǎng)頁設計、微信開發(fā)、成都小程序開發(fā)、網(wǎng)站制作、網(wǎng)站開發(fā)等業(yè)務,是專業(yè)的成都做小程序公司、成都網(wǎng)站建設公司、成都做網(wǎng)站的公司。創(chuàng)新互聯(lián)公司集小程序制作創(chuàng)意,網(wǎng)站制作策劃,畫冊、網(wǎng)頁、VI設計,網(wǎng)站、軟件、微信、小程序開發(fā)于一體。
新聞名稱:圖解LinuxUDP數(shù)據(jù)傳輸(linuxudp如何傳輸數(shù)據(jù)圖解)
瀏覽地址:http://www.5511xx.com/article/ccosipj.html


咨詢
建站咨詢
