从Java到Go：后端服务迁移的考量与实践

package main

import (
    "fmt"
    "log"
    "os/exec"
    "sync" // 用于等待所有goroutine完成
    // _ "github.com/go-sql-driver/mysql" // 引入MySQL驱动，实际使用时需根据选择的驱动引入
)

// DBCommand 结构体模拟从数据库读取的命令信息
type DBCommand struct {
    ID      int
    Command string
}

func main() {
    // 实际应用中，这里会建立数据库连接并查询命令
    // 例如：db, err := sql.Open("mysql", "user:password@tcp(127.0.0.1:3306)/database")
    // if err != nil { log.Fatalf("Failed to connect: %v", err) }
    // defer db.Close()

    // 模拟从数据库获取的命令列表
    commands := []DBCommand{
        {ID: 1, Command: "echo 'Hello from command 1'"},
        {ID: 2, Command: "sleep 2 && echo 'Hello from command 2 after 2 seconds'"},
        {ID: 3, Command: "ls -l /tmp"},
    }

    var wg sync.WaitGroup // WaitGroup用于等待所有goroutine完成

    fmt.Println("开始并行执行命令...")

    for _, cmdData := range commands {
        wg.Add(1) // 每启动一个goroutine，计数器加1
        go func(cmd DBCommand) {
            defer wg.Done() // goroutine执行完毕后，计数器减1

            fmt.Printf("执行命令 ID %d: '%s'\n", cmd.ID, cmd.Command)

            // 执行Shell命令
            cmdExec := exec.Command("sh", "-c", cmd.Command) // 使用sh -c 来执行复杂命令
            output, err := cmdExec.CombinedOutput()          // 捕获标准输出和标准错误

            if err != nil {
                log.Printf("命令 ID %d 执行失败: %v, 输出: %s\n", cmd.ID, err, string(output))
                // 实际应用中，将错误信息保存到数据库
                return
            }

            fmt.Printf("命令 ID %d 输出:\n%s\n", cmd.ID, string(output))
            // 实际应用中，将 string(output) 保存到数据库中 cmd.ID 对应的记录
            // 例如：_, err = db.Exec("UPDATE commands SET output = ? WHERE id = ?", string(output), cmd.ID)
            // if err != nil { log.Printf("保存输出失败 ID %d: %v\n", cmd.ID, err) }

        }(cmdData) // 将cmdData作为参数传递给goroutine，避免闭包问题
    }

    wg.Wait() // 等待所有goroutine完成
    fmt.Println("所有命令执行完毕。")
}