本文介绍如何利用 go 标准库 `os/exec` 包实现对系统 shell 的安全、可控调用，支持交互式输入/输出，并提供可复用的封装函数与完整示例代码。
在 Go 中调用系统命令行（如 bash、zsh 或 cmd.exe）并非简单执行一条命令，而是需要精细管理标准输入（stdin）、标准输出（stdout）和标准错误（stderr）的管道（pipes），尤其当目标是构建交互式 shell 会话（例如嵌入式终端、自动化运维工具或跨平台系统工具）时。Go 的 os/exec 包为此提供了底层支持，但需手动建立管道连接、并发处理 I/O 流，并妥善处理进程生命周期。
以下是一个生产就绪的简化版交互式 shell 调用方案，核心思想是：
- 使用 exec.Command 启动目标 shell 进程（如 "bash"）；
- 通过 StdinPipe()、StdoutPipe()、StderrPipe() 获取可读写管道；
- 启动 goroutine 并发地将 os.Stdin → 进程 stdin、进程 stdout → os.Stdout、进程 stderr → os.Stderr；
- 使用 sync.WaitGroup 确保所有 I/O 流完成后再退出；
- 支持单命令模式（如 date）与交互式 shell 模式（如 bash）无缝切换。
package main
import (
"bufio"
"fmt"
"io"
"log"
"os"
"os/exec"
"sync"
)
// getPipes 安全获取命令的标准输入/输出/错误管道，任一失败即终止程序
func getPipes(c *exec.Cmd) (inp io.Writer, outp, errp io.Reader) {
var err error
if inp, err = c.StdinPipe(); err != nil {
log.Fatal("failed to create stdin pipe:", err)
}
if outp, err = c.StdoutPipe(); err != nil {
log.Fatal("failed to create stdout pipe:", err)
}
if errp, err = c.StderrPipe(); err != nil {
log.Fatal("failed to create stderr pipe:", err)
}
return
}
// pipe 将输入流逐字节复制到输出流（适用于 stdin→cmd 或 cmd→stdout/stderr）
func pipe(wg *sync.WaitGroup, inp io.Reader, outp io.Writer) {
if wg != nil {
defer wg.Done()
}
r := bufio.NewReader(inp)
for {
b, err := r.ReadByte()
if err != nil {
break // EOF or other error — exit gracefully
}
if _, writeErr := outp.Write([]byte{b}); writeErr != nil {
log.Printf("warning: failed to write byte: %v", writeErr)
break
}
}
}
// Command 执行任意系统命令，支持交互式与非交互式场景
func Command(args ...string) {
if len(args) == 0 {
log.Fatal("Command requires at least one argument")
}
cmd := exec.Command(args[0], args[1:]...)
stdin, stdout, stderr := getPipes(cmd)
var wg sync.WaitGroup
// 启动 goroutine：cmd stderr → os.Stderr
wg.Add(1)
go pipe(&wg, stderr, os.Stderr)
// 启动 goroutine：cmd stdout → os.Stdout
wg.Add(1)
go pipe(&wg, stdout, os.Stdout)
// 启动 goroutine：os.Stdin → cmd stdin（无 WaitGroup，因 stdin 是持续输入源）
go pipe(nil, os.Stdin, stdin)
if err := cmd.Start(); err != nil {
log.Fatalf("failed to start command %v: %v", args, err)
}
// 等待 stdout/stderr 流结束（注意：stdin 不阻塞此处）
wg.Wait()
// 等待命令真正退出（避免僵尸进程）
if err := cmd.Wait(); err != nil {
log.Printf("command %v exited with error: %v", args, err)
}
}
func main() {
// 示例 1：启动交互式 bash（按 Ctrl+D 退出）
fmt.Println("=== Starting interactive bash ===")
Command("bash")
// 示例 2：执行一次性命令
fmt.Println("\n=== Running 'date' ===")
Command("date")
fmt.Println("\n=== Running 'echo' ===")
Command("echo", "some text")
fmt.Println("\n=== Running 'ping' (Linux/macOS) ===")
Command("ping", "-c", "3", "www.google.com")
}✅ 关键注意事项：
- 平台兼容性：bash 在 Windows 上默认不可用，如需跨平台，请根据 runtime.GOOS 切换为 cmd（Windows）或 powershell，并调整参数（如 cmd /C echo hello）；
- 安全性警告：切勿直接拼接用户输入作为 args。若需动态执行命令，优先使用结构化参数（如 []string{"ls", "-l", userProvidedPath}），避免 shell 注入风险；
- 资源清理：cmd.Wait() 必须调用，否则子进程可能成为僵尸进程；pipe 中的 Write 错误被记录而非 panic，提升健壮性；
- 交互限制：该方案模拟了基本 shell 交互，但不支持行编辑（如退格、历史命令）、TTY 控制（如 stty）或信号转发（如 Ctrl+C 终止子进程）。如需完整 TTY 行为，应结合 syscall.Syscall 或第三方库（如 github.com/creack/pty）。
此模式是构建轻量级系统工具的理想起点——无论是 CLI 辅助脚本、容器内诊断工具，还是跨平台部署代理，均可基于此模型扩展超时控制、日志审计、命令沙箱等企业级能力。
