TCP/IP网络编程 第十六章:关于IO流分离的其他内容

分离I/O流


两次I/O流分离


我们之前通过2种方法分离过IO流,第一种是第十章的“TCPI/O过程(Routine)分离”。这种方法通过调用fork函数复制出1个文件描述符,以区分输入和输出中使用的文件描述符。虽然文件描述符本身不会根据输入和输出进行区分,但我们分开了2个文件描述符的用途,因此这也属于“流”的分离。
第二种分离在第十五章。通过2次fdopen函数的调用,创建读模式FILE指针(FILE结构体指针)和写模式FILE指针。换言之,我们分离了输入工具和输出工具,因此也可视为“流”的分离。下面说明分离的理由,讨论尚未提及的问题并给出解决方案。


分离“流”的好处


第10章的“流”分离和第15章的“流”分离在目的上有一定差异。首先分析第10章的“流”分离目的。
□通过分开输入过程(代码)和输出过程降低实现难度。
□与输入无关的输出操作可以提高速度

这是第10章讨论过的内容,故不再解释这些优点的原因。接下来给出第15章“流”分离的目的。
□为了将FILE指针按读模式和写模式如以区分。
□可以通过区分读写模式降低实现难度。
□通过区分IO缓冲提高缓冲性能
“流”分离的方法、情况(目的)不同时,带来的好处也有所不同。


“流”分离带来的EOF问题


下面讲解“流”分离带来的问题。第7章介绍过EOF的传递方法和半关闭的必要性(如果记
不清,请复习相应章节)。各位应该还记得如下函数调用语句:

shutdown(sock, SHUT_WR);


当时讲过调用shutdown函数的基于半关闭的EOF传递方法。10章还利用这些技术在示例中添加了半关闭相关代码。也就是说,第10章的“流”分离没有问题。但第15章的基于fdopen函数的“流”则不同,我们还不知道在这种情况下如何进行半关闭,因此有可能犯如下错误:
“半关闭?不是可以针对输出模式的FILE指针调用fclose函数吗?这样可以向对方传递EOF,变成可以接收数据但无法发送数据的半关闭状态呀。”各位是否也这么认为?这是一种很好的猜测,但希望大家先阅读下列代码。另外,接下来的示例中为了简化代码而未添加异常处理,希望各位不要误解。先给出服务器端代码。

#include<stdio.h>
#include<stdlib.h>
#include<string.h>
#include<unistd.h>
#include<arpa/inet.h>
#include<sys/socket.h>
#define BUF_SIZE 1024int main(int argc,char *argv[]){int serv_sock,clnt_sock;FILE* readfp;FILE* writefp;struct sockaddr_in serv_sock,clnt_sock;socklen_t clnt_addr_sz;char buf[BUF_SIZE]={0,};serv_sock=socket(PF_INET,SOCK_STREAM,0);memset(&serv_addr,0,sizeof(serv_addr));serv_addr.sin_family=AF_INET;serv_addr.sin_addr.s_addr=htonl(INADDR_ANY);serv_addr.sin_port=htons(atoi(argv[1]));bind(serv_sock,(struct sockaddr*)&serv_addr,sizeof(serv_addr));listen(serv_sock,5);clnt_addr_sz=sizof(clnt_sock);clnt_sock=accept(serv_sock,(struct sockaddr*)&clnt_addr,&clnt_addr_sz);readfp=fdopen(clnt_sock,"r");writefp=fdopen(clnt_sock,"w");fputs("FROM SERVER: HI~ client? \n",writefp);fputs("I love all of the world \n",writefp);fputs("You are awesome! \n",writefp);fflush(writefp);fclose(writefp);fgets(buf,sizeof(buf),readfp);fputs(buf,stdout);fclose(readfp);return 0;
}

有些人可能认为可以通过第39行的函数调用接受客户端最后发送的字符串。上述示例调用fclose函数后的确会发送EOF。稍后给出的客户端收到EOF后也会发送最后的字符串,只是需要验证第39行的函数调用能否接受。接下来给出客户端代码。

