0725，进程间传递文件描述符，socketpair + sendmsg/recvmsg

我要碎掉了我要碎掉了我要碎掉了

上课喵：

pipe匿名管道的问题

#include <func.h>int main()
{int fds[2];pipe(fds);pid_t pid=fork();if(pid>0){ //fatherclose(fds[0]);//close readint fd=open("file2.txt",O_RDONLY);printf("father: fds[1]:%d\n",fds[1]);write(fds[1],&fd,sizeof(fd));wait(NULL);close(fd);}else{   //sonclose(fds[1]);//close erint chilfd=-1;read(fds[0],&chilfd,sizeof(chilfd));  //read baba pipeprintf("chilefd %d.fds [0]:%d\n",chilfd,fds[0]);char buff[100]={0};read(chilfd,buff,sizeof(buff));printf("buff  %s.\n",buff);}return 0;
}

writev

#include <func.h>
#include <sys/uio.h>int main()
{char buff[]="love";char buff2[]="xixi";int fd=open("file2.txt",O_RDWR|O_CREAT,0664);if(fd==-1){};struct iovec iov[2];iov[0].iov_base=buff;iov[0].iov_len=strlen(buff);iov[1].iov_base=buff2;iov[1].iov_len=strlen(buff2);int ret=writev(fd,iov,2);printf("ret :%d \n",ret);close(fd);return 0;
}

readv

#include <func.h>
#include <sys/uio.h>int main()
{char buff[6]={0};char buff2[6]={0};int fd=open("file2.txt",O_RDWR);if(fd==-1){};struct iovec iov[2];iov[0].iov_base=buff;/* iov[0].iov_len=strlen(buff); */iov[0].iov_len=sizeof(buff);iov[1].iov_base=buff2;iov[1].iov_len=sizeof(buff2);int ret=readv(fd,iov,2);printf("ret :%d \n",ret);printf("buff:%s \n",buff);printf("buff2:%s \n",buff2);close(fd);return 0;
}

结构体struct msghdr的发送和接收实现

真是酣畅淋漓的CP

代码改好了！！
./wr33: sendmsg: Bad file descriptor
嘿嘿~~~因为没有文件所以打开失败了！！！聪明小辉

#include <func.h>
#include <sys/uio.h>int sendFd(int pipefd,int fd){//buid 2 groupchar buff[6]="hellp";struct iovec iov;memset(&iov,0,sizeof(iov));iov.iov_base=buff;iov.iov_len=sizeof(buff);//build 3 groupint len=CMSG_LEN(sizeof(fd));struct cmsghdr* cmsg=(struct cmsghdr*)calloc(1,len);cmsg->cmsg_len=len;cmsg->cmsg_level=SOL_SOCKET;cmsg->cmsg_type=SCM_RIGHTS;int * p=(int*)CMSG_DATA(cmsg);*p=fd;// buid msghdrstruct msghdr msg;memset(&msg,0,sizeof(msg));msg.msg_iov=&iov;msg.msg_iovlen=1;msg.msg_control=cmsg;//传递文件描述msg.msg_controllen=len;int ret=sendmsg(pipefd,&msg,0);printf("sendmsg ret: %d\n",ret);if(ret==-1){error(1,errno,"sendmsg");}free(cmsg);return 0;
}int recvFd(int pipefd,int *pfd){//buid 2 groupchar buff[6]={0};struct iovec iov;memset(&iov,0,sizeof(iov));iov.iov_base=buff;iov.iov_len=sizeof(buff);//3 groupint len=CMSG_LEN(sizeof(int));struct cmsghdr* cmsg=(struct cmsghdr*)calloc(1,len);cmsg->cmsg_len=len;cmsg->cmsg_level=SOL_SOCKET;cmsg->cmsg_type=SCM_RIGHTS;struct msghdr msg;memset(&msg,0,sizeof(msg));msg.msg_iov=&iov;msg.msg_iovlen=1;msg.msg_control=cmsg;//传递文件描述符msg.msg_controllen=len;int ret =recvmsg(pipefd,&msg,0);if(ret==-1){error(1,errno,"recvmsg");}int* p=(int*)CMSG_DATA(cmsg);printf("buff: %s\n",buff);*pfd=*p;//传给外籍的指针(读取文件描述符的值)return 0;
}int main()
{int fds[2];socketpair(AF_LOCAL,SOCK_STREAM,0,fds);pid_t pid=fork();if(pid>0){ //fatherclose(fds[0]);//close readint fd=open("file1.txt",O_RDONLY);printf("father fd:%d\n",fd);/* write(fds[1],&fd,sizeof(fd)); */sendFd(fds[1],fd);wait(NULL);close(fd);}else{   //sonclose(fds[1]);//close erint chilfd=-1;/* read(fds[0],&chilfd,sizeof(chilfd));  //read baba pipe */recvFd(fds[0],&chilfd);printf("chilefd %d.fds [0]:%d\n",chilfd,fds[0]);char buff[100]={0};read(chilfd,buff,sizeof(buff));printf("buff  %s.\n",buff);}return 0;
}

 进程池框架的搭建

作业：

01：参考我们上课的代码: 让子进程A打开一个文件, 把这个文件描述符信息发给父进程B, 让父进程B在这个文件上能写一个字符串. 

好像没什么用？？？？？？

#include <func.h>
#include <sys/uio.h>int sendFd(int pipefd,int fd){//buid 2 groupchar buff[6]={0};struct iovec iov;memset(&iov,0,sizeof(iov));iov.iov_base=buff;iov.iov_len=sizeof(buff);//build 3 groupint len=CMSG_LEN(sizeof(fd));struct cmsghdr* cmsg=(struct cmsghdr*)calloc(1,len);cmsg->cmsg_len=len;cmsg->cmsg_level=SOL_SOCKET;cmsg->cmsg_type=SCM_RIGHTS;int * p=(int*)CMSG_DATA(cmsg);*p=fd;// buid msghdrstruct msghdr msg;memset(&msg,0,sizeof(msg));msg.msg_iov=&iov;msg.msg_iovlen=1;msg.msg_control=cmsg;//传递文件描述msg.msg_controllen=len;int ret=sendmsg(pipefd,&msg,0);if(ret==-1){error(1,errno,"sendmsg");}free(cmsg);return 0;
}int recvFd(int pipefd,int *pfd){//buid 2 groupchar buff[6]={0};struct iovec iov;memset(&iov,0,sizeof(iov));iov.iov_base=buff;iov.iov_len=sizeof(buff);//3 groupint len=CMSG_LEN(sizeof(int));struct cmsghdr* cmsg=(struct cmsghdr*)calloc(1,len);cmsg->cmsg_len=len;cmsg->cmsg_level=SOL_SOCKET;cmsg->cmsg_type=SCM_RIGHTS;struct msghdr msg;memset(&msg,0,sizeof(msg));msg.msg_iov=&iov;msg.msg_iovlen=1;msg.msg_control=cmsg;//传递文件描述符msg.msg_controllen=len;int ret =recvmsg(pipefd,&msg,0);if(ret==-1){error(1,errno,"recvmsg");}int* p=(int*)CMSG_DATA(cmsg);*pfd=*p;//传给外籍的指针(读取文件描述符的值)return 0;
}int main()
{int fd[2];int err=socketpair(AF_LOCAL,SOCK_STREAM,0,fd);if(err==-1){error(1,errno,"sockpair");}int pid=fork();switch (pid){case -1:error(1,errno,"fork");break;case 0:{close(fd[0]);printf("child process:%d\n",getpid());int pfd;recvFd(fd[1],&pfd);char buff[]="我恨你我恨你我恨你！！！！！\n";write(pfd,buff,sizeof(buff));close(pfd);break;}default:{close(fd[1]);int filefd=open("file2.txt",O_RDWR);if(filefd==-1){error(1,errno,"open");}sendFd(fd[0],filefd);break;}      }return 0;
}

