2. Go 开发环境搭建：Go SDK 安装、GOPATH 与 Go Modules 配置、常用 IDE 设置

在开始 Kafka 压测项目之前，必须搭建一套标准、可复现的 Go 开发环境。本章将覆盖从 SDK 安装到 IDE 调试配置的完整闭环，确保后续所有压测代码、依赖管理和性能分析都能在统一环境中运行。

2.1 Go SDK 安装与版本选择

Go 语言官方提供跨平台二进制安装包，支持 Linux、macOS 和 Windows。对于 Kafka 压测项目，推荐使用 Go 1.21+ 版本，原因如下：

• 泛型稳定：1.18 引入泛型，1.21 进一步优化编译速度，适合编写通用压测框架。
• 工具链集成：内置 go tool trace、go test -bench 等性能分析工具。
• 模块兼容：对 Go Modules 的依赖解析更严格，避免压测项目出现隐式版本冲突。

2.2 GOPATH 与 Go Modules 配置

Go 的依赖管理经历了从 GOPATH 到 Go Modules 的演进。在 Kafka 压测项目中，我们完全采用 Go Modules 模式，但理解 GOPATH 有助于排查历史遗留问题。

2.2.1 GOPATH 模式（了解即可）

• 默认路径：$HOME/go（Linux/macOS）或 %USERPROFILE%\go（Windows）。
• 目录结构：src/（源码）、pkg/（编译对象）、bin/（可执行文件）。
• 局限：所有项目必须放在 $GOPATH/src 下，无法支持多版本依赖。

2.2.2 Go Modules 配置（推荐）

从 Go 1.16 开始，GO111MODULE 默认值为 on。对于压测项目，建议显式开启并设置以下环境变量：

# 开启模块模式
export GO111MODULE=on

# 设置模块代理（加速依赖下载）
export GOPROXY=https://goproxy.cn,direct

# 设置私有仓库（如公司内部 GitLab）
export GOPRIVATE=gitlab.example.com/*

# 设置模块缓存路径（默认 $GOPATH/pkg/mod）
export GOMODCACHE=$HOME/go/pkg/mod

2.3 常用 IDE 设置：VS Code 与 GoLand

两个 IDE 各有优势：VS Code 轻量、插件生态丰富；GoLand 专为 Go 设计，调试和重构功能更强大。以下分别给出针对 Kafka 压测项目的推荐配置。

2.3.1 VS Code 配置

// .vscode/settings.json 推荐配置
{
  "go.useLanguageServer": true,
  "go.lintTool": "golangci-lint",
  "go.lintFlags": ["--fast"],
  "go.testFlags": ["-v", "-count=1"],
  "go.coverOnSingleTest": true,
  "go.coverOnSingleTestFile": true,
  "editor.formatOnSave": true,
  "go.formatTool": "gofumpt"
}

2.3.2 GoLand 配置

• SDK 管理：File → Settings → Go → GOROOT，选择已安装的 Go SDK 路径。
• 模块代理：Settings → Go → Go Modules，填入 https://goproxy.cn,direct。
• 运行配置：为压测程序创建 Go Build 配置，设置 Working directory 为项目根目录。
• 基准测试：右键 _test.go 文件，选择 Run 'BenchmarkXxx'，GoLand 自动解析 -bench 参数。

2.4 环境搭建流程总览

以下 SVG 图展示了从 SDK 安装到 IDE 调试的完整闭环流程，包含关键决策点和验证步骤。

2.5 快速验证清单

完成上述配置后，执行以下命令验证环境是否就绪：

# 1. 验证 Go 版本
go version

# 2. 验证模块代理
go env GOPROXY

# 3. 创建测试项目并拉取依赖
mkdir kafka-benchmark && cd kafka-benchmark
go mod init github.com/yourname/kafka-benchmark
go get github.com/segmentio/kafka-go@latest

# 4. 编写最小压测骨架（main.go）
cat <<EOF > main.go
package main

import (
    "fmt"
    "time"
)

func main() {
    fmt.Println("Kafka 压测环境就绪")
    time.Sleep(1 * time.Second)
}
EOF

# 5. 运行
go run main.go

2.6 常见问题与解决方案