Rust写入命名管道：数据仅在程序退出时显示，如何实现实时输出？

你的问题根源在于文件缓冲机制和tail -f的行缓冲行为，只需两个修改就能实现实时输出：

修改要点 #

• 给发送的字符串添加换行符：tail -f默认按行输出，只有收到换行符才会立即刷新显示；
• 显式刷新管道文件的缓冲区：Rust的File默认用块缓冲，数据会暂存内存，必须调用flush()强制写入管道。

修改后的完整代码 #

use termion::event::Key;
use termion::input::TermRead;
use termion::raw::IntoRawMode;
use std::io::Write;
use std::fs::{File, OpenOptions};

fn send_data(file: &mut File, payload: &str) -> Result<(), std::io::Error> {
    // 拼接换行符，确保完整写入
    file.write_all(format!("{payload}\n").as_bytes())?;
    // 强制刷新缓冲区，将数据写入管道
    file.flush()?;
    Ok(())
}

fn main() {
    let mut file = OpenOptions::new()
        .write(true)
        .open("/tmp/my_named_pipe")
        .expect("Failed to open named pipe for writing");

    let mut stdout = std::io::stdout().into_raw_mode().unwrap();
    stdout.flush().unwrap();

    loop {
        let key = match std::io::stdin().keys().next() {
            Some(Ok(input)) => input,
            _ => break,
        };
        match key { // 按x发送数据，q退出
            Key::Char('q') => break,
            Key::Char('x') => send_data(&mut file, "foobar").unwrap(),
            _ => (),
        }
    }
}

细节说明 #

1. write_all替代write：确保整个字符串（含换行符）被完整写入，避免部分数据滞留缓冲区；
2. flush()的作用：强制将用户态缓冲区的数据刷入内核管道，让接收端能立即读取；
3. 关于换行符：如果不需要换行，也可以用tail -f --line-buffered命令监听，它会强制tail实时输出所有收到的数据，无需等待换行。

内容的提问来源于stack exchange，提问作者Kolja