高级I/O函数pipe,dup,readv,splice,sendfile,tee,fcntl

2023-10-27 23:08

本文主要是介绍高级I/O函数pipe,dup,readv,splice,sendfile,tee,fcntl,希望对大家解决编程问题提供一定的参考价值,需要的开发者们随着小编来一起学习吧!

pipe函数

用于创建一个管道,实现进程间通信。

#include<unistd.h>

int pipe(int fd[2]);

 dup函数和dup2函数

有时我们希望把标准输入重定向到一个文件,或者把标准输出重定向到一个网络连接(比如CGI编程),可以通过dup和dup2实现

 看个例子:

server.c

#include<sys/socket.h>
#include<netinet/in.h>
#include<arpa/inet.h>
#include<signal.h>
#include<unistd.h>
#include<stdlib.h>
#include<assert.h>
#include<stdio.h>
#include<errno.h>
#include<string.h>
#include<stdbool.h>
#include<libgen.h>
const int BUFFER_SIZE=1024;
int main(int argc,char* argv[])
{if(argc<=2){printf("usage: %s ip_address port_number\n",basename(argv[0]));return 1;}const char* ip=argv[1];int port=atoi(argv[2]);int sock=socket(PF_INET,SOCK_STREAM,0);assert(sock>=0);// 创建一个ipv4地址struct sockaddr_in address;bzero(&address,sizeof(address));address.sin_family=AF_INET;inet_pton(AF_INET,ip,&address.sin_addr);address.sin_port=htons(port);int  ret=bind(sock,(struct sockaddr*)&address,sizeof(address));assert(ret!=-1);ret=listen(sock,5);assert(ret!=-1);struct sockaddr_in client;socklen_t client_addrlength=sizeof(client);int connfd=accept(sock,(struct sockaddr*)&client,&client_addrlength);if(connfd<0){printf("errno is: %d\n",errno);}else{close(STDOUT_FILENO);dup(connfd);printf("abcd\n");close(connfd);}close(sock);return 0;
}

client.c

#include<sys/socket.h>
#include<netinet/in.h>
#include<arpa/inet.h>
#include<signal.h>
#include<unistd.h>
#include<stdlib.h>
#include<assert.h>
#include<stdio.h>
#include<errno.h>
#include<string.h>
#include<stdbool.h>
#include<libgen.h>
const int BUFFER_SIZE=512;
int main(int argc,char* argv[])
{if(argc<=2){printf("usage: %s ip_address port_number send_buffer_size\n",basename(argv[0]));return 1;}const char* ip=argv[1];int port=atoi(argv[2]);int sockfd=socket(PF_INET,SOCK_STREAM,0);assert(sockfd>=0);// 创建一个ipv4地址struct sockaddr_in server_address;bzero(&server_address,sizeof(server_address));server_address.sin_family=AF_INET;inet_pton(AF_INET,ip,&server_address.sin_addr);server_address.sin_port=htons(port);if(connect(sockfd,(struct sockaddr*)&server_address,sizeof(server_address))<0){printf("connection failed\n");}else{char buffer[BUFFER_SIZE];memset(buffer,'a',BUFFER_SIZE);send(sockfd,buffer,BUFFER_SIZE,0);memset(buffer,'\0',BUFFER_SIZE);int ret=recv(sockfd,buffer,BUFFER_SIZE,0);printf("get %d bytes content:%s\n",ret,buffer);}close(sockfd);return 0;
}

sendfile

sendfile函数在2个文件描述符之间直接传递数据(完全在内核中操作),从而避免内核缓冲区和用户缓冲区之间的数据拷贝,效率很高,称之为零拷贝。

server.c

#include<sys/socket.h>
#include<netinet/in.h>
#include<arpa/inet.h>
#include<signal.h>
#include<unistd.h>
#include<stdlib.h>
#include<assert.h>
#include<stdio.h>
#include<errno.h>
#include<string.h>
#include<stdbool.h>
#include<libgen.h>
#include<sys/stat.h>
#include<fcntl.h>
#include<sys/sendfile.h>
const int BUFFER_SIZE=1024;
int main(int argc,char* argv[])
{if(argc<=3){printf("usage: %s ip_address port_number filename\n",basename(argv[0]));return 1;}const char* ip=argv[1];int port=atoi(argv[2]);const char* file_name=argv[3];int filefd=open(file_name,O_RDONLY);assert(filefd>0);struct stat stat_buf;fstat(filefd,&stat_buf);int sock=socket(PF_INET,SOCK_STREAM,0);assert(sock>=0);// 创建一个ipv4地址struct sockaddr_in address;bzero(&address,sizeof(address));address.sin_family=AF_INET;inet_pton(AF_INET,ip,&address.sin_addr);address.sin_port=htons(port);int  ret=bind(sock,(struct sockaddr*)&address,sizeof(address));assert(ret!=-1);ret=listen(sock,5);assert(ret!=-1);struct sockaddr_in client;socklen_t client_addrlength=sizeof(client);int connfd=accept(sock,(struct sockaddr*)&client,&client_addrlength);if(connfd<0){printf("errno is: %d\n",errno);}else{sendfile(connfd,filefd,NULL,stat_buf.st_size);close(connfd);}close(sock);return 0;
}

 