所以那狗东西要怎么打印出来可恶！！！！ 

02：仿照我们上课写的进程池, 自己手写(不要直接复制)一个进程池代码。

过

抄抄抄：

02：使用select编写聊天室程序：客户端和服务端使用tcp通信；服务端可以处理新客户端的连接和转发消息；客户端可以连入服务端并发送消息。

哥们发现少一个右括号直接傻眼了喵
xiaohuichen@xiaohuichen-virtual-machine:~/001/724$ cat douqusi.c
#include <func.h>
#define IP1  "192.168.235.128"
#define PORT1 8080int main()
{struct sockaddr_in addr;addr.sin_family=AF_INET;addr.sin_port=htons(PORT1);addr.sin_addr.s_addr=inet_addr(IP1);int lifd=socket(AF_INET,SOCK_STREAM,0);bind(lifd,(struct sockaddr *)&addr,sizeof(struct sockaddr));listen(lifd,100);int ac_fd[1000];int ac_num=0;char buf[256];char buf_sent[256];fd_set readfds;FD_ZERO(&readfds);int fd_max;FD_SET(lifd,&readfds);fd_max=lifd;fd_set old_fds=readfds;printf("listenning\n");while(1){readfds=old_fds;select (fd_max+1,&readfds,NULL,NULL,NULL);if(FD_ISSET(lifd,&readfds)){ac_fd[ac_num]=accept(lifd,NULL,NULL);FD_SET(ac_fd[ac_num],&old_fds);if(ac_fd[ac_num]>fd_max){fd_max=ac_fd[ac_num];}ac_num++;printf("welcome user%d \n",ac_fd[ac_num-1]);}for(int i=0;i<ac_num;i++){if(FD_ISSET(ac_fd[i],&readfds)){int a=recv(ac_fd[i],buf,256,0);if(a==0){close(ac_fd[i]);}}sprintf(buf_sent,"user%d:%s",ac_fd[i],buf);for(int j=0;j<ac_num;j++){send(ac_fd[j],buf_sent,strlen(buf_sent)+1,0);}}}return 0;
}

