c++怎么利用iostream实现类似管道的文件传输_双向流缓冲代理【进阶】

冬辰姑娘_1003

冬辰姑娘_1003

2026-03-25

850人浏览

原创

需继承std::streambuf自定义双向代理,分离读写缓冲区并重载underflow()、overflow()、sync()和showmanyc();不可直接用std::iostream或std::filebuf绑定单fd实现双工,因POSIX要求pipe两端fd方向严格分离。

c++怎么利用iostream实现类似管道的文件传输_双向流缓冲代理【进阶】

std::streambuf 怎么代理两个方向的 I/O?

不能直接用 std::iostream 做双向管道代理——它底层的 std::streambuf 默认只支持单向缓冲(in 或 out 之一),强行复用会导致读写互相干扰、数据错位或 underflow()/overflow() 无限递归。

真正可行的做法是继承 std::streambuf,自己管理两套缓冲区:一套供 sgetc()/snextc() 等读操作使用,另一套供 sputc()/sputn() 等写操作使用,并重载 underflow()、overflow()、sync() 和 showmanyc()。

  • underflow() 负责从「输入源」(比如另一个 std::streambuf*)拉数据进读缓冲区,返回下一个可读字符
  • overflow(int c) 把字符 c 或写缓冲区内容推给「输出目标」,返回 traits_type::not_eof(c) 表示成功
  • sync() 必须显式调用,用于刷新写缓冲并确保读缓冲已同步(否则可能漏读刚写入的数据)
  • 别忘了在构造时用 setg() 和 setp() 初始化读/写缓冲指针,否则一读就崩

为什么不能直接 std::pipe + std::iostream?

Linux 的 pipe() 返回两个 fd,但 std::filebuf 只接受单个 fd 且绑定后方向固定:用 open("fd://123", std::ios::in) 就只能读,再想写会失败;反之亦然。C++ 标准库没有原生支持全双工 fd 的流缓冲区。

常见错误现象:std::iostream 构造后调 write() 成功但 read() 返回 0,或反复 read() 却始终阻塞——本质是底层 filebuf 把同一个 fd 同时当读端和写端用了,触发内核级未定义行为。

  • POSIX 要求 pipe fd 对必须分开:一个只读,一个只写
  • std::filebuf::open() 不校验 fd 方向,但系统调用 read()/write() 会按 open flags 拒绝非法操作
  • 若硬要“伪双向”,得用 socketpair(AF_UNIX, SOCK_STREAM, 0, ...) 替代 pipe(),再分别用两个 std::filebuf 绑定两端

std::iostream 双向代理的实际性能陷阱

自己写的 streambuf 代理层不是零成本——每次 read() 或 write() 都多一层虚函数调用和缓冲区拷贝。尤其在高频小包场景下,比直接用 read()/write() 慢 2–5 倍。

更隐蔽的问题是缓冲策略冲突:比如代理对象内部用 4KB 读缓冲,但上游数据以 64 字节分片到达,就会频繁触发 underflow(),而每次都要重新从源头拉数据,无法预取。

C++14
C++14

C++14 对 C++11 的修正与增强版本,适合旧系统维护和较老工具链兼容。

下载
  • 避免在代理 streambuf 中做阻塞等待:把 underflow() 设为非阻塞,由上层控制超时逻辑
  • 如果上下游都是内存 buffer(比如两个 std::vector<char></char>),优先用指针直连,绕过 streambuf 层
  • sync() 调用开销大,别在每字节后都调;批量写完再刷一次更稳

一个最小可用的双向 streambuf 示例骨架

下面这个类把读写缓冲分离,支持传入两个独立的 std::streambuf*(如分别来自 std::cin.rdbuf() 和 std::cout.rdbuf()):