我用我的电脑telnet服务器,sendfile会把文件内容发送给客户端。

 

splice函数

splice函数用于在2个文件描述符之间移动数据,也是零拷贝。定义如下:

 

 

server.c

#define _GNU_SOURCE 1
#include<sys/socket.h>
#include<netinet/in.h>
#include<arpa/inet.h>
#include<signal.h>
#include<unistd.h>
#include<stdlib.h>
#include<assert.h>
#include<stdio.h>
#include<errno.h>
#include<string.h>
#include<stdbool.h>
#include<libgen.h>
#include<sys/stat.h>
#include<fcntl.h>
#include<sys/sendfile.h>
const int BUFFER_SIZE=1024;
int main(int argc,char* argv[])
{if(argc<=2){printf("usage: %s ip_address port_number\n",basename(argv[0]));return 1;}const char* ip=argv[1];int port=atoi(argv[2]);int sock=socket(PF_INET,SOCK_STREAM,0);assert(sock>=0);// 创建一个ipv4地址struct sockaddr_in address;bzero(&address,sizeof(address));address.sin_family=AF_INET;inet_pton(AF_INET,ip,&address.sin_addr);address.sin_port=htons(port);int  ret=bind(sock,(struct sockaddr*)&address,sizeof(address));assert(ret!=-1);ret=listen(sock,5);assert(ret!=-1);struct sockaddr_in client;socklen_t client_addrlength=sizeof(client);int connfd=accept(sock,(struct sockaddr*)&client,&client_addrlength);if(connfd<0){printf("errno is: %d\n",errno);}else{int pipefd[2];assert(ret!=-1);ret=pipe(pipefd);//创建管道// 将connfd上流入的客户数据定向到管道中ret=splice(connfd,NULL,pipefd[1],NULL,32768,SPLICE_F_MORE | SPLICE_F_MOVE);assert(ret!=-1);// 将管道的输出定向到connfd客户连接文件描述符ret=splice(pipefd[0],NULL,connfd,NULL,32768,SPLICE_F_MORE | SPLICE_F_MOVE);assert(ret!=-1);close(connfd);}close(sock);return 0;
}

 client.c

#include<sys/socket.h>
#include<netinet/in.h>
#include<arpa/inet.h>
#include<signal.h>
#include<unistd.h>
#include<stdlib.h>
#include<assert.h>
#include<stdio.h>
#include<errno.h>
#include<string.h>
#include<stdbool.h>
#include<libgen.h>
const int BUFFER_SIZE=512;
int main(int argc,char* argv[])
{if(argc<=2){printf("usage: %s ip_address port_number send_buffer_size\n",basename(argv[0]));return 1;}const char* ip=argv[1];int port=atoi(argv[2]);int sockfd=socket(PF_INET,SOCK_STREAM,0);assert(sockfd>=0);// 创建一个ipv4地址struct sockaddr_in server_address;bzero(&server_address,sizeof(server_address));server_address.sin_family=AF_INET;inet_pton(AF_INET,ip,&server_address.sin_addr);server_address.sin_port=htons(port);if(connect(sockfd,(struct sockaddr*)&server_address,sizeof(server_address))<0){printf("connection failed\n");}else{char buffer[BUFFER_SIZE];memset(buffer,'a',BUFFER_SIZE);send(sockfd,buffer,BUFFER_SIZE,0);memset(buffer,'\0',BUFFER_SIZE);int ret=recv(sockfd,buffer,BUFFER_SIZE,0);printf("get %d bytes content:%s\n",ret,buffer);}close(sockfd);return 0;
}

fcntl函数