HTTP:（咳咳，是我不知道怎么跑然后连了一个客户端喵）

#include <func.h>
#define IP1  "192.168.235.128"
#define PORT1 8080struct sockaddr* addr_create(const char* ip,int  port ){struct sockaddr_in* addr=(struct sockaddr_in*)malloc(sizeof(struct sockaddr_in));memset(addr,0,sizeof(*addr));addr->sin_family=AF_INET;addr->sin_port=htons(port);addr->sin_addr.s_addr=inet_addr(ip);return (struct sockaddr*)addr;
}int main()
{int sofd=socket(AF_INET,SOCK_STREAM,0);if(sofd==-1){error(1,errno,"socket");}int on=1;int ret=setsockopt(sofd,SOL_SOCKET,SO_REUSEADDR,&on,sizeof(on));if(ret==-1){error(1,errno,"setsoclopt");}struct sockaddr* addr=addr_create(IP1,PORT1);ret=bind(sofd,addr,sizeof(*addr));if(ret==-1){error(1,errno,"bind");}ret=listen(sofd,1);while(1){int peerfd=accept(sofd,NULL,NULL);char buff[4096]={0};ret=recv(peerfd,buff,sizeof(buff),0);printf("\nrecv: %d.bytes \n",ret);printf("----%s\n",buff);char response[4096]={0};const char* start_line="HTTP/1.1 200 ok\r\n";const char* headers="Server:MyHttpServer1.0\r\n""Connection:keep-aliave\r\n""Conntent-Type:text/html\r\n""Content-Length:";const char* empty_line="\r\n";const char* body="<html><head>This is a test</head><body>hello,client</body></html>";sprintf(response,"%s%s%ld\r\n%s%s",start_line,headers,strlen(body),empty_line,body);send(peerfd,response,strlen(response),0);}close(sofd);return 0;
}

本文来自互联网用户投稿，该文观点仅代表作者本人，不代表本站立场。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如若转载，请注明出处：http://xiahunao.cn/news/3266316.html

如若内容造成侵权/违法违规/事实不符，请联系瞎胡闹网进行投诉反馈，一经查实，立即删除！

相关文章

Idea2024 创建Meaven项目没有src文件夹

Idea2024 创建Meaven项目没有src文件夹

1、直接创建 新建maven项目&#xff0c;发现没有src/main/java 直接新建文件夹&#xff1a;右击项目名->new->Directory 可以看到idea给出了快捷创建文件夹的选项&#xff0c;可以根据需要创建&#xff0c;这里点击src/main/java 回车&#xff0c;可以看到文件夹已经创建…
阅读更多...
用户管理与高级SQL语句（数据库管理与高可用）

用户管理与高级SQL语句（数据库管理与高可用）

1.表&#xff08;Table &#xff09; 数据库中的表与我们日常生活中使用的表格类似&#xff0c;它也是由行&#xff08;Row&#xff09; 和列&#xff08;Column&#xff09;组成的。列由同类的信息组成&#xff0c;每列又称为一个字段&#xff0c;每列的标题称为字段名。行包…
阅读更多...
sql注入的专项练习 sqlilabs(含代码审计)

sql注入的专项练习 sqlilabs(含代码审计)

