Go语言后端迁移：并行任务处理与数据库集成策略

package main

import (
    "fmt"
    "sync"
    "time"
)

// 模拟从数据库读取的命令结构
type Command struct {
    ID     int
    CmdStr string
    Args   []string
}

// 模拟执行命令并返回输出
func executeCommand(cmd Command) string {
    // 实际中这里会调用 os/exec 执行命令
    fmt.Printf("Executing command %d: %s %v\n", cmd.ID, cmd.CmdStr, cmd.Args)
    time.Sleep(time.Duration(cmd.ID) * 100 * time.Millisecond) // 模拟耗时操作
    return fmt.Sprintf("Output for command %d: Done!", cmd.ID)
}

func main() {
    // 模拟从数据库读取的命令列表
    commands := []Command{
        {ID: 1, CmdStr: "ls", Args: []string{"-l"}},
        {ID: 2, CmdStr: "pwd"},
        {ID: 3, CmdStr: "echo", Args: []string{"Hello Go"}},
        {ID: 4, CmdStr: "sleep", Args: []string{"0.5"}},
    }

    results := make(chan string, len(commands)) // 用于收集结果的通道
    var wg sync.WaitGroup                       // 用于等待所有Goroutine完成

    for _, cmd := range commands {
        wg.Add(1)
        go func(c Command) {
            defer wg.Done()
            output := executeCommand(c)
            results <- output // 将结果发送到通道
        }(cmd)
    }

    // 启动一个Goroutine来关闭结果通道
    go func() {
        wg.Wait()      // 等待所有任务完成
        close(results) // 关闭通道，表示没有更多结果会发送
    }()

    // 从结果通道接收并处理输出
    for output := range results {
        fmt.Println(output)
        // 实际应用中，这里可以将 output 保存到数据库
    }

    fmt.Println("All commands processed.")
}

package main

import (
    "fmt"
    "log"
    "os/exec"
    "time"
)

func main() {
    // 执行一个简单的ls命令
    cmd := exec.Command("ls", "-l")
    output, err := cmd.CombinedOutput() // 执行命令并捕获标准输出和标准错误
    if err != nil {
        log.Fatalf("Command failed: %v, Output: %s", err, output)
    }
    fmt.Printf("Command output:\n%s\n", string(output))

    // 异步执行命令示例 (更适合并行场景)
    cmdAsync := exec.Command("sleep", "2")
    if err := cmdAsync.Start(); err != nil { // 启动命令，不等待其完成
        log.Fatalf("Failed to start command: %v", err)
    }
    fmt.Println("Command started in background...")

    // 可以在这里做其他事情
    time.Sleep(1 * time.Second)

    // 等待命令完成
    if err := cmdAsync.Wait(); err != nil { // 等待命令完成并获取退出状态
        log.Fatalf("Command finished with error: %v", err)
    }
    fmt.Println("Command finished.")
}

go get github.com/go-sql-driver/mysql

package main

import (
    "database/sql"
    "fmt"
    "log"

    _ "github.com/go-sql-driver/mysql" // 导入驱动，但不需要直接使用其导出函数
)

func main() {
    // 构建DSN (Data Source Name)
    // 格式：user:password@tcp(host:port)/dbname?charset=utf8mb4&parseTime=True&loc=Local
    dsn := "user:password@tcp(127.0.0.1:3306)/testdb?charset=utf8mb4&parseTime=True&loc=Local"

    db, err := sql.Open("mysql", dsn)
    if err != nil {
        log.Fatalf("Failed to open database connection: %v", err)
    }