正如其名字(file control)描述那样,提供了对文件描述符的各种控制操作。另一个常见的控制文件描述符属性和行为的系统调用是ioctl,而且ioctl比fcntl能够执行更多的控制。但是对于控制文件描述符常用的属性和行为,fcntl函数是由POSIX规范指定的首选方法。定义如下:

 

 

这篇关于高级I/O函数pipe,dup,readv,splice,sendfile,tee,fcntl的文章就介绍到这儿,希望我们推荐的文章对编程师们有所帮助!



http://www.chinasem.cn/article/289033

相关文章

PostgreSQL中rank()窗口函数实用指南与示例

《PostgreSQL中rank()窗口函数实用指南与示例》在数据分析和数据库管理中,经常需要对数据进行排名操作,PostgreSQL提供了强大的窗口函数rank(),可以方便地对结果集中的行进行排名... 目录一、rank()函数简介二、基础示例:部门内员工薪资排名示例数据排名查询三、高级应用示例1. 每

全面掌握 SQL 中的 DATEDIFF函数及用法最佳实践

《全面掌握SQL中的DATEDIFF函数及用法最佳实践》本文解析DATEDIFF在不同数据库中的差异,强调其边界计算原理,探讨应用场景及陷阱,推荐根据需求选择TIMESTAMPDIFF或inte... 目录1. 核心概念:DATEDIFF 究竟在计算什么?2. 主流数据库中的 DATEDIFF 实现2.1

MySQL中的LENGTH()函数用法详解与实例分析

《MySQL中的LENGTH()函数用法详解与实例分析》MySQLLENGTH()函数用于计算字符串的字节长度,区别于CHAR_LENGTH()的字符长度,适用于多字节字符集(如UTF-8)的数据验证... 目录1. LENGTH()函数的基本语法2. LENGTH()函数的返回值2.1 示例1:计算字符串

MySQL 中的 CAST 函数详解及常见用法

《MySQL中的CAST函数详解及常见用法》CAST函数是MySQL中用于数据类型转换的重要函数,它允许你将一个值从一种数据类型转换为另一种数据类型,本文给大家介绍MySQL中的CAST... 目录mysql 中的 CAST 函数详解一、基本语法二、支持的数据类型三、常见用法示例1. 字符串转数字2. 数字

Python中你不知道的gzip高级用法分享

《Python中你不知道的gzip高级用法分享》在当今大数据时代,数据存储和传输成本已成为每个开发者必须考虑的问题,Python内置的gzip模块提供了一种简单高效的解决方案,下面小编就来和大家详细讲... 目录前言:为什么数据压缩如此重要1. gzip 模块基础介绍2. 基本压缩与解压缩操作2.1 压缩文

Python内置函数之classmethod函数使用详解

《Python内置函数之classmethod函数使用详解》:本文主要介绍Python内置函数之classmethod函数使用方式,具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地... 目录1. 类方法定义与基本语法2. 类方法 vs 实例方法 vs 静态方法3. 核心特性与用法(1编程客

Python函数作用域示例详解

《Python函数作用域示例详解》本文介绍了Python中的LEGB作用域规则,详细解析了变量查找的四个层级,通过具体代码示例,展示了各层级的变量访问规则和特性,对python函数作用域相关知识感兴趣... 目录一、LEGB 规则二、作用域实例2.1 局部作用域(Local)2.2 闭包作用域(Enclos

MySQL count()聚合函数详解

《MySQLcount()聚合函数详解》MySQL中的COUNT()函数,它是SQL中最常用的聚合函数之一,用于计算表中符合特定条件的行数,本文给大家介绍MySQLcount()聚合函数,感兴趣的朋... 目录核心功能语法形式重要特性与行为如何选择使用哪种形式?总结深入剖析一下 mysql 中的 COUNT

MySQL 中 ROW_NUMBER() 函数最佳实践

《MySQL中ROW_NUMBER()函数最佳实践》MySQL中ROW_NUMBER()函数,作为窗口函数为每行分配唯一连续序号,区别于RANK()和DENSE_RANK(),特别适合分页、去重... 目录mysql 中 ROW_NUMBER() 函数详解一、基础语法二、核心特点三、典型应用场景1. 数据分

MySQL数据库的内嵌函数和联合查询实例代码

《MySQL数据库的内嵌函数和联合查询实例代码》联合查询是一种将多个查询结果组合在一起的方法,通常使用UNION、UNIONALL、INTERSECT和EXCEPT关键字,下面:本文主要介绍MyS... 目录一.数据库的内嵌函数1.1聚合函数COUNT([DISTINCT] expr)SUM([DISTIN