📚 课程目录第2章环境搭建与基础示例

2. 环境搭建与基础示例：Go环境配置、go get安装GoDAG、创建第一个DAG图并打印节点

本章是《GoDAG调度与边界领域》课程的实践起点。你将完成从零搭建Go开发环境、获取GoDAG库、到成功运行第一个有向无环图（DAG）程序的全过程。我们采用“最小可行示例”策略，确保你快速获得可执行的DAG图，为后续调度算法与边界分析打下坚实基础。

2.1 Go语言环境配置

GoDAG基于Go语言开发，推荐使用Go 1.18及以上版本（支持泛型）。以下是环境配置的标准化步骤：

步骤	操作	验证命令	预期输出
1	下载并安装Go（官方下载）	`go version`	`go version go1.21.0 linux/amd64`
2	设置GOPATH与GOROOT（可选）	`go env GOPATH`	`/home/user/go`
3	启用Go Modules（推荐）	`go env GO111MODULE`	`on`
4	配置代理（国内网络优化）	`go env GOPROXY`	`https://goproxy.cn,direct`

💡 提示： 如果你使用Go 1.21+，Go Modules默认开启，无需手动设置。建议将GOPROXY设置为国内镜像以加速依赖下载。

2.2 使用go get安装GoDAG

GoDAG是一个轻量级的DAG库，专注于调度与依赖管理。安装命令如下：

# 初始化项目模块（如果尚未初始化）
mkdir godag-first && cd godag-first
go mod init godag-first

# 安装GoDAG库
go get github.com/your-org/godag@v0.2.0

# 验证安装
go list -m github.com/your-org/godag

安装成功后，go.mod文件会记录依赖版本，go.sum文件确保依赖完整性。GoDAG库的核心包结构如下：

包路径	核心类型	职责
`godag`	`DAG`, `Node`	DAG图定义、节点管理、拓扑排序
`godag/scheduler`	`Scheduler`	调度策略接口与默认实现
`godag/executor`	`Executor`	节点执行引擎与并发控制

2.3 创建第一个DAG图并打印节点

下面我们构建一个包含5个节点的DAG图，节点间存在明确的依赖关系。该图模拟了一个简单的数据处理流水线：数据采集 → 清洗 → 转换 → 聚合 → 输出。

  📐 DAG结构说明： 节点A（数据采集）是根节点，无依赖；节点B（清洗）和节点C（转换）依赖A；节点D（聚合）依赖B和C；节点E（输出）依赖D。这是一个典型的“扇入-扇出”模式。

对应的Go代码实现如下。我们使用GoDAG的NewDAG()创建图，通过AddNode()添加节点，AddEdge()建立依赖关系，最后调用PrintNodes()输出所有节点信息。

package main

import (
    "fmt"
    "github.com/your-org/godag"
)

func main() {
    // 1. 创建DAG实例
    dag := godag.NewDAG()

    // 2. 添加节点（每个节点包含ID和名称）
    nodeA := dag.AddNode("A", "数据采集")
    nodeB := dag.AddNode("B", "清洗")
    nodeC := dag.AddNode("C", "转换")
    nodeD := dag.AddNode("D", "聚合")
    nodeE := dag.AddNode("E", "输出")

    // 3. 建立依赖边（A → B, A → C, B → D, C → D, D → E）
    _ = dag.AddEdge(nodeA.ID(), nodeB.ID())
    _ = dag.AddEdge(nodeA.ID(), nodeC.ID())
    _ = dag.AddEdge(nodeB.ID(), nodeD.ID())
    _ = dag.AddEdge(nodeC.ID(), nodeD.ID())
    _ = dag.AddEdge(nodeD.ID(), nodeE.ID())

    // 4. 打印所有节点及其依赖关系
    fmt.Println("=== DAG节点列表 ===")
    dag.PrintNodes()

    // 5. 验证DAG合法性（无环检测）
    if dag.IsValid() {
        fmt.Println("✅ DAG验证通过：无环结构")
    } else {
        fmt.Println("❌ DAG验证失败：存在环")
    }
}

运行上述代码，控制台输出如下：

=== DAG节点列表 ===
节点ID: A, 名称: 数据采集, 依赖数: 0, 被依赖数: 2
节点ID: B, 名称: 清洗, 依赖数: 1, 被依赖数: 1
节点ID: C, 名称: 转换, 依赖数: 1, 被依赖数: 1
节点ID: D, 名称: 聚合, 依赖数: 2, 被依赖数: 1
节点ID: E, 名称: 输出, 依赖数: 1, 被依赖数: 0
✅ DAG验证通过：无环结构

⚠️ 常见错误： 如果AddEdge()返回错误，通常是因为添加了重复边或引用了不存在的节点ID。GoDAG在运行时进行严格校验，建议始终检查错误返回值。

2.4 节点属性与元数据扩展

实际调度场景中，节点通常需要携带额外属性（如执行时间、优先级、重试策略）。GoDAG支持通过SetMeta()方法附加元数据：

// 为节点设置元数据
nodeA.SetMeta("exec_time", "2s")
nodeA.SetMeta("priority", 1)
nodeB.SetMeta("exec_time", "3s")
nodeB.SetMeta("retry", 3)

// 读取元数据
execTime, _ := nodeA.GetMeta("exec_time")
fmt.Printf("节点A执行时间: %v\n", execTime)

元数据以map[string]interface{}形式存储，支持任意类型。这在后续调度器决策（如基于优先级的调度、超时控制）中至关重要。

2.5 拓扑排序验证

创建DAG后，拓扑排序是验证依赖关系正确性的核心手段。GoDAG内置了基于Kahn算法的拓扑排序：

// 获取拓扑排序结果
order, err := dag.TopologicalSort()
if err != nil {
    fmt.Printf("拓扑排序失败: %v\n", err)
    return
}

fmt.Println("=== 拓扑排序结果 ===")
for i, nodeID := range order {
    node, _ := dag.GetNode(nodeID)
    fmt.Printf("第%d步: %s (%s)\n", i+1, nodeID, node.Name())
}

输出示例：

=== 拓扑排序结果 ===
第1步: A (数据采集)
第2步: B (清洗)
第3步: C (转换)
第4步: D (聚合)
第5步: E (输出)

💡 关键理解： 拓扑排序结果不唯一。如果节点B和C都依赖A且彼此独立，那么B和C的顺序可以互换。GoDAG的Kahn实现会按照节点添加顺序输出，保证确定性。

2.6 本章小结与检查清单

完成本章后，请确认以下能力已掌握：

✅ Go环境已正确配置，go version输出正常
✅ 使用go get成功安装GoDAG库
✅ 能够创建包含5个以上节点的DAG图
✅ 理解AddNode()、AddEdge()、PrintNodes()的用法
✅ 能够通过TopologicalSort()获取合法执行顺序
✅ 知道如何为节点附加元数据（执行时间、优先级等）