最好看的小说排行,小说网,完美世界有声小说

新聞中心

這里有您想知道的互聯(lián)網(wǎng)營銷解決方案

Linux編程中常用的recvfrom函數(shù)詳解(recvfromlinux)

在Linux操作系統(tǒng)中，網(wǎng)絡編程是非常重要的一部分。而網(wǎng)絡編程中，數(shù)據(jù)的傳輸和接收是必不可少的。在Linux編程中，接收數(shù)據(jù)時通常會使用到 recvfrom 函數(shù)。本文將詳細講解 Linux 編程中 recvfrom 函數(shù)的定義、用法以及注意事項。

在兗州等地區(qū)，都構建了全面的區(qū)域性戰(zhàn)略布局，加強發(fā)展的系統(tǒng)性、市場前瞻性、產(chǎn)品創(chuàng)新能力，以專注、極致的服務理念，為客戶提供成都網(wǎng)站設計、網(wǎng)站制作網(wǎng)站設計制作按需定制,公司網(wǎng)站建設,企業(yè)網(wǎng)站建設,成都品牌網(wǎng)站建設,全網(wǎng)營銷推廣,外貿(mào)網(wǎng)站制作,兗州網(wǎng)站建設費用合理。

一、recvfrom 函數(shù)的定義

recvfrom 函數(shù)是 Linux 中的系統(tǒng)調用函數(shù)，主要用于接收數(shù)據(jù)。該函數(shù)的定義如下：

“`c

ssize_t recvfrom(int sockfd, void *buf, size_t len, int flags, struct sockaddr *src_addr, socklen_t *addrlen);

“`

其中，各個參數(shù)的含義如下：

– sockfd：表示接收數(shù)據(jù)的套接字描述符；

– buf：表示接收數(shù)據(jù)的緩沖區(qū)；

– len：表示接收數(shù)據(jù)的緩沖區(qū)的長度；

– flags：表示接收數(shù)據(jù)時的額外選項；

– src_addr：源地址信息；

– addrlen：源地址信息的長度。

該函數(shù)的返回值為 ssize_t，表示成功接收到的數(shù)據(jù)長度。如果返回-1，則表示出現(xiàn)錯誤。此時可以通過 perror 函數(shù)打印錯誤信息，以便進行調試。

二、recvfrom 函數(shù)的用法

在使用 recvfrom 函數(shù)時，我們需要先創(chuàng)建一個 socket 套接字，并將其綁定到一個 IP 地址和端口號上。接下來，我們就可以使用 recvfrom 函數(shù)來接收數(shù)據(jù)了。具體的代碼如下所示：