#include<"头文件声明和服务器端声明一样,故省略">
#define BUF_SIZE 1024int main(int argc,char *argv[]){int sock;char buf[BUF_SIZE];struct sockaddr_in serv_addr;FILE * readfp;FILE * writefp;sock=socket(PF_INET,SOCK_STREAM,0);memset(&serv_addr,0,sizepf(serv_addr));serv_addr.sin_family=AF_INET;serv_addr.sin_addr.s_addr=inet_addr(argv[1]);serv_addr.sin_port=htons(atoi(argv[2]));connect(sock,(struct sockaddr*)&serv_addr,sizeof(serv_addr));readfp=fdopen(sock,"r");writefp=fdopen(sock,"w");while(1){if(fgets(buf,sizeof(buf),readfp)==NULL)break;fputs(buf,stdout);fflush(stdout);}fputs("FROM CLIENT: Thank you! \n",writefp);fflush(writefp);fclose(writefp);fclose(readfp);return 0;
}

从运行结果可以得出以下结论:“服务器端未能接受由客户端传来的最后的字符串!”。

很容易判断其原因::在服务器示例中的第38行调用的fclose函数完全终止了套接字,而不是半关闭。以上就是需要通过本章解决的问题。

文件描述符的复制和半关闭

终止"流"时无法半关闭的原因

 这张图描述了之前示例中服务器端的两个文件指针。那么一切就真相大白了。当读指针调用fclose函数的时候会关闭文件描述符,此时会关闭套接字。那么如何解决呢?不就是创建FILE指针前先复制文件描述符即可。

 如图所示,复制后另外创建1个文件描述符,然后利用各自的文件描述符生成读模式FILE指针和写模式FILE指针。这就为半关闭准备好了环境,因为套接字和文件描述符之间具有如下关系:

"销毁所有文件描述符后才能销毁套接字"

也就是说,针对写模式FILE指针调用fclose函数时,只能销毁与该FILE指针相关的文件描述符,无法销毁套接字。

那此时的状态是否为半关闭状态?不是!只是准备好了半关闭环境。要进入真正的半关闭状态需要特殊处理。仔细观察,还剩1个文件描述符。而且该文件描述符可以同时进行IO因此,不但没有发送EOF,而且仍然可以利用文件描述符进行输出。稍后将介绍发送EOF并进入半关闭状态的方法。首先介绍如何复制文件描述符,之前的fork函数不在考虑范围内。

复制文件描述符

之前所提到的文件描述符复制与fork函数中进行的复制有所区别。调用fork函数时将复制整个进程,此时的复制从某种意义上是复制到另一个进程中。但是这里提到的复制是可以在同一个进程内完成文件描述符的复制。当然,文件描述符的值不能重复,因此要使用互不相同的值。为了形成这种结构,需要复制文件描述符。此处所谓的"复制"具有如下含义:"为了访问同一文件或套接字,创建另外一个文件描述符。"

dup&dup2

下面给出文件描述符的复制方法,通过下列两个函数之一完成。

#include<unistd.h>
int dup(int fildes);
int dup2(int fildes,int fildes2);
//成功时返回复制的文件描述符,失败时返回-1fildes     //需要复制的文件描述符fildes2    //明确指定的文件描述符整数值

dup2函数明确指定复制的文件描述符整数值。向其传递大于0且小于进程能生成的最大文件描述符值时,该值将成为复制出的文件描述符的值。

复制文件描述符后"流"的分离

下面我们的目的就是使之前的服务器客户端模型正常工作。所谓"正常"工作是指,通过服务器端的半关闭状态接收客户端最后发出的字符串。当然,为了完成这一任务,服务端需要同时发送EOF。下面是示例代码:

#include<"头文件和之前的示例相同,故省略">
#define BUF_SIZE 1024int main(int argc,char*argv[]){int serv_sock,clnt_sock;FILE *readfp;FILE *writefp;struct sockaddr_in serv_addr,clnt_addr;socklen_t clnt_addr_sz;char buf[BUF_SIZE]={0,};serv_sock=socket(PF_INET,SOCK_STREAM,0);memset(&serv_addr,0,sizeof(serv_addr));serv_addr.sin_family=AF_INET;serv_addr.sin_addr.s_addr=htonl(INADDR_ANY);serv_addr.sin_port=htons(atoi(argv[1]));bind(serv_sock,(struct sockadd*)&serv_addr,sizeof(serv_addr));listen(serv_sock,5);clnt_addr_sz=sizeof(clnt_addr);clnt_sock=accept(serv_sock,(struct sockaddr*)&clnt_addr,&clnt_addr_sz);readfp=fdopen(clnt_sock,"r");writefp=fdopen(dup(clnt_sock),"w");fputs("FROM SERVER: HI~ client? \n",writefp);fputs("I love all of the world \n".writefp);fputs("You are awesome! \n",writefp);fflush(writefp);shutdown(fileno(writefp),SHUT_WR);fclose(writefp);//关闭并发送EOFfgets(buf,sizeof(buf),readfp);fputs(buf,stdout);fclose(readfp);return 0;
}

