17370845950

用Go构建轻量CI/CD监控后端，对接GitHub/GitLab/Jenkins API拉取构建状态，用结构体建模+sync.Map缓存，定时轮询+WebSocket实时推送，HTML模板+HTMX或DOM局部更新，辅以认证与日志。

用 Go 实现 CI/CD 流水线的可视化监控，核心不是从零造轮子，而是用 Go 构建轻量、可控的后端服务，对接已有 CI 工具（如 GitHub Actions、GitLab CI、Jenkins）的 API，拉取构建/部署状态，再通过 Web 界面实时展示。重点在于状态聚合、增量更新和低延迟响应。

对接 CI 工具 API 获取构建状态

Go 的标准 net/http 和 encoding/json 足够完成主流 CI 平台的状态拉取。以 GitHub Actions 为例：

• 使用 personal access token（带 repo:status 权限）调用 /repos/{owner}/{repo}/actions/runs 或 /repos/{owner}/{repo}/actions/workflows/{workflow_id}/runs
• 解析 JSON 响应，提取 status（queued/in_progress/completed）、conclusion（success/failure/cancelled）、head_branch、event、created_at 等关键字段
• 对 GitLab CI，调用 /projects/:id/pipelines；对 Jenkins，用 /job/{jobName}/lastBuild/api/json（需开启 CSRF 保护或使用 API Token）

用结构体建模流水线状态并做内存缓存

定义清晰的领域模型，避免嵌套过深：

type PipelineRun struct {
    ID          int64     `json:"id"`
    Repo        string    `json:"repo"`
    Branch      string    `json:"branch"`
    Workflow    string    `json:"workflow"`
    Status      string    `json:"status"` // "running", "success", "failed"
    Conclusion  string    `json:"conclusion"`
    StartedAt   time.Time `json:"started_at"`
    FinishedAt  time.Time `json:"finished_at"`
    DurationSec int       `json:"duration_sec"`
}

用 sync.Map 或 github.com/bluele/gcache 实现内存缓存，按 repo+branch+workflow 组合为 key 存储最新运行记录。定时（如每 30 秒）轮询更新，避免频繁请求上游 API。

提供 WebSocket 实时推送状态变更

前端需要“秒级可见”构建状态变化，HTTP 轮询体验差。Go 推荐用 gorilla/websocket：

• 启动一个 goroutine 监听缓存变更（例如用 channel 广播 PipelineRun 更新）
• 每个 WebSocket 连接对应一个 client 结构体，注册到中心 hub
• 状态更新时，hub 向所有连接广播 JSON 消息，如 {"repo":"myapp","branch":"main","status":"success"}
• 前端用 new WebSocket(...) 接收并刷新对应卡片，无需整页重载

用 HTML + HTMX 或轻量前端渲染视图

不需要 React/Vue：Go 的 html/template 可直接生成静态结构，配合 HTMX 实现局部刷新：

• 定义模板 index.html，用 {{range .Pipelines}} 渲染卡片列表
• 卡片 div 添加 hx-get="/api/pipeline/{{.Repo}}/{{.Branch}}" hx-trigger="every 10s"，自动轮询最新状态
• 或更优：WebSocket 收到消息后，用 document.getElementById(...).innerHTML = ... 局部更新 DOM
• 状态色标用 CSS 类控制：status-running → bg-yellow-400，status-success → bg-green-500

不复杂但容易忽略：加一层简单的认证（如 HTTP Basic 或 JWT），避免把内部构建状态暴露给公网；日志打点用 zap 或 zerolog 记录每次拉取是否超时、失败原因，方便排查集成问题。