“`c

#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));

// 初始化服務器地址結構

servaddr.sin_family = AF_INET;

servaddr.sin_addr.s_addr = INADDR_ANY;

servaddr.sin_port = htons(PORT);

// 綁定服務器地址結構到 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)建了一個 UDP 套接字，并將其綁定到 localhost:8888 這個地址上。然后，通過一個 while 循環(huán)持續(xù)監(jiān)聽是否有數(shù)據(jù)發(fā)送過來。如果接收到了數(shù)據(jù)，就將其打印出來，并向客戶端發(fā)送一條相同的消息。

三、recvfrom 函數(shù)的注意事項

在使用 recvfrom 函數(shù)時，需要注意以下幾點：

1. 如果緩沖區(qū)大小小于接收到的數(shù)據(jù)大小，那么函數(shù)會將緩沖區(qū)填滿，并且截斷那些超過緩沖區(qū)的部分；

2. 如果設置了 MSG_PEEK 標志，那么 recvfrom 函數(shù)只是讀取數(shù)據(jù)，并不會將數(shù)據(jù)從輸入隊列中移除；

3. 如果設置了 MSG_DONTWT 標志，那么 recvfrom 函數(shù)將不會阻塞，即使沒有數(shù)據(jù)可讀，它也會立即返回；

4. 當通過 sendto 函數(shù)向遠程主機發(fā)送數(shù)據(jù)時，需要注意參數(shù)的正確性，否則會出現(xiàn)數(shù)據(jù)發(fā)送失敗的情況。

相關問題拓展閱讀：

linux 下用socket 文件傳輸問題(UDP)

linux 下用socket 文件傳輸問題(UDP)

你傳輸文本的時候用的什么函數(shù)阿？send/recv?還是sendto/recvfrom？或者直接read/write？

文件不是一樣的？只不過需要自己擬定一個協(xié)議，比如先發(fā)送文件大小，然后把文件打開了往里放不就好了，沒有難度吧

要下班了，時間急，不寫代碼了先給你一個思路

實現(xiàn)最簡單的udp socket 模型，實現(xiàn)發(fā)送一個字符串。

實現(xiàn)一個簡單的打開文件，讀取文件的例子，如用fgets(),類似的函數(shù)有很多，然后再把讀取的文件內容忘另一個文件里寫(相關函數(shù)fopen(),write(),read())。

把上面兩個函數(shù)結合到一起，在客戶端實現(xiàn)打開要傳送的文件，按一定的大小讀取，讀取后調用sendto（）發(fā)送到服務器端。在服務器端創(chuàng)建一個文件，然后調用recvfrom（）接受客戶端發(fā)送過來的數(shù)據(jù)，向來是創(chuàng)建的那個文件中寫。

下面是改好的udp發(fā)送文件的例子。

服務器端程序的編譯

gcc -o file_server file_server

客戶端程序的編譯

gcc -o file_client file_client.c

服務器程序和客戶端程應當分別運行在2臺計算機上.

服務器端程序的運行,在一個計算機的終端執(zhí)行

./file_server

客戶端程序的運行,在另一個計算機的終端中執(zhí)行

./file_client 運行服務器程序的計算機的IP地址

根據(jù)提示輸入要傳輸?shù)姆掌魃系奈募?，該文件在服務器的運行目錄上

在實際編程和測試中,可以用2個終端代替2個計算機,這樣就可以在一臺計算機上測試網(wǎng)絡程序,

服務器端程序的運行,在一個終端執(zhí)行

./file_server

客戶端程序的運行,在另一個終端中執(zhí)行

./file_client 127.0.0.1

說明: 任何計算機都可以通過127.0.0.1訪問自己. 也可以用計算機的實際IP地址代替127.0.0.1

//////////////////////////////////////////////////////////////////////////////////////

// file_server.c 文件傳輸順序服務器示例

//////////////////////////////////////////////////////////////////////////////////////

//本文件是服務器的代碼

#include // for sockaddr_in

#include // for socket

#include// for printf

#include// for exit

#include// for bzero

#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)

{

//設置一個socket地址結構server_addr,代表服務器internet地址, 端口

struct sockaddr_in server_addr， pcliaddr;

bzero(&server_addr,sizeof(server_addr)); //把一段內存區(qū)的內容全部設置為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ù)報套接字（UDPt,用server_socket代表服務器socket

// 創(chuàng)建數(shù)據(jù)報套接字（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,實際是給客戶端

if(send(new_server_socket,buffer,file_block_length,0) // for sockaddr_in

#include // for socket

#include// for printf

#include// for exit

#include// for bzero

#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);

}

//設置一個socket地址結構client_addr,代表客戶機internet地址, 端口

struct sockaddr_in client_addr;

bzero(&client_addr,sizeof(client_addr)); //把一段內存區(qū)的內容全部設置為0

client_addr.sin_family = AF_INET; //internet協(xié)議族

client_addr.sin_addr.s_addr = htons(INADDR_ANY);//INADDR_ANY表示自動獲取本機地址

client_addr.sin_port = htons(0); //0表示讓系統(tǒng)自動分配一個空閑端口

//創(chuàng)建用于internet的流協(xié)議(TCP)socket,用client_socket代表客戶機socket

int client_socket = socket(AF_INET,SOCK_DGRAM,0);

if( client_socket BUFFER_SIZE?BUFFER_SIZE:strlen(file_name));

//向服務器發(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 printf

#include// for exit

#include// for bzero

#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)

{

//設置一個socket地址結構server_addr,代表服務器internet地址, 端口

struct sockaddr_in server_addr;

bzero(&server_addr,sizeof(server_addr)); //把一段內存區(qū)的內容全部設置為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代表服務器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,實際是給客戶端

if(send(new_server_socket,buffer,file_block_length,0) // for sockaddr_in

#include // for socket

#include// for printf

#include// for exit

#include// for bzero

#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);

}

//設置一個socket地址結構client_addr,代表客戶機internet地址, 端口

struct sockaddr_in client_addr;

bzero(&client_addr,sizeof(client_addr)); //把一段內存區(qū)的內容全部設置為0

client_addr.sin_family = AF_INET; //internet協(xié)議族

client_addr.sin_addr.s_addr = htons(INADDR_ANY);//INADDR_ANY表示自動獲取本機地址

client_addr.sin_port = htons(0); //0表示讓系統(tǒng)自動分配一個空閑端口

//創(chuàng)建用于internet的流協(xié)議(TCP)socket,用client_socket代表客戶機socket

int client_socket = socket(AF_INET,SOCK_STREAM,0);

if( client_socket BUFFER_SIZE?BUFFER_SIZE:strlen(file_name));

//向服務器發(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);

}

//從服務器接收數(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);

//關閉socket

close(client_socket);

return 0;

}

成都創(chuàng)新互聯(lián)科技有限公司，是一家專注于互聯(lián)網(wǎng)、IDC服務、應用軟件開發(fā)、網(wǎng)站建設推廣的公司，為客戶提供互聯(lián)網(wǎng)基礎服務！
創(chuàng)新互聯(lián)（www.cdcxhl.com）提供簡單好用，價格厚道的香港/美國云服務器和獨立服務器。創(chuàng)新互聯(lián)——四川成都IDC機房服務器托管/機柜租用。為您精選優(yōu)質idc數(shù)據(jù)中心機房租用、服務器托管、機柜租賃、大帶寬租用，高電服務器托管，算力服務器租用，可選線路電信、移動、聯(lián)通機房等。

當前名稱：Linux編程中常用的recvfrom函數(shù)詳解(recvfromlinux)
本文來源：http://fisionsoft.com.cn/article/cddghhs.html

新聞中心

linux 下用socket 文件傳輸問題(UDP)

其他資訊