Java调用Sox play播放网络电台流音频中途停止问题求助

核心原因推测 #

Java通过Runtime.exec启动的子进程和终端环境存在差异，最常见的问题是未处理子进程的标准输出/错误输出缓冲区阻塞，或者环境变量不完整导致进程异常挂起而非退出。

具体解决思路 #

1. 必须处理子进程的标准输出和错误输出 #

终端运行play时，系统会自动接管stdout/stderr的输出，但Java子进程的这些流如果不主动读取，缓冲区满后会导致进程阻塞（即使没有可见输出，也可能有底层调试信息或空输出占用缓冲区）。

实现方式：启动独立线程读取stdout和stderr，避免缓冲区阻塞：

Process p = Runtime.getRuntime().exec(new String[]{"play", "--magic", station}, new String[]{"AUDIODEV=pcm.radsound"});

// 启动线程读取stdout
new Thread(() -> {
    try (BufferedReader reader = new BufferedReader(new InputStreamReader(p.getInputStream()))) {
        String line;
        while ((line = reader.readLine()) != null) {
            // 可以写入日志或打印，即使是空内容也要读取
            System.out.println("[PLAY stdout] " + line);
        }
    } catch (IOException e) {
        e.printStackTrace();
    }
}).start();

// 启动线程读取stderr
new Thread(() -> {
    try (BufferedReader reader = new BufferedReader(new InputStreamReader(p.getErrorStream()))) {
        String line;
        while ((line = reader.readLine()) != null) {
            System.err.println("[PLAY stderr] " + line);
        }
    } catch (IOException e) {
        e.printStackTrace();
    }
}).start();

// 等待进程结束
int exitCode = p.waitFor();
System.out.println("Play进程退出，代码：" + exitCode);

2. 传递完整的环境变量 #

Runtime.exec的环境参数只传入了AUDIODEV，而终端运行时拥有完整的系统环境变量（如PATH、HOME、LC_ALL等），play进程可能在运行中依赖这些变量，缺失后会出现隐性异常但不退出。

解决方法：获取当前Java进程的环境变量，添加AUDIODEV后传给子进程：

// 获取当前环境变量
Map<String, String> env = new HashMap<>(System.getenv());
env.put("AUDIODEV", "pcm.radsound");

// 转换为字符串数组
String[] envArray = env.entrySet().stream()
    .map(entry -> entry.getKey() + "=" + entry.getValue())
    .toArray(String[]::new);

// 启动进程
Process p = Runtime.getRuntime().exec(new String[]{"play", "--magic", station}, envArray);

// 同样需要处理stdout/stderr（参考思路1）

3. 改用ProcessBuilder替代Runtime.exec #

ProcessBuilder比Runtime.exec更灵活，支持合并错误流、设置工作目录，调试更方便：

ProcessBuilder pb = new ProcessBuilder("play", "--magic", station);
// 设置环境变量
pb.environment().put("AUDIODEV", "pcm.radsound");
// 合并stderr到stdout，方便统一处理
pb.redirectErrorStream(true);

Process p = pb.start();

// 读取合并后的输出
new Thread(() -> {
    try (BufferedReader reader = new BufferedReader(new InputStreamReader(p.getInputStream()))) {
        String line;
        while ((line = reader.readLine()) != null) {
            System.out.println("[PLAY output] " + line);
        }
    } catch (IOException e) {
        e.printStackTrace();
    }
}).start();

int exitCode = p.waitFor();
System.out.println("Play进程退出，代码：" + exitCode);

4. 增加进程监控与日志 #

如果上述方法仍未解决，可增加进程状态监控，记录所有输出到日志文件，排查隐性问题：

// 日志输出到文件
File logFile = new File("/tmp/play_stream.log");
try (PrintWriter logWriter = new PrintWriter(new FileWriter(logFile, true))) {
    Process p = Runtime.getRuntime().exec(new String[]{"play", "--magic", station}, envArray);

    // 读取输出并写入日志
    new Thread(() -> {
        try (BufferedReader reader = new BufferedReader(new InputStreamReader(p.getInputStream()))) {
            String line;
            while ((line = reader.readLine()) != null) {
                logWriter.println("[STDOUT] " + new Date() + ": " + line);
                logWriter.flush();
            }
        } catch (IOException e) {
            logWriter.println("[ERROR] " + new Date() + ": " + e.getMessage());
            logWriter.flush();
        }
    }).start();

    // 定期检查进程状态
    new Thread(() -> {
        while (p.isAlive()) {
            logWriter.println("[STATUS] " + new Date() + ": 进程仍在运行");
            logWriter.flush();
            try {
                Thread.sleep(60000); // 每分钟检查一次
            } catch (InterruptedException e) {
                break;
            }
        }
    }).start();

    int exitCode = p.waitFor();
    logWriter.println("[EXIT] " + new Date() + ": 进程退出，代码：" + exitCode);
    logWriter.flush();
} catch (IOException e) {
    e.printStackTrace();
}

5. 替代方案：直接用Java音频API播放 #

如果依赖play命令的问题难以排查，可以尝试用Java原生或第三方库直接播放流式音频，避免外部进程依赖：

• 原生javax.sound.sampled：适合处理WAV等格式的流，但需要自行解析音频流编码
• JavaFX MediaPlayer：支持多种流式音频格式，代码示例：

import javafx.application.Application;
import javafx.scene.media.Media;
import javafx.scene.media.MediaPlayer;
import javafx.stage.Stage;

public class RadioPlayer extends Application {
    @Override
    public void start(Stage stage) {
        String stationUrl = "你的电台URL";
        Media media = new Media(stationUrl);
        MediaPlayer player = new MediaPlayer(media);
        player.play();
    }

    public static void main(String[] args) {
        launch(args);
    }
}

注意：树莓派上需要确保JavaFX环境已正确配置。

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