结果证明服务器端在半关闭的情况下向客户端发送了EOF,通过该示例希望大家掌握一点:"

无论复制出多少文件描述符,均应调用shutdown函数发送EOF并进入半关闭状态"

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

如若内容造成侵权/违法违规/事实不符,请联系多彩编程网进行投诉反馈email:809451989@qq.com,一经查实,立即删除!

相关文章

Spring框架概述及核心设计思想

文章目录 一. Spring框架概述1. 什么是Spring框架2. 为什么要学习框架&#xff1f;3. Spring框架学习的难点 二. Spring核心设计思想1. 容器是什么&#xff1f;2. IoC是什么&#xff1f;3. Spring是IoC容器4. DI&#xff08;依赖注入&#xff09;5. DL&#xff08;依赖查找&…

数据结构_进阶(1):搜索二叉树

1.内容 建议再看这节之前能对C有一定了解 二叉树在前面C的数据结构阶段时有出过&#xff0c;现在我们对二叉树来学习一些更复杂的类型&#xff0c;也为之后C学习的 map 和 set 做铺垫 1. map和set特性需要先铺垫二叉搜索树&#xff0c;而二叉搜索树也是一种树形结构2. 二叉搜…

Stable Diffusion生成图片参数查看与抹除

前几天分享了几张Stable Diffusion生成的艺术二维码&#xff0c;有同学反映不知道怎么查看图片的参数信息&#xff0c;还有的同学问怎么保护自己的图片生成参数不会泄露&#xff0c;这篇文章就来专门分享如何查看和抹除图片的参数。 查看图片的生成参数 1、打开Stable Diffus…

Ubuntu 安装 Docker

本文目录 1. 卸载旧版本 Docker2. 更新及安装工具软件2.1 更新软件包列表2.2 安装几个工具软件2.3 增加一个 docker 的官方 GPG key2.4 下载仓库文件 3. 安装 Docker3.1 再次更新系统3.2 安装 docker-ce 软件 4. 查看是否启动 Docker5. 验证是否安装成功 1. 卸载旧版本 Docker …

【iOS】—— 属性关键字及weak关键字底层原理

文章目录 先来看看常用的属性关键字有哪些&#xff1a;内存管理有关的的关键字&#xff1a;&#xff08;weak&#xff0c;assign&#xff0c;strong&#xff0c;retain&#xff0c;copy&#xff09;关键字weak关键字assignweak 和 assign 的区别&#xff1a;关键字strong&#…

React(3)

