Go语言实现进程间交互：利用Stdin/Stdout管道通信教程

package main

import (
    "bufio"
    "fmt"
    "os"
    "strings"
)

func main() {
    // 使用无限循环确保程序持续运行，直到接收到"exit"
    for {
        // 创建一个带缓冲的读取器来读取标准输入
        buf := bufio.NewReader(os.Stdin)
        input, err := buf.ReadString('\n') // 读取一行直到换行符

        if err != nil {
            // 如果读取失败，打印错误并终止程序
            fmt.Println("Echo failed: ", input)
            panic(err)
        }

        // 检查输入是否以"exit"开头
        if strings.HasPrefix(input, "exit") {
            fmt.Println("Bye!") // 打印退出消息
            return               // 退出程序
        }

        fmt.Print(input) // 将接收到的输入原样打印到标准输出
    }
}

package main

import (
    "bufio"
    "fmt"
    "math/rand"
    "os/exec"
    "time"
)

func main() {
    // 1. 创建命令对象：指定要执行的外部程序路径
    // 注意：这里假设 'e' 可执行文件与 main.go 在同一目录，或者在PATH中
    cmd := exec.Command("./e") // 在Unix-like系统中使用 "./e"，Windows可能需要 "e.exe"

    // 2. 获取标准输出管道：用于读取外部程序的输出
    progin, err := cmd.StdoutPipe()
    if err != nil {
        fmt.Println("Trouble with e's stdout")
        panic(err)
    }

    // 3. 获取标准输入管道：用于向外部程序写入输入
    progout, err := cmd.StdinPipe()
    if err != nil {
        fmt.Println("Trouble with e's stdin")
        panic(err)
    }

    // 4. 启动外部程序
    err = cmd.Start()
    if err != nil {
        fmt.Println("Trouble starting e")
        panic(err)
    }

    // 初始化随机数生成器
    r := rand.New(rand.NewSource(time.Now().UnixNano())) // 使用当前时间作为种子，确保每次运行随机性

    // 创建一个带缓冲的读取器，从外部程序的输出管道读取数据
    buf := bufio.NewReader(progin)

    // 5. 进行I/O操作循环
    for {
        // 写入数据到外部程序
        var toProg string
        // 随机决定是否发送 "exit" 命令
        if r.Float64() < .1 { // 大约10%的概率发送 "exit"
            toProg = "exit"
        } else {
            toProg = fmt.Sprintf("%d", r.Intn(100)) // 发送一个0-99的随机整数
        }
        fmt.Println("Printing: ", toProg)
        // 写入数据到输入管道，并加上换行符，因为子程序是按行读取的
        _, err := progout.Write([]byte(toProg + "\n"))
        if err != nil {
            fmt.Println("Error writing to stdin pipe:", err)
            break // 写入失败，可能子进程已退出
        }

        // 读取数据从外部程序
        // 暂停一小段时间，给子程序处理输入并生成输出的时间
        time.Sleep(500 * time.Millisecond)

        input, err := buf.ReadString('\n') // 读取子程序的一行输出
        if err != nil {
            // 如果读取失败，可能是子程序已退出或管道关闭
            fmt.Println("I did *not* like that: ", input, "Error:", err)
            break // 终止循环
        }
        fmt.Println("Received: ", input)

        // 如果发送了 "exit" 并且接收到了 "Bye!"，则退出循环
        if strings.HasPrefix(toProg, "exit") && strings.HasPrefix(input, "Bye!") {
            fmt.Println("Exiting controller as child program has terminated.")
            break
        }
    }

    // 等待子进程完成，清理资源
    err = cmd.Wait()
    if err != nil {
        fmt.Println("Child process exited with error:", err)
    } else {
        fmt.Println("Child process finished successfully.")
    }
}