VIP20
本课程属于：072-Go项目结构契约压测闭环 Web后端与企业应用开发 · 共 20 门相关课程，组合学习更完整。
查看所属VIP全部课程 →
← 返回所属目录 咨询 / 购买

Kafka消息队列压测：Go项目结构治理实践

共计 30 章节
点击此处阅读海量试读课程：100+行业、1000+细分领域
01
课程导学与项目全景
Kafka压测背景 · Go项目结构闭环概念 · 课程目标与学习路径
课程导学项目全景
02
Go开发环境搭建
Go SDK安装 · GOPATH与Go Modules配… · 常用IDE（VS Code/GoLa…
Go开发环境搭建
03
Go基础语法速览
变量 · 常量 · 数据类型
Go基础语法速览
04
Go并发编程基础
goroutine · channel · sync.WaitGroup
Go并发编程基础
05
Go项目结构设计
标准项目布局（Standard Go… · 包管理 · 内部包与外部包划分
Go项目结构设计
06
Kafka核心概念
Topic · Partition · Producer
Kafka核心概念
07
Kafka安装与集群部署
单机部署 · Docker Compose搭建多B… · 常用配置项解析
Kafka安装
08
Go连接Kafka
Sarama库介绍 · Producer客户端初始化 · 同步/异步发送消息
GoKafka
09
Go Kafka Consumer实现
Consumer Group消费模式 · 消息拉取与提交Offset · 重平衡处理
GoKafka
10
压测指标定义
吞吐量（TPS/QPS） · 延迟（P50/P99/P999） · 错误率
压测指标定义TPS/QPS
11
压测工具设计原则
模块化 · 可配置 · 可观测
压测工具设计原则模块化
12
项目初始化与配置管理
使用Viper加载YAML配置 · 环境变量覆盖 · 配置结构体定义
项目初始化配置管理
13
生产者压测模块（一）
消息体构造 · 分区策略 · 批量发送与压缩（gzip/snapp…
生产者压测模块消息体构造
14
生产者压测模块（二）
并发控制（goroutine池） · 速率限制（令牌桶） · 背压机制
生产者压测模块goroutine
15
消费者压测模块（一）
多Consumer Group并行消… · 消息处理耗时模拟 · Offset管理策略
消费者压测模块Consumer
16
消费者压测模块（二）
消费延迟监控 · 消息去重与顺序保证 · 死信队列处理
消费者压测模块消费延迟监控
17
压测数据采集与统计
Prometheus客户端集成 · Histogram/Vec指标 · 实时吞吐量与延迟计算
压测数据采集统计
18
压测结果输出与可视化
CSV/JSON结果导出 · Grafana仪表盘配置 · 火焰图与延迟分布图
压测结果输出可视化
19
压力控制与动态调节
基于反馈的速率自适应 · 优雅启停 · 超时与重试策略
压力控制动态调节
20
错误处理与容错
网络抖动重连 · Kafka leader选举期间处理 · 日志分级与告警
错误处理容错
21
单元测试与Mock
Go testing框架 · testify断言 · mock Kafka客户端（sara…
Mock单元测试
22
集成测试与基准测试
testcontainers启动Ka… · go test -bench基准测试 · pprof性能分析
集成测试基准测试
23
CI/CD集成
GitHub Actions自动化测… · Docker镜像构建 · 压测流水线编排
CI/CD集成
24
压测场景设计
恒定负载 · 阶梯负载 · 突发负载
压测场景设计恒定负载
25
性能调优实战（一）
Go runtime调优（GOMAX… · Sarama参数调优（Net.Max…
性能调优实战Go
26
性能调优实战（二）
Kafka Broker调优（num… · OS参数调优（tcp_rmem/vm…
性能调优实战Kafka
27
压测报告生成
HTML报告模板 · 图表嵌入（ECharts/SVG） · 对比基线分析
压测报告生成HTML
28
项目文档与注释
Go Doc生成 · README编写规范 · API文档与架构图
项目文档注释
29
项目总结与复盘
常见踩坑记录 · 最佳实践清单 · 扩展方向（云原生/Kubernete…
项目总结复盘
30
课程结业与展望
综合实战项目演示 · 学习资源推荐 · 社区与开源贡献指引
课程结业综合实战项目演示