Flutter如何将Process的stdout输出流绑定到StreamBuilder组件

• 流逻辑存在根本性错误：Process.start返回的进程实例的stdout本身就是Stream<List<int>>类型的原生流，不需要手动写死循环定时读取。你当前的写法只是将流转换器对象直接转为字符串输出，根本拿不到进程实际输出的内容，同时死循环没有退出条件，就算进程结束也会一直运行占用资源。
• StreamBuilder逻辑错误：builder方法会在每次流推送新数据、状态变化时触发，直接在方法内部拼接外部的executionOutput变量会导致内容被重复追加，出现大量重复输出。

1. 进程输出流逻辑 #

// 可将process定义为State类的成员变量，方便后续销毁时kill进程
Process? _process;

Stream<String> getOutput() async* {
  // 启动外部进程，加-u参数关闭python默认的输出缓冲，确保输出实时推送
  _process = await Process.start('python.exe', ['-u', 'streamData.py']);
  // 直接将stdout字节流解码为字符串流返回，无需手动轮询，进程结束后流会自动关闭
  yield* _process!.stdout.transform(utf8.decoder);
  // 如需同时捕获标准错误输出，可使用StreamGroup合并两个流（需要先导入async包）
  // yield* StreamGroup.merge([
  //   _process!.stdout.transform(utf8.decoder),
  //   _process!.stderr.transform(utf8.decoder)
  // ]);
}

2. 组件层代码 #

首先在对应State类中定义全局变量：

// 累积输出的缓冲区
final StringBuffer _outputBuffer = StringBuffer();
// 滚动控制器
final ScrollController _scrollController = ScrollController();

StreamBuilder实现：

StreamBuilder<String>(
  stream: getOutput(),
  builder: (BuildContext context, AsyncSnapshot<String> snapshot) {
    // 收到新输出时追加到缓冲区
    if (snapshot.hasData) {
      _outputBuffer.write(snapshot.data);
    }
    // 异常处理逻辑
    if (snapshot.hasError) {
      return SingleChildScrollView(
        controller: _scrollController,
        reverse: true,
        child: Text('运行出错：${snapshot.error}'),
      );
    }
    // 加载中、运行中、运行结束状态通用返回，直接展示累积的输出
    return SingleChildScrollView(
      controller: _scrollController,
      reverse: true,
      child: Text(_outputBuffer.toString()),
    );
  }
)

3. 资源释放逻辑 #

在页面销毁时手动杀死进程、释放控制器，避免后台残留进程：

@override
void dispose() {
  _process?.kill();
  _scrollController.dispose();
  super.dispose();
}

• 如果不想在启动python时加-u参数，也可以在python脚本的所有print方法中添加flush=True参数，强制每次打印都刷新输出缓冲，避免输出延迟推送。
• 如果页面会多次重建，不要直接在stream参数中调用getOutput()，会导致每次重建都启动新进程。建议将流实例存在State变量中，在initState方法中完成初始化，只启动一次进程。

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