用 goroutine + channel 做任务分发易崩因缺乏背压控制，导致内存暴涨或 goroutine 泛滥；应使用带缓冲 channel（如 make(chan *task, 30)）并配合 select 非阻塞写入，超时则降级处理。
为什么用 goroutine + channel 做任务分发容易崩
因为没做背压控制，任务一多就内存暴涨或 goroutine 泛滥。真实 CI 场景里，git push 频繁触发、PR 同时提交、重试任务堆积——这些都会让无缓冲 chan 直接阻塞或 panic。
实操建议：
立即学习“go语言免费学习笔记（深入）”；
- 用带容量的
chan *Task，容量设为并发 worker 数 × 2～3（比如 10 个 worker，make(chan *Task, 30)） - 发送前加
select非阻塞写入，超时就丢弃或降级进数据库队列：select { case taskCh <- t: default: log.Warn("task dropped: channel full") // fallback to persistent queue } - 别在
http.HandlerFunc里直接go handle(t)—— 缺少上下文取消和生命周期管理
http.Post 调用下游构建服务时如何避免超时雪崩
CI 分发中心本质是 HTTP 中介，但默认 http.Client 没设 timeout，一个慢构建会卡住整个 goroutine 池，后续请求全排队。
实操建议：
立即学习“go语言免费学习笔记（深入）”；
- 每个下游调用必须用独立
http.Client，且Timeout设为硬上限（如 90s），IdleConnTimeout和MaxIdleConns按负载调（500 QPS 建议MaxIdleConns=100） - 用
context.WithTimeout(ctx, 90*time.Second)包裹client.Do(req)，否则client.Timeout在 DNS 解析或 TLS 握手阶段不生效 - 错误分类处理：
net/http: request canceled是 context 超时，可重试；i/o timeout是网络问题，应限流或告警
怎么让任务支持「按仓库/分支/事件类型」动态路由到不同 worker 池
硬编码 if repo == "foo" { runOnPoolA() } 会导致每次加新项目都要改代码、重启服务，违背可扩展前提。
Destoon B2B网站
下载
Destoon B2B网站管理系统是一套完善的B2B(电子商务)行业门户解决方案。系统基于PHP+MySQL开发，采用B/S架构，模板与程序分离，源码开放。模型化的开发思路，可扩展或删除任何功能；创新的缓存技术与数据库设计，可负载千万级别数据容量及访问。 系统特性1、跨平台。支持Linux/Unix/Windows服务器，支持Apache/IIS/Zeus等2、跨浏览器。基于最新Web标准构建，在
实操建议：
立即学习“go语言免费学习笔记（深入）”；
- 把路由规则抽成 YAML 配置，例如：
routes: - match: repo: "backend-.*" event: "push" pool: "k8s-gpu" - match: repo: "frontend-.*" event: "pull_request" pool: "docker-build" - 用
regexp.Compile预编译所有repo和event正则，缓存到 map[string]*regexp.Regexp，避免每次匹配都重编译 - 路由逻辑放 middleware 层，不在 handler 里判断；匹配失败的任务统一打标
route_unmatched进监控，而不是静默丢弃
worker 进程崩溃后，任务状态怎么不丢
只靠内存 channel 或本地变量存任务状态，worker 一 OOM 或被 k8s kill，正在跑的任务就变成“幽灵任务”——没人知道它卡在哪、该不该重试。
实操建议：
立即学习“go语言免费学习笔记（深入）”；
- 所有任务创建、状态变更（
queued→running→success）必须走原子写入，推荐用 PostgreSQL 的INSERT ... ON CONFLICT UPDATE或 Redis 的SET task:123 running NX EX 3600 - worker 启动时先查自己负责的未完成任务（
status = 'running' AND updated_at ），自动恢复或标记为 <code>failed - 别用文件系统存状态——NFS 权限、挂载延迟、节点漂移都会让状态不同步
真正难的不是分发任务，而是当 300 个 worker 在 5 个集群节点上同时拉取、执行、上报时，你怎么确保每条状态更新不被覆盖、不被遗漏、不因网络分区而分裂。这需要对存储语义有明确选择，而不是堆 goroutine。
