--- slug: "golang-toolkit" name: "golang-toolkit" version: 1.0.1 displayName: "Go语言工具包专业版" summary: "企业级 Go 开发方案，含性能优化、并发模式库、内存治理与构建工具链集成。。面向企业级 Go 开发团队的专业工具包，提供性能优化、并发模式与工程化能力。核心能力: - 并发模式库（Worke" summary_zh: "企业级 Go 开发方案，含性能优化、并发模式库、内存治理与构建工具链集成。。面向企业级 Go 开发团队的专业工具包，提供性能优化、并发模式与工程化能力。核心能力: - 并发模式库（Worke" license: "MIT" edition: "pro" description: |- 面向企业级 Go 开发团队的专业工具包，提供性能优化、并发模式与工程化能力。核心能力: - 并发模式库（Worker Pool、Fan-In/Fan-Out、Pipeline、ErrGroup） - 性能优化（内存对齐、逃逸分析、GC 调优） - 内存治理与资源泄漏检测 - 交叉编译与构建工具链集成 - 结构体内存优化与字段对齐分析 适用场景: - 高并发服务架构设计与实现 - 性能瓶颈分析与优化 - 内存泄漏排查与治理 - 多平台交叉编译与发布 差异化: 专业版兼容免费版所有陷阱防范能力... tags: - 开发工具 - Go语言 - 并发编程 - 性能优化 - 企业开发 - 工具 - 效率 - 自动化 - 写作 - 电商 - 研究 - 分析 - 集成 - func - ctx - context - int - return tools: - read - exec - write homepage: "" category: "Automation" --- # Go语言工具包专业版 ## 付费版专享能力 | 能力 | 免费版 | 付费版 | |---|---|---| | 基础功能 | 支持 | 支持 | | 代码静态分析与质量评分 | 不支持 | 支持 | | 依赖漏洞检测与升级建议 | 不支持 | 支持 | | 批量代码审查与报告生成 | 不支持 | 支持 | | CI/CD流水线集成 | 不支持 | 支持 | | 代码复杂度可视化与重构建议 | 不支持 | 支持 | ## 核心能力 | 能力模块 | 免费版 | 专业版新增 | |:-----|:-----|:-----| | 陷阱防范 | Goroutine/Channel/Defer 陷阱 | 生产级陷阱检测脚本 | | 并发模式 | 基础 WaitGroup/Context | Worker Pool/Fan-In/Fan-Out/Pipeline | | 错误处理 | errors.Is/As/Wrap | ErrGroup 批量错误处理 | | 性能优化 | - | 逃逸分析/内存对齐/GC 调优 | | 内存管理 | 基础 Map 并发安全 | 内存泄漏检测/sync.Pool 复用 | | 构建工具 | 基础 go build | 交叉编译/条件编译/嵌入式资源 | | 性能分析 | - | pprof CPU/内存/goroutine 分析 | ### 能力模块 针对能力模块,自动解析输入参数、调度任务队列、格式化输出,返回结构化响应. **输入**: 用户提供能力模块相关的配置参数、输入数据和处理选项. **输出**: 返回能力模块的处理结果。- 验证返回数据的完整性和格式正确性 - 参考`能力模块`的配置文档进行参数调优 ### 陷阱防范 针对陷阱防范,自动解析输入参数、调度任务队列、格式化输出,返回结构化响应. **输入**: 用户提供陷阱防范相关的配置参数、输入数据和处理选项. **输出**: 返回陷阱防范的处理结果。- 验证返回数据的完整性和格式正确性 - 参考`陷阱防范`的配置文档进行参数调优 ### 并发模式 针对并发模式,自动解析输入参数、调度任务队列、格式化输出,返回结构化响应. **输入**: 用户提供并发模式相关的配置参数、输入数据和处理选项. **输出**: 返回并发模式的处理结果。- 验证返回数据的完整性和格式正确性 - 参考`并发模式`的配置文档进行参数调优 # ## 快速开始 1. 确认运行环境满足依赖说明中的要求 2. 在AI Agent对话中调用本技能,提供必要的输入参数 3. 检查输出结果,根据需要进行后续处理 > 详细的输入输出格式请参考下方章节说明。 ## 适用场景 ### 场景一：高并发 Worker Pool 实现 服务需要处理大量并发任务，需要控制 goroutine 数量避免资源耗尽. ```go package workerpool // ... import ( "context" "sync" ) // ... // WorkerPool 固定大小的 worker 池 type WorkerPool struct { tasks chan func() wg sync.WaitGroup workers int } // ... func New(workers, queueSize int) *WorkerPool { p := &WorkerPool{ tasks: make(chan func(), queueSize), workers: workers, } p.wg.Add(workers) for i := 0; i < workers; i++ { go p.worker() } return p } // ... func (p *WorkerPool) worker() { defer p.wg.Done() for task := range p.tasks { task() } } // ... func (p *WorkerPool) Submit(ctx context.Context, task func()) error { select { case p.tasks <- task: return nil case <-ctx.Done(): return ctx.Err() } } // ... func (p *WorkerPool) Shutdown() { close(p.tasks) p.wg.Wait() } // ... // 使用示例 func main() { pool := workerpool.New(10, 100) ctx := context.Background() // ... for i := 0; i < 1000; i++ { taskID := i pool.Submit(ctx, func() { processTask(taskID) }) } pool.Shutdown() } ``` ### 场景二：Pipeline 模式处理数据流 需要处理大量数据，每个阶段并行执行. ```go package pipeline // ... import "context" // ... // Stage 流水线阶段 type Stage func(ctx context.Context, in <-chan int) <-chan int // ... // Pipeline 多阶段流水线 func Pipeline(ctx context.Context, stages ...Stage) <-chan int { ch := make(chan int) go func() { defer close(ch) // 生成数据 for i := 0; i < 1000; i++ { select { case ch <- i: case <-ctx.Done(): return } } }() // ... for _, stage := range stages { ch = stage(ctx, ch) } return ch } // ... // 示例阶段：平方 func Square(ctx context.Context, in <-chan int) <-chan int { out := make(chan int) go func() { defer close(out) for n := range in { select { case out <- n * n: case <-ctx.Done(): return } } }() return out } // ... // 示例阶段：过滤偶数 func FilterEven(ctx context.Context, in <-chan int) <-chan int { out := make(chan int) go func() { defer close(out) for n := range in { if n%2 == 0 { select { case out <- n: case <-ctx.Done(): return } } } }() return out } // ... // 使用：生成 → 平方 → 过滤偶数 func main() { ctx := context.Background() results := Pipeline(ctx, Square, FilterEven) for r := range results { println(r) } } ``` ### 场景三：逃逸分析与内存优化 分析变量逃逸情况，优化内存分配. ```bash go build -gcflags="-m" main.go go build -gcflags="-m -m" main.go # 更详细 type User struct{ Name string } # ... func newUser() *User { u := User{Name: "test"} // 逃逸到堆 return &u } # ... func process(v interface{}) {} process(42) // 42 逃逸到堆 # ... func counter() func() int { n := 0 return func() int { // n 逃逸 n++ return n } } # ... func makeSlice(n int) []int { return make([]int, n) // n 不确定时逃逸 } ``` ```go // 内存对齐优化 // 优化前：字段顺序不合理，内存浪费 type BadStruct struct { a bool // 1 字节 + 7 字节填充 b int64 // 8 字节 c bool // 1 字节 + 7 字节填充 } // 总计 24 字节 // ... // 优化后：紧凑排列 type GoodStruct struct { b int64 // 8 字节 a bool // 1 字节 c bool // 1 字节 + 6 字节填充 } // 总计 16 字节 // ... // 使用 unsafe.Sizeof 检查 fmt.Println(unsafe.Sizeof(BadStruct{})) // 24 fmt.Println(unsafe.Sizeof(GoodStruct{})) // 16 ``` ## 使用流程 ### 错误恢复步骤 ```go import "golang.org/x/sync/errgroup" // ... func processAll(ctx context.Context, urls []string) error { g, ctx := errgroup.WithContext(ctx) g.SetLimit(5) // 限制并发数 // ... results := make([]string, len(urls)) // ... for i, url := range urls { i, url := i, url g.Go(func() error { data, err := fetch(ctx, url) if err != nil { return err } results[i] = data return nil }) } // ... if err := g.Wait(); err != nil { return err } return nil } ``` ### sync.Pool 对象复用 ```go var bufPool = sync.Pool{ New: func() interface{} { return new(bytes.Buffer) }, } // ... func processData(data []byte) string { buf := bufPool.Get().(*bytes.Buffer) defer func() { buf.Reset() bufPool.Put(buf) }() // ... buf.Write(data) // 处理... return buf.String() } ``` # ## 输入格式 | 参数名 | 类型 | 必填 | 说明 | |---:|---:|---:|---:| | content | string | 否 | golang-toolkit处理的内容输入 |, | | mode | string | 否 | 处理模式, 可选: json/text/markdown, | | max_retries | integer | 否 | 单步最大重试次数, 默认: 2 | | skip_steps | array | 否 | 跳过的步骤编号(用于断点续传), 默认: [] | ## 输出格式 ```json { "success": true, "data": { "final_result": { "toolkit_result": "toolkit_result_value", "toolkit_metadata": "toolkit_metadata_value", "toolkit_status": "toolkit_status_value" }, "execution_log": [ { "step": 1, "name": "按流程执行", "status": "completed", "duration_ms": 1200, "output_summary": "按流程执行" }, { "step": 2, "name": "按流程执行", "status": "completed", "duration_ms": 3500, "output_summary": "按流程执行" }, { "step": 3, "name": "按流程执行", "status": "completed", "duration_ms": 2100, "output_summary": "按流程执行" }, { "step": 4, "name": "按流程执行", "status": "completed", "duration_ms": 800, "output_summary": "按流程执行" } ], "total_duration_ms": 7600, "gates_passed": 3, "gates_total": 3 }, "error": null } ``` 中间产物模板参考: `assets/golang-toolkit_template` ## 错误处理 | 错误场景 | 原因 | 处理方式 | |:---:|:---:|:---:| | Step Golang Toolkit 核心处理处理失败 | 按流程执行 | 自动(最多max_retries次), 仍失败则记录断点, 暂停流程 | | Gate条件不满足 | Step Golang Toolkit 智能分析输出质量不达标 | 返回Step Golang Toolkit 智能分析重新处理, 或提示用户调整输入 | | 输入数据格式错误 | content格式不符合要求 | 列出期望格式, 提供示例, 中止流程 | | 断点续传失败 | 缓存的中间产物已过期或损坏 | 从Step 1重新开始, 清除旧缓存 | | 超时 | 总处理时间超过Golang Toolkit 批量处理分钟 | 返回已完成步骤的结果, 标记为partial | | 其他异常 | 内部处理异常 | 检查输入后 | ## 依赖说明 ### 运行环境 - **Agent 平台**: 支持读取 SKILL.md 的任意 AI Agent（Claude Code / Cursor / Codex / Gemini CLI 等） - **操作系统**: Windows / macOS / Linux - **Go 版本**: 建议 1.19 及以上（需支持泛型、SetMemoryLimit） ### 依赖说明(补充) | 依赖项 | 类型 | 是否必需 | 获取方式 | |:------|------:|:------|:------| | Go | 编译器/运行时 | 必需 | golang.org 下载 | | golang.org/x/sync | 扩展库 | 推荐 | `go get golang.org/x/sync` | | GoReleaser | 构建工具 | 可选 | goreleaser.com 安装 | | pprof | 分析工具 | 内置 | Go 工具链内置 | | LLM API | API | 必需 | 由 Agent 内置 LLM 提供 | ### API Key 配置 - 本工具为纯 Markdown 指令驱动，无需额外 API Key - Go 模块下载需要配置 GOPROXY 代理 - 性能分析服务默认监听 localhost:6060 ### 可用性分类 - **分类**: MD+EXEC（Markdown 指令 + 命令行执行） - **说明**: 通过自然语言指令驱动 Agent 提供 Go 专业开发建议，性能分析与交叉编译需要命令行执行能力 ## 案例展示 ### 交叉编译配置 ```bash GOOS=linux GOARCH=amd64 go build -o （请参考skill目录中的脚本文件） # ... GOOS=darwin GOARCH=arm64 go build -o （请参考skill目录中的脚本文件） # ... GOOS=windows GOARCH=amd64 go build -o （请参考skill目录中的脚本文件） # ... go build -ldflags="-s -w" -o （请参考skill目录中的脚本文件） # ... //go:embed static/* var staticFS embed.FS # ... ``` ### pprof 性能分析 ```go import _ "net/http/pprof" // ... func init() { go func() { http.ListenAndServe("localhost:6060", nil) }() } // ... // 命令行分析 // 基准测试 // 竞争检测 ``` ### GC 调优 ```bash GOGC=200 go run main.go # 减少 GC 频率，增加内存使用 GOGC=50 go run main.go # 增加 GC 频率，减少内存使用 GOGC=off go run main.go # ... import "runtime/debug" debug.SetMemoryLimit(1 << 30) # 1GB 软限制 ``` ## 常见问题 ### Q1：如何排查内存泄漏？ ```bash go tool pprof http://localhost:6060/debug/pprof/heap # ... (pprof) top 10 # 查看内存占用最多的函数 (pprof) list FuncName # 查看函数的内存分配 (pprof) web # 生成可视化图 curl http://localhost:6060/debug/pprof/heap > heap1.out curl http://localhost:6060/debug/pprof/heap > heap2.out go tool pprof -base heap1.out heap2.out ``` ### Q2：如何选择 Worker Pool 大小？ ```go // CPU 密集型：等于 CPU 核心数 workers := runtime.NumCPU() // ... // IO 密集型：可以远大于 CPU 核心数 workers := runtime.NumCPU() * 100 // ... // 动态调整：根据队列长度 func dynamicWorkers(target int) int { queue := runtime.NumGoroutine() if queue > target*2 { return target / 2 // 减少Worker } return target } ``` ### Q3：如何避免接口导致的逃逸？ ```go // 逃逸：interface{} 导致分配 func log(args ...interface{}) {} log(42) // 42 逃逸到堆 // ... // 优化：使用泛型（Go 1.18+） func log[T any](v T) {} log(42) // 不逃逸 // ... // 或使用具体类型 func logInt(v int) {} logInt(42) // 不逃逸 ``` ### Q4：Pipeline 中如何处理错误？ ```go // 使用 errgroup + channel 传递错误 func Pipeline(ctx context.Context) error { g, ctx := errgroup.WithContext(ctx) // ... ch1 := generate(ctx, g) ch2 := process(ctx, g, ch1) ch3 := filter(ctx, g, ch2) // ... g.Go(func() error { for range ch3 { // 消费结果 } return nil }) // ... return g.Wait() // ... // ... ## 已知限制 // ... - 每次请求仅处理单一任务,不支持批量并发 - - 和网络环境 // ...