从java程序调用unix shell？从java程序中读取和写入来自unix管道的稳定数据流

import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStream;
import java.io.InputStreamReader;

public class UnixShellExample {
    public static void main(String[] args) {
        try {
            // 创建ProcessBuilder对象，并指定要执行的命令
            ProcessBuilder processBuilder = new ProcessBuilder("sh", "-c", "ls -l");

            // 启动外部进程
            Process process = processBuilder.start();

            // 获取进程的输入流
            InputStream inputStream = process.getInputStream();
            BufferedReader reader = new BufferedReader(new InputStreamReader(inputStream));

            // 读取命令执行结果
            String line;
            while ((line = reader.readLine()) != null) {
                System.out.println(line);
            }

            // 等待命令执行完成
            int exitCode = process.waitFor();
            System.out.println("Exit Code: " + exitCode);

        } catch (IOException | InterruptedException e) {
            e.printStackTrace();
        }
    }
}

import java.io.IOException;
import java.io.PipedInputStream;
import java.io.PipedOutputStream;

public class UnixPipeExample {
    public static void main(String[] args) {
        try {
            // 创建PipedInputStream和PipedOutputStream对象
            PipedInputStream inputStream = new PipedInputStream();
            PipedOutputStream outputStream = new PipedOutputStream();

            // 将输入流和输出流连接起来
            inputStream.connect(outputStream);

            // 创建写入数据的线程
            Thread writerThread = new Thread(() -> {
                try {
                    outputStream.write("Hello, Unix pipe!".getBytes());
                    outputStream.close();
                } catch (IOException e) {
                    e.printStackTrace();
                }
            });

            // 创建读取数据的线程
            Thread readerThread = new Thread(() -> {
                try {
                    int data;
                    while ((data = inputStream.read()) != -1) {
                        System.out.print((char) data);
                    }
                    inputStream.close();
                } catch (IOException e) {
                    e.printStackTrace();
                }
            });

            // 启动线程
            writerThread.start();
            readerThread.start();

        } catch (IOException e) {
            e.printStackTrace();
        }
    }
}