class bidir_proxy : public std::streambuf {
    std::streambuf* in_;
    std::streambuf* out_;
    std::vector<char> in_buf_, out_buf_;
<p>public:
bidir<em>proxy(std::streambuf<em> in, std::streambuf</em> out)
: in</em>(in), out_(out), in<em>buf</em>(4096), out<em>buf</em>(4096) {
setg(in<em>buf</em>.data(), in<em>buf</em>.data(), in<em>buf</em>.data());
setp(out<em>buf</em>.data(), out<em>buf</em>.data(), out<em>buf</em>.data() + out<em>buf</em>.size());
}</p>
<p>protected:
int underflow() override {
if (gptr() >= egptr()) {
auto n = in_->sgetn(in<em>buf</em>.data(), in<em>buf</em>.size());
setg(in<em>buf</em>.data(), in<em>buf</em>.data(), in<em>buf</em>.data() + n);
}
return gptr() </p>
<pre class="brush:php;toolbar:false;">int overflow(int c) override {
    if (c != traits_type::eof()) {
        *pptr() = static_cast<char>(c);
        pbump(1);
    }
    return sync() == 0 ? traits_type::not_eof(c) : traits_type::eof();
}

int sync() override {
    auto n = pptr() - pbase();
    if (n > 0) {
        out_->sputn(pbase(), n);
        setp(out_buf_.data(), out_buf_.data(), out_buf_.data() + out_buf_.size());
    }
    return 0;
}</char>

};

用法:bidir_proxy proxy(cin.rdbuf(), cout.rdbuf()); std::iostream io(&proxy);。注意:这仅适用于同进程内流代理,跨进程仍需 socket/pipe + 多线程协调。

最容易被忽略的是 showmanyc() ——如果你希望 io.peek() 正常工作,必须重载它并返回当前读缓冲中可用字节数,否则 peek 总是返回 traits_type::eof()。

C++免费学习笔记(深入):立即使用
在学习笔记中,你将探索 C++ 的入门与实战技巧!

相关文章

c++速学教程(入门到精通)
c++速学教程(入门到精通)

c++怎么学习?c++怎么入门?c++在哪学?c++怎么学才快?不用担心,这里为大家提供了c++速学教程(入门到精通),有需要的小伙伴保存下载就能学习啦!

下载

相关标签:

c++ stream

本站声明:本文内容由网友自发贡献,版权归原作者所有,本站不承担相应法律责任。如您发现有涉嫌抄袭侵权的内容,请联系admin@php.cn

相关专题

更多
string转int
string转int

在编程中,我们经常会遇到需要将字符串(str)转换为整数(int)的情况。这可能是因为我们需要对字符串进行数值计算,或者需要将用户输入的字符串转换为整数进行处理。php中文网给大家带来了相关的教程以及文章,欢迎大家前来学习阅读。

2023.08.02

6659

3

int占多少字节
int占多少字节

int占4个字节,意味着一个int变量可以存储范围在-2,147,483,648到2,147,483,647之间的整数值,在某些情况下也可能是2个字节或8个字节,int是一种常用的数据类型,用于表示整数,需要根据具体情况选择合适的数据类型,以确保程序的正确性和性能。本专题为大家提供相关的文章、下载、课程内容,供大家免费下载体验。

2024.08.29

3225

6

c++怎么把double转成int
c++怎么把double转成int

本专题整合了 c++ double相关教程,阅读专题下面的文章了解更多详细内容。

2025.08.29

4168

10

C++中int的含义
C++中int的含义

本专题整合了C++中int相关内容,阅读专题下面的文章了解更多详细内容。

2025.08.29

2845

10

C++ 智能指针与现代内存管理
C++ 智能指针与现代内存管理

深入讲解 C++ 现代内存管理的核心工具——智能指针,涵盖 unique_ptr 独占所有权语义、shared_ptr 引用计数机制与循环引用问题、weak_ptr 弱引用的应用场景、make_unique/make_shared 工厂函数的性能优势、自定义删除器的编写、RAII 资源管理思想的实践,以及从裸指针迁移到智能指针的重构策略,帮助开发者编写安全无泄漏的现代 C++ 代码。

2026.04.23

379

31

线程和进程的区别
线程和进程的区别

线程和进程的区别:线程是进程的一部分,用于实现并发和并行操作,而线程共享进程的资源,通信更方便快捷,切换开销较小。本专题为大家提供线程和进程区别相关的各种文章、以及下载和课程。

2023.08.10

4358

6

Python 多线程与异步编程实战
Python 多线程与异步编程实战

本专题系统讲解 Python 多线程与异步编程的核心概念与实战技巧,包括 threading 模块基础、线程同步机制、GIL 原理、asyncio 异步任务管理、协程与事件循环、任务调度与异常处理。通过实战示例,帮助学习者掌握 如何构建高性能、多任务并发的 Python 应用。

2025.12.24

1209

20

java多线程相关教程合集
java多线程相关教程合集

本专题整合了java多线程相关教程,阅读专题下面的文章了解更多详细内容。

2026.01.21

423

30

C++多线程相关合集
C++多线程相关合集

本专题整合了C++多线程相关教程,阅读专题下面的的文章了解更多详细内容。

2026.01.21

559

24

热门下载

更多
网站特效
/
网站源码
/
网站素材
/
前端模板

精品课程

更多
相关推荐
/
热门推荐
/
最新课程
C++ Core Guidelines
C++ Core Guidelines

共0课时 | 0人学习

C++ Reference
C++ Reference

共0课时 | 0人学习

C++ 官方标准说明
C++ 官方标准说明

共0课时 | 0人学习