Webserver(2.6)有名管道

ops/2024/11/1 11:19:03/

目录

  • 有名管道
  • 有名管道使用
  • 有名管道的注意事项
  • 读写特性
  • 有名管道实现简单版聊天功能
    • 拓展:如何解决聊天过程的阻塞

有名管道

可以用在没有关系的进程之间,进行通信

有名管道使用

  • 通过命令创建有名管道
    mkfifo 名字
    在这里插入图片描述

  • 通过函数创建有名管道
    int mkfifo

#include <stdio.h>
#include <sys/types.h>
#include <sys/stat.h>
#include <string.h>
#include <stdlib.h>int main(){int ret=mkfifo("fifo1",0664);if(ret==-1){perror("mkfifo");exit(0);}return 0;
}

write.c

#include <stdio.h>
#include <sys/types.h>
#include <sys/stat.h>
#include <string.h>
#include <stdlib.h>
#include <unistd.h>
#include <fcntl.h>//向管道中写数据
int main(){//1.判断文件是否存在int ret=access("test",F_OK);if(ret==-1){printf("管道不存在,创建管道\n");//2.创建管道文件ret=mkfifo("test",0664);if(ret==-1){perror("mkfifo");exit(0);}   }//3.打开管道int fd=open("test",O_WRONLY);if(fd==-1){perror("open");exit(0);}//写数据for(int i=0;i<100;i++){char buf[1024];sprintf(buf,"hello,%d\n",i);printf("write data:%s\n",buf);write(fd,buf,strlen(buf));sleep(1);}close(fd);return 0;
}

读端read.c

#include <stdio.h>
#include <sys/types.h>
#include <sys/stat.h>
#include <string.h>
#include <stdlib.h>
#include <unistd.h>
#include <fcntl.h>//向管道中写数据
int main(){//1.打开管道文件int fd=open("test",O_RDONLY);if(fd==-1){perror("open");exit(0);}//读数据while(1){char buf[1024]={0};int len=read(fd,buf,sizeof(buf));if(len==0){printf("写端断开连接了..\n");break;}printf("recv buf:%s\n",buf);}close(fd);return 0;
}

在这里插入图片描述
读端和写端一起打开,才能写出数据
在这里插入图片描述
在这里插入图片描述

写端暂停之后,也读取不到了,就退出程序了
在这里插入图片描述在这里插入图片描述

如果先关闭读端,写端也立马终止程序了
读端关闭了,还在写数据,会产生信号,因为没有读端了还写数据,管道会破裂,所以产生信号立马终止。
在这里插入图片描述

有名管道的注意事项

1.一个为只读而打开一个管道的进程会阻塞,直到另外一个进程为只写打开管道
2.一个为只写而打开一个管道的进程会阻塞,直到另一个进程为只读打开管道(与上一个相对)

读写特性

读管道:
管道中有数据,read返回实际读到的字节数
管道中无数据,管道写端被全部关闭,read返回0(相当于读到文件末尾)
写端没有全部被关闭,read阻塞等待

写管道:
管道读端被全部关闭,进程会异常终止,进程会收到sigpipe信号。
管道读端没有被全部关闭,管道已经满了,write会阻塞,管道未满,write将数据写入,并返回实际写入的字节数

有名管道实现简单版聊天功能

如何实现互发呢?
创建两个管道,一个从A到B,一个从B到A
chatA

#include <stdio.h>
#include <sys/types.h>
#include <sys/stat.h>
#include <string.h>
#include <stdlib.h>
#include <unistd.h>
#include <fcntl.h>int main(){//1.判断有名管道文件是否存在int ret=access("fifo1",F_OK);if(ret==-1){//文件不存在printf("管道不存在,创建对应的有名管道\n");ret=mkfifo("fifo1",0664);if(ret==-1){perror("mkfifo");exit(0);}}ret=access("fifo2",F_OK);if(ret==-1){//文件不存在printf("管道不存在,创建对应的有名管道\n");ret=mkfifo("fifo2",0664);if(ret==-1){perror("mkfifo");exit(0);}}//2.以只写的方式打开管道fifo1int fdw=open("fifo1",O_WRONLY);if(fdw==-1){perror("open");exit(0);}printf("打开管道fifo1成功,等待写入...\n");//3.以只读的方式打开管道fifo2int fdr=open("fifo2",O_RDONLY);if(fdr==-1){perror("open");exit(0);}printf("打开管道fifo2成功,等待读取...\n");char buf[128];//4.循环的写读数据while(1){memset(buf,0,128);//获取标准输入的数据fgets(buf,128,stdin);//写数据ret=write(fdw,buf,strlen(buf));if(ret==-1){perror("write");exit(0);}//5.读管道数据memset(buf,0,128);ret=read(fdr,buf,128);if(ret<=0){perror("read");break;}printf("buf:%s\n",buf);}//6.关闭文件描述符close(fdr);close(fdw);return 0;
}

chatB

