建站
咨詢
售后
建站咨詢
新聞中心
在Linux操作系統(tǒng)中，網(wǎng)絡(luò)編程是非常重要的一部分。而網(wǎng)絡(luò)編程中，數(shù)據(jù)的傳輸和接收是必不可少的。在Linux編程中，接收數(shù)據(jù)時(shí)通常會(huì)使用到 recvfrom 函數(shù)。本文將詳細(xì)講解 Linux 編程中 recvfrom 函數(shù)的定義、用法以及注意事項(xiàng)。
在兗州等地區(qū)，都構(gòu)建了全面的區(qū)域性戰(zhàn)略布局，加強(qiáng)發(fā)展的系統(tǒng)性、市場(chǎng)前瞻性、產(chǎn)品創(chuàng)新能力，以專注、極致的服務(wù)理念，為客戶提供成都網(wǎng)站設(shè)計(jì)、網(wǎng)站制作 網(wǎng)站設(shè)計(jì)制作按需定制,公司網(wǎng)站建設(shè),企業(yè)網(wǎng)站建設(shè),成都品牌網(wǎng)站建設(shè),全網(wǎng)營(yíng)銷推廣,外貿(mào)網(wǎng)站制作,兗州網(wǎng)站建設(shè)費(fèi)用合理。
一、recvfrom 函數(shù)的定義
recvfrom 函數(shù)是 Linux 中的系統(tǒng)調(diào)用函數(shù)，主要用于接收數(shù)據(jù)。該函數(shù)的定義如下：
“`c
ssize_t recvfrom(int sockfd, void *buf, size_t len, int flags, struct sockaddr *src_addr, socklen_t *addrlen);
“`
其中，各個(gè)參數(shù)的含義如下：
– sockfd：表示接收數(shù)據(jù)的套接字描述符；
– buf：表示接收數(shù)據(jù)的緩沖區(qū)；
– len：表示接收數(shù)據(jù)的緩沖區(qū)的長(zhǎng)度；
– flags：表示接收數(shù)據(jù)時(shí)的額外選項(xiàng)；
– src_addr：源地址信息；
– addrlen：源地址信息的長(zhǎng)度。
該函數(shù)的返回值為 ssize_t，表示成功接收到的數(shù)據(jù)長(zhǎng)度。如果返回-1，則表示出現(xiàn)錯(cuò)誤。此時(shí)可以通過 perror 函數(shù)打印錯(cuò)誤信息，以便進(jìn)行調(diào)試。
二、recvfrom 函數(shù)的用法
在使用 recvfrom 函數(shù)時(shí)，我們需要先創(chuàng)建一個(gè) socket 套接字，并將其綁定到一個(gè) IP 地址和端口號(hào)上。接下來，我們就可以使用 recvfrom 函數(shù)來接收數(shù)據(jù)了。具體的代碼如下所示：
“`c
#include
#include
#include
#include
#include
#include
#include
#define PORT 8888
#define MAXLINE 1024
int mn(int argc, char *argv[])
{
int sockfd;
char buffer[MAXLINE];
struct sockaddr_in servaddr, cliaddr;
// 創(chuàng)建 socket 套接字
sockfd = socket(AF_INET, SOCK_DGRAM, 0);
if (sockfd == -1) {
perror(“socket creation fled”);
exit(EXIT_FLURE);
}
memset(&servaddr, 0, sizeof(servaddr));
memset(&cliaddr, 0, sizeof(cliaddr));
// 初始化服務(wù)器地址結(jié)構(gòu)
servaddr.sin_family = AF_INET;
servaddr.sin_addr.s_addr = INADDR_ANY;
servaddr.sin_port = htons(PORT);
// 綁定服務(wù)器地址結(jié)構(gòu)到 socket 套接字上
if (bind(sockfd, (const struct sockaddr *)&servaddr, sizeof(servaddr)) == -1) {
perror(“bind fled”);
exit(EXIT_FLURE);
}
printf(“Server listening on port %d\n”, PORT);
// 接收數(shù)據(jù)
while (1) {
socklen_t len = sizeof(cliaddr);
ssize_t n = recvfrom(sockfd, buffer, MAXLINE, 0, (struct sockaddr *)&cliaddr, &len);
if (n == -1) {
perror(“recvfrom error”);
exit(EXIT_FLURE);
}
buffer[n] = ‘\0’;
printf(“Received message from client: %s\n”, buffer);
// 向客戶端發(fā)送數(shù)據(jù)
int ret = sendto(sockfd, (const char *)buffer, strlen(buffer), 0, (const struct sockaddr *)&cliaddr, len);
if (ret == -1) {
perror(“sendto error”);
exit(EXIT_FLURE);
}
printf(“Message sent to client: %s\n”, buffer);
}
close(sockfd);
return 0;
}
“`
該程序首先創(chuàng)建了一個(gè) UDP 套接字，并將其綁定到 localhost:8888 這個(gè)地址上。然后，通過一個(gè) while 循環(huán)持續(xù)監(jiān)聽是否有數(shù)據(jù)發(fā)送過來。如果接收到了數(shù)據(jù)，就將其打印出來，并向客戶端發(fā)送一條相同的消息。
三、recvfrom 函數(shù)的注意事項(xiàng)
在使用 recvfrom 函數(shù)時(shí)，需要注意以下幾點(diǎn)：
1. 如果緩沖區(qū)大小小于接收到的數(shù)據(jù)大小，那么函數(shù)會(huì)將緩沖區(qū)填滿，并且截?cái)嗄切┏^緩沖區(qū)的部分；
2. 如果設(shè)置了 MSG_PEEK 標(biāo)志，那么 recvfrom 函數(shù)只是讀取數(shù)據(jù)，并不會(huì)將數(shù)據(jù)從輸入隊(duì)列中移除；
3. 如果設(shè)置了 MSG_DONTWT 標(biāo)志，那么 recvfrom 函數(shù)將不會(huì)阻塞，即使沒有數(shù)據(jù)可讀，它也會(huì)立即返回；
4. 當(dāng)通過 sendto 函數(shù)向遠(yuǎn)程主機(jī)發(fā)送數(shù)據(jù)時(shí)，需要注意參數(shù)的正確性，否則會(huì)出現(xiàn)數(shù)據(jù)發(fā)送失敗的情況。
相關(guān)問題拓展閱讀：
- linux 下用socket 文件傳輸問題(UDP)
linux 下用socket 文件傳輸問題(UDP)
你傳輸文本的時(shí)候用的什么函數(shù)阿？send/recv?還是sendto/recvfrom？或者直接read/write？
文件不是一樣的？只不過需要自己擬定一個(gè)協(xié)議，比如先發(fā)送文件大小，然后把文件打開了往里放不就好了，沒有難度吧
要下班了，時(shí)間急，不寫代碼了先給你一個(gè)思路
實(shí)現(xiàn)最簡(jiǎn)單的udp socket 模型，實(shí)現(xiàn)發(fā)送一個(gè)字符串。
實(shí)現(xiàn)一個(gè)簡(jiǎn)單的打開文件，讀取文件的例子，如用fgets(),類似的函數(shù)有很多，然后再把讀取的文件內(nèi)容忘另一個(gè)文件里寫(相關(guān)函數(shù)fopen(),write(),read())。
把上面兩個(gè)函數(shù)結(jié)合到一起，在客戶端實(shí)現(xiàn)打開要傳送的文件，按一定的大小讀取，讀取后調(diào)用sendto（）發(fā)送到服務(wù)器端。在服務(wù)器端創(chuàng)建一個(gè)文件，然后調(diào)用recvfrom（）接受客戶端發(fā)送過來的數(shù)據(jù)，向來是創(chuàng)建的那個(gè)文件中寫。
下面是改好的udp發(fā)送文件的例子。
服務(wù)器端程序的編譯
gcc -o file_server file_server
客戶端程序的編譯
gcc -o file_client file_client.c
服務(wù)器程序和客戶端程應(yīng)當(dāng)分別運(yùn)行在2臺(tái)計(jì)算機(jī)上.
服務(wù)器端程序的運(yùn)行,在一個(gè)計(jì)算機(jī)的終端執(zhí)行
./file_server
客戶端程序的運(yùn)行,在另一個(gè)計(jì)算機(jī)的終端中執(zhí)行
./file_client 運(yùn)行服務(wù)器程序的計(jì)算機(jī)的IP地址
根據(jù)提示輸入要傳輸?shù)姆?wù)器上的文件，該文件在服務(wù)器的運(yùn)行目錄上
在實(shí)際編程和測(cè)試中,可以用2個(gè)終端代替2個(gè)計(jì)算機(jī),這樣就可以在一臺(tái)計(jì)算機(jī)上測(cè)試網(wǎng)絡(luò)程序,
服務(wù)器端程序的運(yùn)行,在一個(gè)終端執(zhí)行
./file_server
客戶端程序的運(yùn)行,在另一個(gè)終端中執(zhí)行
./file_client 127.0.0.1
說明: 任何計(jì)算機(jī)都可以通過127.0.0.1訪問自己. 也可以用計(jì)算機(jī)的實(shí)際IP地址代替127.0.0.1
//////////////////////////////////////////////////////////////////////////////////////
// file_server.c 文件傳輸順序服務(wù)器示例
//////////////////////////////////////////////////////////////////////////////////////
//本文件是服務(wù)器的代碼
#include // for sockaddr_in
#include // for socket
#include // for socket
#include// for printf
#include// for exit
#include// for bzero
/*
#include
#include
#include
#include
*/
#define HELLO_WORLD_SERVER_PORT
#define LENGTH_OF_LISTEN_QUEUE 20
#define BUFFER_SIZE 1024
#define FILE_NAME_MAX_SIZE 512
int main(int argc, char **argv)
{
//設(shè)置一個(gè)socket地址結(jié)構(gòu)server_addr,代表服務(wù)器internet地址, 端口
struct sockaddr_in server_addr， pcliaddr;
bzero(&server_addr,sizeof(server_addr)); //把一段內(nèi)存區(qū)的內(nèi)容全部設(shè)置為0
server_addr.sin_family = AF_INET;
server_addr.sin_addr.s_addr = htons(INADDR_ANY);
server_addr.sin_port = htons(HELLO_WORLD_SERVER_PORT);
//創(chuàng)建用于internet的據(jù)報(bào)套接字（UDPt,用server_socket代表服務(wù)器socket
// 創(chuàng)建數(shù)據(jù)報(bào)套接字（UDP）
int server_socket = socket(PF_INET,SOCK_DGRAM,0);
if( server_socket FILE_NAME_MAX_SIZE?FILE_NAME_MAX_SIZE:strlen(buffer));
//int fp = open(file_name, O_RDON);
//if( fp 0)
while( (file_block_length = fread(buffer,sizeof(char),BUFFER_SIZE,fp))>0)
{
printf(“file_block_length = %d\n”,file_block_length);
//發(fā)送buffer中的字符串到new_server_socket,實(shí)際是給客戶端
if(send(new_server_socket,buffer,file_block_length,0) // for sockaddr_in
#include // for socket
#include // for socket
#include// for printf
#include// for exit
#include// for bzero
/*
#include
#include
#include
#include
*/
#define HELLO_WORLD_SERVER_PORT
#define BUFFER_SIZE 1024
#define FILE_NAME_MAX_SIZE 512
int main(int argc, char **argv)
{
if (argc != 2)
{
printf(“Usage: ./%s ServerIPAddress\n”,argv);
exit(1);
}
//設(shè)置一個(gè)socket地址結(jié)構(gòu)client_addr,代表客戶機(jī)internet地址, 端口
struct sockaddr_in client_addr;
bzero(&client_addr,sizeof(client_addr)); //把一段內(nèi)存區(qū)的內(nèi)容全部設(shè)置為0
client_addr.sin_family = AF_INET; //internet協(xié)議族
client_addr.sin_addr.s_addr = htons(INADDR_ANY);//INADDR_ANY表示自動(dòng)獲取本機(jī)地址
client_addr.sin_port = htons(0); //0表示讓系統(tǒng)自動(dòng)分配一個(gè)空閑端口
//創(chuàng)建用于internet的流協(xié)議(TCP)socket,用client_socket代表客戶機(jī)socket
int client_socket = socket(AF_INET,SOCK_DGRAM,0);
if( client_socket BUFFER_SIZE?BUFFER_SIZE:strlen(file_name));
//向服務(wù)器發(fā)送buffer中的數(shù)據(jù)
socklen_t n = sizeof(server_addr) ;
sendto(client_socket,buffer,BUFFER_SIZE,0,(struct sockaddr*)&server_addr,n);
// int fp = open(file_name, O_WRON|O_CREAT);
// if( fp // for sockaddr_in
#include // for socket
#include // for socket
#include// for printf
#include// for exit
#include// for bzero
/*
#include
#include
#include
#include
*/
#define HELLO_WORLD_SERVER_PORT
#define LENGTH_OF_LISTEN_QUEUE 20
#define BUFFER_SIZE 1024
#define FILE_NAME_MAX_SIZE 512
int main(int argc, char **argv)
{
//設(shè)置一個(gè)socket地址結(jié)構(gòu)server_addr,代表服務(wù)器internet地址, 端口
struct sockaddr_in server_addr;
bzero(&server_addr,sizeof(server_addr)); //把一段內(nèi)存區(qū)的內(nèi)容全部設(shè)置為0
server_addr.sin_family = AF_INET;
server_addr.sin_addr.s_addr = htons(INADDR_ANY);
server_addr.sin_port = htons(HELLO_WORLD_SERVER_PORT);
//創(chuàng)建用于internet的流協(xié)議(TCP)socket,用server_socket代表服務(wù)器socket
int server_socket = socket(PF_INET,SOCK_STREAM,0);
if( server_socket FILE_NAME_MAX_SIZE?FILE_NAME_MAX_SIZE:strlen(buffer));
//int fp = open(file_name, O_RDON);
//if( fp 0)
while( (file_block_length = fread(buffer,sizeof(char),BUFFER_SIZE,fp))>0)
{
printf(“file_block_length = %d\n”,file_block_length);
//發(fā)送buffer中的字符串到new_server_socket,實(shí)際是給客戶端
if(send(new_server_socket,buffer,file_block_length,0) // for sockaddr_in
#include // for socket
#include // for socket
#include// for printf
#include// for exit
#include// for bzero
/*
#include
#include
#include
#include
*/
#define HELLO_WORLD_SERVER_PORT
#define BUFFER_SIZE 1024
#define FILE_NAME_MAX_SIZE 512
int main(int argc, char **argv)
{
if (argc != 2)
{
printf(“Usage: ./%s ServerIPAddress\n”,argv);
exit(1);
}
//設(shè)置一個(gè)socket地址結(jié)構(gòu)client_addr,代表客戶機(jī)internet地址, 端口
struct sockaddr_in client_addr;
bzero(&client_addr,sizeof(client_addr)); //把一段內(nèi)存區(qū)的內(nèi)容全部設(shè)置為0
client_addr.sin_family = AF_INET; //internet協(xié)議族
client_addr.sin_addr.s_addr = htons(INADDR_ANY);//INADDR_ANY表示自動(dòng)獲取本機(jī)地址
client_addr.sin_port = htons(0); //0表示讓系統(tǒng)自動(dòng)分配一個(gè)空閑端口
//創(chuàng)建用于internet的流協(xié)議(TCP)socket,用client_socket代表客戶機(jī)socket
int client_socket = socket(AF_INET,SOCK_STREAM,0);
if( client_socket BUFFER_SIZE?BUFFER_SIZE:strlen(file_name));
//向服務(wù)器發(fā)送buffer中的數(shù)據(jù)
send(client_socket,buffer,BUFFER_SIZE,0);
// int fp = open(file_name, O_WRON|O_CREAT);
// if( fp
FILE * fp = fopen(file_name,”w”);
if(NULL == fp )
{
printf(“File:\t%s Can Not Open To Write\n”, file_name);
exit(1);
}
//從服務(wù)器接收數(shù)據(jù)到buffer中
bzero(buffer,BUFFER_SIZE);
int length = 0;
while( length = recv(client_socket,buffer,BUFFER_SIZE,0))
{
if(length
{
printf(“Recieve Data From Server %s Failed!\n”, argv);
break;
}
//int write_length = write(fp, buffer,length);
int write_length = fwrite(buffer,sizeof(char),length,fp);
if (write_length
{
printf(“File:\t%s Write Failed\n”, file_name);
break;
}
bzero(buffer,BUFFER_SIZE);
}
printf(“Recieve File:\t %s From Server Finished\n”,file_name, argv);
close(fp);
//關(guān)閉socket
close(client_socket);
return 0;
}
成都創(chuàng)新互聯(lián)科技有限公司，是一家專注于互聯(lián)網(wǎng)、IDC服務(wù)、應(yīng)用軟件開發(fā)、網(wǎng)站建設(shè)推廣的公司，為客戶提供互聯(lián)網(wǎng)基礎(chǔ)服務(wù)！
創(chuàng)新互聯(lián)（www.cdcxhl.com）提供簡(jiǎn)單好用，價(jià)格厚道的香港/美國(guó)云服務(wù)器和獨(dú)立服務(wù)器。創(chuàng)新互聯(lián)——四川成都IDC機(jī)房服務(wù)器托管/機(jī)柜租用。為您精選優(yōu)質(zhì)idc數(shù)據(jù)中心機(jī)房租用、服務(wù)器托管、機(jī)柜租賃、大帶寬租用，高電服務(wù)器托管，算力服務(wù)器租用，可選線路電信、移動(dòng)、聯(lián)通機(jī)房等。
分享標(biāo)題：Linux編程中常用的recvfrom函數(shù)詳解(recvfromlinux)
網(wǎng)站網(wǎng)址：http://m.5511xx.com/article/cddghhs.html