在做题之前先复习了数据库的增删改查&#xff0c;然后自己用本地的环境&#xff0c;在自己建的库里面进行了sql语句的测试&#xff0c;主要是回顾了一下sql注入联合注入查询的语句和sql注入的一般做题步骤。 1.获取当前数据库 2.获取数据库中的表 3.获取表中的字段名 一、sql…
阅读更多...
51单片机嵌入式开发：19、STC89C52R控制LCD1602码表+数码管+后台数显（串口）

51单片机嵌入式开发：19、STC89C52R控制LCD1602码表+数码管+后台数显（串口）

STC89C52R控制LCD1602码表数码管后台数显&#xff08;串口&#xff09; 1 概述1.1 项目概述1.2 项目组成部分1.3 功能描述 2 开发环境2.1 支持设备2.2 硬件电路 3 软件代码工程4 演示4.1 Proteus仿真4.2 实物演示 5 总结 1 概述 1.1 项目概述 本项目旨在利用STC89C52R单片机实…
阅读更多...
联通智慧商业零售解决方案，旨在为全球零售企业提供低成本、高效能的组网与通信服务

联通智慧商业零售解决方案，旨在为全球零售企业提供低成本、高效能的组网与通信服务

联通智慧商业零售解决方案&#xff1a;驱动零售业全球布局与创新 在全球化的大背景下&#xff0c;零售业面临着前所未有的机遇与挑战。随着消费者需求的多样化和市场环境的快速变化&#xff0c;零售商必须不断寻求创新&#xff0c;以保持竞争力。中国联通国际&#xff0c;凭借…
阅读更多...
优略解距离法—Topsis模型【清风数模学习笔记】

优略解距离法—Topsis模型【清风数模学习笔记】

层次分析法的局限性 &#xff08;1&#xff09;决策层不能太多 &#xff08;2&#xff09;数据已知&#xff0c;使用层次分析法不准确 构造计算评分 相较于取卷面理论上的最高分&#xff08;100&#xff09;和最低分&#xff08;0&#xff09;&#xff0c;取分数区间上的最…
阅读更多...
Golang | Leetcode Golang题解之第290题单词规律

Golang | Leetcode Golang题解之第290题单词规律

题目&#xff1a; 题解&#xff1a; func wordPattern(pattern string, s string) bool {word2ch : map[string]byte{}ch2word : map[byte]string{}words : strings.Split(s, " ")if len(pattern) ! len(words) {return false}for i, word : range words {ch : patt…
阅读更多...
CSS技巧专栏：一日一例 12 -纯CSS实现边框上下交错的按钮特效

CSS技巧专栏：一日一例 12 -纯CSS实现边框上下交错的按钮特效

CSS技巧专栏&#xff1a;一日一例 12 -纯CSS实现边框上下交错的按钮特效 大家好&#xff0c;今天我们来做一个上下边框交错闪动的按钮特效。 本例图片 案例分析 虽说这按钮给人的感觉就是上下两个边框交错变换了位置&#xff0c;但我们都知道border是没法移动的。那么这个按…
阅读更多...
python实现接缝雕刻算法

python实现接缝雕刻算法

python实现接缝雕刻算法 接缝雕刻算法步骤详解Python实现详细解释优缺点应用领域接缝雕刻算法（Seam Carving Algorithm）是一种内容感知的图像缩放技术，可以智能地改变图像的尺寸，而不会明显影响其重要内容。它通过动态规划的方式寻找图像中的“接缝”，即在图像中从上到下或…
阅读更多...
排序系列 之 希尔排序

排序系列 之 希尔排序

&#xff01;&#xff01;&#xff01;排序仅针对于数组哦本次排序是按照升序来的哦 介绍 英文名为ShellSort&#xff0c;又称“缩小增量排序”是直接插入排序算法的一种更高效的改进版本希尔排序是把记录按下标的指定步长分组&#xff0c;然后按照每组使用直接插入排序&#…
阅读更多...
【全面讲解下Docker in Docker的原理与实践】

【全面讲解下Docker in Docker的原理与实践】

🌈个人主页: 程序员不想敲代码啊 🏆CSDN优质创作者，CSDN实力新星，CSDN博客专家 👍点赞⭐评论⭐收藏 🤝希望本文对您有所裨益，如有不足之处，欢迎在评论区提出指正，让我们共同学习、交流进步！ 👉目录 👉前言👉原理👉实践👉安全和最佳实践👉前言 🦛…
阅读更多...
Python 教程（三）：字符串特性大全