1.案例选项卡 import React, { Component } from reactexport default class App extends Component {state{tabList:[{id:1,text:"电影"},{id:2,text:"影院"},{id:3,text:"我的"}]}render() {return (<div><ul>{this.state.tabList…

【LocalSend】开源跨平台的局域网文件传输工具,支持IOS、Android、Mac、Windows、Linux

工作前提条件&#xff1a;设备使用相同的局域网。 LocalSend is a cross-platform app that enables secure communication between devices using a REST API and HTTPS encryption. Unlike other messaging apps that rely on external servers, LocalSend doesn’t require …

【经济调度】基于多目标宇宙优化算法优化人工神经网络环境经济调度研究(Matlab代码实现)

目录 &#x1f4a5;1 概述 &#x1f4da;2 运行结果 &#x1f389;3 参考文献 &#x1f308;4 Matlab代码及数据 &#x1f4a5;1 概述 基于多目标宇宙优化算法&#xff08;Multi-Objective Universe Optimization Algorithm, MOUA&#xff09;优化人工神经网络环境经济调度是一…

预付费电表收费系统

预付费电表收费系统是一种先进的电表管理系统&#xff0c;它能够帮助电力公司更加高效地管理电表收费&#xff0c;提高用电效率&#xff0c;降低能源浪费。本文将从以下几个方面介绍预付费电表收费系统的特点和优势。 一、预付费电表收费系统的原理 预付费电表收费系统是指用户…

Hadoop集群启动常见错误

错误一 &#xff1a; 配置文件错误 解决方案&#xff1a;检查配置文件&#xff0c;修改错误。重新分发&#xff08;同步&#xff09; 常见错误二 &#xff1a; 重复格式化 DataNode NameNode 在格式化时如果发现下面的提示说明重复格式化了 datanode和namenode的集群id…

Spring Cloud 远程接口调用OpenFeign负载均衡实现原理详解

环境&#xff1a;Spring Cloud 2021.0.7 Spring Boot 2.7.12 配置依赖 maven依赖 <dependency><groupId>org.springframework.cloud</groupId><artifactId>spring-cloud-starter-openfeign</artifactId> </dependency> <dependency&…

一百三十、海豚调度器——用DolphinScheduler定时调度HiveSQL任务

一、目标 用海豚调度器对Hive数仓各层数据库的SQL任务进行定时调度。比如&#xff0c;DWD层脱敏清洗表的动态插入数据、DWS层指标表的动态插入数据 二、工具版本 1、海豚调度器&#xff1a;apache-dolphinscheduler-2.0.5-bin.tar.gz 2、Hive&#xff1a;apache-hive-3.1.2…

长短期记忆网络(LSTM)原理解析

长短期记忆网络&#xff08;Long Short-Term Memory&#xff0c;简称LSTM&#xff09;是一种常用于处理序列数据的深度学习模型。它在循环神经网络&#xff08;Recurrent Neural Network&#xff0c;RNN&#xff09;的基础上进行了改进&#xff0c;旨在解决传统RNN中的梯度消失…

PyTorch训练RNN, GRU, LSTM:手写数字识别

文章目录 pytorch 神经网络训练demoResult参考来源 pytorch 神经网络训练demo 数据集&#xff1a;MNIST 该数据集的内容是手写数字识别&#xff0c;其分为两部分&#xff0c;分别含有60000张训练图片和10000张测试图片 图片来源&#xff1a;https://tensornews.cn/mnist_intr…

Kafka消息监控管理工具Offset Explorer的使用教程

1、kafka监控管理工具 Offset Explorer是一款用于监控和管理Apache Kafka集群中消费者组偏移量的开源工具。它提供了一个简单直观的用户界面&#xff0c;用于查看和管理Kafka消费者组偏移量的详细信息。 Offset Explorer具有以下主要功能和特点&#xff1a; 实时监控&#x…

架构训练营学习笔记3-5:消息队列备选架构设计实战

本文属于架构训练营学习笔记系列&#xff1a;模块3的案例讲解 总的来说&#xff0c;这篇从更高的维度去讲&#xff0c;而不是关注消息队列的常见问题&#xff1a;比如消息如何发送&#xff0c;消息如何不丢失 &#xff0c;消息如何不重复。总体上分为2部分&#xff1a;利益干系…

【Docker】什么是Docker,它用来干什么

作者简介&#xff1a; 辭七七&#xff0c;目前大一&#xff0c;正在学习C/C&#xff0c;Java&#xff0c;Python等 作者主页&#xff1a; 七七的个人主页 文章收录专栏&#xff1a; 七七的闲谈 欢迎大家点赞 &#x1f44d; 收藏 ⭐ 加关注哦&#xff01;&#x1f496;&#x1f…

ADB初识

ADB是Android Debug Bridge&#xff0c;是一个命令行程序。abd可以从计算机上通过USB控制Android手机设备。可以使用ADB复制文件、安装和卸载应用程序&#xff0c;运行shell命令等。 ADB的下载配置 Windows版本&#xff1a;https://dl.google.com/android/repository/platform…

2.SpringBoot运维实用篇

SpringBoot运维实用篇 ​ ​ 下面就从运维实用篇开始讲&#xff0c;在运维实用篇中&#xff0c;我给学习者的定位是玩转配置&#xff0c;为开发实用篇中做各种技术的整合做好准备工作。 主要分为以下内容&#xff1a; SpringBoot程序的打包与运行配置高级多环境开发日志 ​…

C国演义 [第十二章]

第十二章 打家劫舍题目理解步骤dp数组递推公式初始化遍历顺序 代码 打家劫舍II题目理解步骤递推公式初始化遍历顺序 代码 打家劫舍 力扣链接 你是一个专业的小偷&#xff0c;计划偷窃沿街的房屋。每间房内都藏有一定的现金&#xff0c;影响你偷窃的唯一制约因素就是相邻的房屋…