Go语言中与外部程序进行持久化交互：使用exec包实现标准I/O管道通信

// 不正确的示例：尝试反复赋值 cmd.Stdin
cmd := exec.Command("e")
// ...
cmd.Stdin = strings.NewReader(toProg + "\n") // 每次循环都重新赋值，这无法建立持久管道
// ...

package main

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

func main() {
    // 假设外部程序名为 "./e"，需要确保它在当前目录下或PATH中
    cmd := exec.Command("./e") 

    // 1. 获取外部程序的标准输出管道，用于从外部程序读取数据
    progin, err := cmd.StdoutPipe()
    if err != nil {
        fmt.Println("获取外部程序stdout管道失败:", err)
        panic(err)
    }

    // 2. 获取外部程序的标准输入管道，用于向外部程序写入数据
    progout, err := cmd.StdinPipe()
    if err != nil {
        fmt.Println("获取外部程序stdin管道失败:", err)
        panic(err)
    }

    // 3. 启动外部程序
    err = cmd.Start()
    if err != nil {
        fmt.Println("启动外部程序失败:", err)
        panic(err)
    }

    // 初始化随机数生成器
    r := rand.New(rand.NewSource(time.Now().UnixNano()))

    // 使用bufio.NewReader包装progin，以便按行读取
    buf := bufio.NewReader(progin)

    for {
        // 写入数据到外部程序
        var toProg string
        if r.Float64() < .1 { // 大约10%的概率发送"exit"
            toProg = "exit"
        } else {
            toProg = fmt.Sprintf("%d", r.Intn(100)) // 发送随机整数
        }
        fmt.Println("发送给外部程序:", toProg)

        // 通过progout管道写入数据，注意需要转换为字节切片并加上换行符
        _, err := progout.Write([]byte(toProg + "\n"))
        if err != nil {
            fmt.Println("写入外部程序失败:", err)
            panic(err)
        }

        // 如果发送了"exit"，则等待外部程序退出并结束本程序
        if toProg == "exit" {
            fmt.Println("发送'exit'命令，等待外部程序退出...")
            // 关闭输入管道，通知外部程序没有更多输入
            progout.Close() 
            cmd.Wait() // 等待外部程序完成
            fmt.Println("外部程序已退出。")
            break
        }

        // 读取外部程序的输出
        // 为了演示简单同步，等待一小段时间，确保外部程序有时间处理输入并生成输出
        time.Sleep(500 * time.Millisecond) 

        input, err := buf.ReadString('\n') // 按行读取直到遇到换行符
        if err != nil {
            fmt.Println("从外部程序读取数据失败:", err)
            // 如果外部程序正常退出，ReadString可能会返回io.EOF，此时可以优雅退出
            // 对于本例，如果外部程序因其他错误退出，这里会panic
            if err.Error() == "EOF" {
                fmt.Println("外部程序输出流已关闭，可能已退出。")
                break
            }
            panic(err)
        }
        fmt.Println("收到外部程序响应:", input)
    }
}

package main

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

func main() {
    reader := bufio.NewReader(os.Stdin)
    for {
        // 从标准输入读取一行
        input, err := reader.ReadString('\n')

        if err != nil {
            // 如果遇到EOF或其他读取错误，打印错误并退出
            fmt.Println("Echo程序读取输入失败:", err)
            break // 退出循环
        }

        // 检查是否是退出命令
        if strings.HasPrefix(strings.TrimSpace(input), "exit") {
            fmt.Println("Bye!") // 打印退出信息
            return             // 退出程序
        }

        // 将输入原样输出到标准输出
        fmt.Print(input)
    }
}