Python 教程（三）：字符串特性大全

目录 专栏列表前言1. 字符串基础2. 字符串方法字符串查询字符串修改字符串切片 3. 字符串格式化旧式格式化&#xff08;% 操作符&#xff09;str.format() 方法f-string&#xff08;Python 3.6&#xff09; 4. 字符串编码5. Unicode 和 ASCII6. 正则表达式7. 字符串比较8. 字符…
阅读更多...
从零入手人工智能（6）—— 聚类

从零入手人工智能（6）—— 聚类

1.小故事 有一家零售连锁店&#xff0c;他们以其精准的市场定位和个性化的顾客服务而闻名&#xff0c;随着市场竞争的加剧和顾客需求的多样化&#xff0c;他们的管理层开始意识到&#xff0c;只有更加深入地了解他们的顾客群体&#xff0c;以便更好地满足他们的需求。 他们定…
阅读更多...
文件包含漏洞--pyload

文件包含漏洞--pyload

文章目录 前言一、pandas是什么&#xff1f;二、使用步骤 1.引入库2.读入数据总结 一.PHP伪协议利用 php://协议 php://filter &#xff1a;用于在读取和写入文件时进行过滤和转换操作。 通常利用文件包含执行php://filter伪协议读取的源码会被服务器执行从而不会显示&#xf…
阅读更多...
重塑生态体系 深挖应用场景 萤石诠释AI时代智慧生活新图景

重塑生态体系 深挖应用场景 萤石诠释AI时代智慧生活新图景

7月24日&#xff0c;“智动新生&#xff0c;尽在掌控”2024萤石夏季新品发布会在杭州举办。来自全国各地的萤石合作伙伴、行业从业者及相关媒体&#xff0c;共聚杭州&#xff0c;共同见证拥抱AI的萤石&#xff0c;将如何全新升级&#xff0c;AI加持下的智慧生活又有何不同。 发…
阅读更多...
MATLAB学习日志DAY16

MATLAB学习日志DAY16

16.数组类型&#xff08;1&#xff09; 16.1多维数组 MATLAB 环境中的多维数组是具有多个下标的数组。创建多维数组的一种方法是调用具有多个参数的 zeros、ones、rand 或 randn。 R randn(3,4,5); 创建一个 345 数组&#xff0c;共包含 3*4*5 60 个正态分布的随机元素。…
阅读更多...
【Golang 面试基础题】每日 5 题（七）

【Golang 面试基础题】每日 5 题（七）

✍个人博客&#xff1a;Pandaconda-CSDN博客 &#x1f4e3;专栏地址&#xff1a;http://t.csdnimg.cn/UWz06 &#x1f4da;专栏简介&#xff1a;在这个专栏中&#xff0c;我将会分享 Golang 面试中常见的面试题给大家~ ❤️如果有收获的话&#xff0c;欢迎点赞&#x1f44d;收藏…
阅读更多...
升腾c92刷bios（一）

升腾c92刷bios（一）

一、刷机bios 原机的bios是不允许设备通过usb接口进行系统更换&#xff0c;需要输入boot的正好和密码才可以&#xff0c;可惜的是我们并不知道原机的密码是什么。 步骤如下&#xff1a; 1、u盘进行格式化为fat32格式 2、将c92的bios程序进行备份和升级&#xff08;文章结尾提…
阅读更多...
Mindspore框架循环神经网络RNN模型实现情感分类|（三）RNN模型构建

Mindspore框架循环神经网络RNN模型实现情感分类|（三）RNN模型构建

Mindspore框架循环神经网络RNN模型实现情感分类 Mindspore框架循环神经网络RNN模型实现情感分类|&#xff08;一&#xff09;IMDB影评数据集准备 Mindspore框架循环神经网络RNN模型实现情感分类|&#xff08;二&#xff09;预训练词向量 Mindspore框架循环神经网络RNN模型实现…
阅读更多...
数据集成工具之kettle

数据集成工具之kettle

Kettle 是一个用于数据集成的开源工具&#xff0c;由 Pentaho 开发&#xff0c;现已由 Hitachi Vantara 维护。Kettle 的全名是 Pentaho Data Integration (PDI)&#xff0c;主要用于数据提取、转换和加载&#xff08;ETL&#xff09;过程。 1. 核心组件 Spoon: 图形化的设计工…
阅读更多...
最新文章

Copyright @ 2022~2023