#include <stdio.h>
#include <sys/types.h>
#include <sys/stat.h>
#include <string.h>
#include <stdlib.h>
#include <unistd.h>
#include <fcntl.h>int main(){//1.判断有名管道文件是否存在int ret=access("fifo1",F_OK);if(ret==-1){//文件不存在printf("管道不存在,创建对应的有名管道\n");ret=mkfifo("fifo1",0664);if(ret==-1){perror("mkfifo");exit(0);}}ret=access("fifo2",F_OK);if(ret==-1){//文件不存在printf("管道不存在,创建对应的有名管道\n");ret=mkfifo("fifo2",0664);if(ret==-1){perror("mkfifo");exit(0);}}//2.以只读的方式打开管道fifo1int fdr=open("fifo1",O_RDONLY);if(fdr==-1){perror("open");exit(0);}printf("打开管道fifo1成功,等待读取...\n");//3.以只写的方式打开管道fifo2int fdw=open("fifo2",O_WRONLY);if(fdw==-1){perror("open");exit(0);}printf("打开管道fifo2成功,等待写入...\n");char buf[128];//4.循环的写读数据while(1){//5.读管道数据memset(buf,0,128);ret=read(fdr,buf,128);if(ret<=0){perror("read");break;}printf("buf:%s\n",buf);memset(buf,0,128);//获取标准输入的数据fgets(buf,128,stdin);//写数据ret=write(fdw,buf,strlen(buf));if(ret==-1){perror("write");exit(0);}}//6.关闭文件描述符close(fdr);close(fdw);return 0;
}

在这里插入图片描述
在这里插入图片描述

拓展:如何解决聊天过程的阻塞

读和写不能放到同一个文件中,因为必然会引起阻塞,每次写完都需要等待对方上一次读完才能发过去


http://www.ppmy.cn/ops/130118.html

相关文章

超子物联网HAL库笔记:准备篇

超子物联网 HAL库学习 汇总入口&#xff1a; 超子物联网HAL库笔记&#xff1a;[汇总] 写作不易&#xff0c;如果您觉得写的不错&#xff0c;欢迎给博主来一波点赞、收藏~让博主更有动力吧&#xff01; 1. HAL库简介 HAL库 HAL库&#xff08;Hardware Abstraction Layer&#…

采用STM32CubeMX和HAL库的模数转换器应用实例

目录 STM32的ADC配置流程 模/数&#xff08;A/D&#xff09;转换器应用的硬件设计 模/数&#xff08;A/D&#xff09;转换器应用的软件设计 1. 通过STM32CubeMX新建工程 2. 通过Keil MDK实现工程 STM32的ADC功能繁多&#xff0c;比较基础实用的是单通道采集&#xff0c;实…

统信UOS适配C#

通过Mono或.NET Core等运行时,在UOS上进行C#应用开发、编译、调试及部署变得便捷。 文章目录 一、环境部署1. C#开发环境安装2. C#开发环境配置二、 C#开发案例三、常见问题1. 图形界面支持2. 调试工具一、环境部署 1. C#开发环境安装 统信UOS V20使用dotnet 7.0 amd64版本,…

springboot框架使用RabbitMQ举例代码

以前分享过一个理论有兴趣的小伙伴可以看下 https://blog.csdn.net/Drug_/article/details/138164180 不多说 还是直接上代码 第一步&#xff1a;引入依赖 可以不指定版本 <!-- amqp --><dependency><groupId>org.springframework.boot</groupId…

Python 工具库每日推荐【Pillow】

文章目录 引言Python图像处理库的重要性今日推荐:Pillow工具库主要功能:使用场景:安装与配置快速上手示例代码代码解释实际应用案例案例:创建图像拼贴案例分析高级特性图像增强图像水印扩展阅读与资源优缺点分析优点:缺点:总结【 已更新完 TypeScript 设计模式 专栏,感兴…

计算机网络(Ⅶ)Web and HTTP

一些术语&#xff1a; Web页&#xff1a;由一些对象组成 对象可以是HTML文件&#xff0c;JPEG图像&#xff0c;Java小程序&#xff0c;声音剪辑文件等 Web页含有一个基本的HTML文件&#xff0c;该基本HTML文件又包含若干对象的引用&#xff08;链接&#xff09; 通过URL对每个对…

五、快速入门K8s之Pod容器的生命周期

一、容器的初始化init ⭐️ init c &#xff1a; init contariner 初始化容器&#xff0c;只是用来初始化&#xff0c;初始化完成就会死亡可以大于的等于一也可以没有&#xff0c;每个init只有在前一个init c执行完成后才可以执行下一个、init容器总是运行到成功完成为止&#…

大语言模型驱动的跨域属性级情感分析——论文阅读笔记

前言 论文PDF下载地址&#xff1a;7156 最近想搜一下基于大语言模型的情感分析论文&#xff0c;搜到了这篇在今年发表的论文&#xff0c;于是简单阅读之后在这里记一下笔记。 如图1所示&#xff0c;在餐厅领域中的"快"是上菜快&#xff0c;属于正面情感&#xff0c;但…