Haskell流处理时出现Broken Pipe错误求助

错误原因 #

Broken pipe 错误本质是接收端（mplayer）已终止，但代码还在尝试向其输入流写入数据。触发问题的核心原因有两点：

1. 格式不兼容：你用yt-dlp指定了bv+ba（视频+音频合并流），mplayer处理这种混合流时可能因格式解析失败提前退出，导致管道断裂。
2. 缺少错误处理与流程控制：
   • 当yt-dlp输出流耗尽（返回Nothing）时，代码陷入无限循环，持续空转；
   • 未监听mplayer的运行状态，即使它崩溃或正常结束，代码仍继续写入；
   • 未处理write操作的失败情况，管道断裂时直接抛出未捕获的异常。

修复方案 #

1. 指定纯音频格式：让yt-dlp输出mplayer能稳定处理的纯音频流，替换-f bv+ba为-f bestaudio。
2. 添加进程状态监听：跟踪mplayer的运行状态，一旦它退出就停止写入并清理资源。
3. 完善流处理逻辑：
   • 输入流耗尽时主动关闭输出流并退出循环；
   • 捕获write操作的异常，避免程序直接崩溃。

修改后的代码 #

import Control.Concurrent
import System.IO.Streams 
import Data.ByteString
import System.Process (runInteractiveCommand, waitForProcess, ProcessHandle)
import Control.Exception (catch, IOException)

main = do
  -- 启动mplayer并保存进程句柄，用于监听运行状态
  (sink, _, _, mplayerProc) <- runInteractiveCommand "mplayer -novideo -cache 5096 -"
  mainSink <- lockingOutputStream sink

  -- 启动线程监听mplayer，进程退出时立即关闭输出流
  forkIO $ do
    _ <- waitForProcess mplayerProc
    close mainSink

  -- 启动yt-dlp，输出纯音频流
  (_, source, _, _) <- runInteractiveCommand "yt-dlp \"https://www.youtube.com/watch?v=uFtfDK39ZhI\" -f bestaudio -o -"
  
  -- 处理流传输，捕获IO异常避免崩溃
  catch (loop mainSink source)
        (\e -> print (e :: IOException))

loop :: OutputStream ByteString -> InputStream ByteString -> IO ()
loop sink src = do
  sourceBytes <- read src
  case sourceBytes of
    Nothing -> close sink  -- 输入流耗尽，关闭输出流后退出
    Just bs -> do
      writeResult <- write bs sink
      case writeResult of
        Nothing -> return ()  -- 输出流已关闭，直接退出循环
        Just _ -> loop sink src

关键改动说明 #

• 用bestaudio替换bv+ba，确保输出纯音频流，避免mplayer因格式问题提前退出；
• 新增线程监听mplayer的进程句柄，进程退出时立即关闭输出流，阻止后续无效写入；
• 移除冗余的peek操作，直接用read处理流，避免空转；
• 处理write的返回值：若返回Nothing说明输出流已关闭，直接退出循环；
• 添加IOException捕获，出现错误时优雅打印信息而非直接崩溃。

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