Tauri项目中实时推送外部可执行程序日志至前端的问题

核心修改方案 #

你的问题根源在于两个点：一是使用了标准库的同步Command和BufReader，在Tokio异步任务中会阻塞读取；二是外部程序在非终端环境下通常会启用全缓冲，不会实时输出日志。以下是修复后的代码：

use tauri::Window;
use tokio::io::{AsyncBufReadExt, AsyncRead};
use tokio::process::Command; // 使用Tokio的异步Command

#[tauri::command(async)]
pub async fn run_executable(window: Window) {
    // 初始化异步命令
    let mut cmd = Command::new("../executables/pwdemo");
    cmd.stdout(tokio::process::Stdio::piped());

    // 启动子进程
    let mut child = cmd.spawn().expect("Failed to execute command");
    let stdout = child.stdout.take().expect("Failed to capture stdout");

    // 异步读取stdout并实时推送
    tokio::spawn(async move {
        let reader = tokio::io::BufReader::new(stdout);
        let mut lines = reader.lines();

        while let Some(line) = lines.next_line().await.expect("Failed to read line") {
            window.emit("logMessage", Some(line))
                .expect("Failed to emit event");
        }
    });

    // 异步等待子进程结束，不阻塞事件循环
    let _ = child.wait().await.expect("Failed to wait for child process");
}

关键修改说明 #

1. 替换为Tokio异步Command：用tokio::process::Command替代标准库的同步实现，确保所有操作都是异步非阻塞的，不会卡住Tauri的事件循环。
2. 异步读取流：使用tokio::io::BufReader和next_line().await的异步读取逻辑，能在新日志行产生时立即读取并推送给前端。
3. 异步等待子进程：用child.wait().await替代同步等待，避免阻塞当前异步任务的执行。

处理外部程序的缓冲问题 #

如果修改后仍无法实时输出，大概率是外部程序pwdemo在非终端环境下启用了全缓冲，可通过以下两种方式解决：

• 方式一：修改外部程序代码：若pwdemo是你自行开发的，在输出日志后手动调用缓冲刷新方法，比如C/C++的fflush(stdout)、Rust的std::io::stdout().flush()，强制输出缓冲内容。
• 方式二：模拟终端环境：使用tokio-pty-process库创建伪终端，让外部程序误以为运行在终端中，自动切换为行缓冲。示例代码片段：

  use tauri::Window;
  use tokio_pty_process::Command; // 需要添加tokio-pty-process依赖
  
  #[tauri::command(async)]
  pub async fn run_executable(window: Window) {
      let mut cmd = Command::new("../executables/pwdemo");
      let mut child = cmd.spawn().expect("Failed to spawn process");
      let mut reader = child.pty().expect("Failed to get pty");
  
      tokio::spawn(async move {
          let mut buf = [0; 1024];
          while let Ok(n) = reader.read(&mut buf).await {
              if n == 0 {
                  break;
              }
              let line = String::from_utf8_lossy(&buf[..n]).trim().to_string();
              window.emit("logMessage", Some(line))
                  .expect("Failed to emit event");
          }
      });
  
      let _ = child.wait().await.expect("Failed to wait for process");
  }
  

  需在Cargo.toml中添加依赖：tokio-pty-process = "0.4"（版本号以最新稳定版为准）。

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