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

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(),而每次都要重新从源头拉数据,无法预取。
- 避免在代理
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++ 的入门与实战技巧!











