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

Go项目业务接口工程：业务接口与消息队列的异步处理

共计 30 章节
点击此处阅读海量试读课程：100+行业、1000+细分领域
01
课程导学与项目背景
异步处理在Go项目中的价值 · 消息队列选型对比（RabbitMQ… · 课程项目架构总览
课程导学项目背景
02
Go语言基础回顾
Goroutine与Channel核… · 并发模型 · 错误处理与defer机制
Go语言基础回顾
03
RabbitMQ核心概念
Exchange · Queue · Binding
RabbitMQ核心概念
04
Go连接RabbitMQ
使用amqp091-go库建立连接 · Channel管理 · Connection重连策略
GoRabbitMQ
05
生产者模式实现
Direct/Topic/Fanou… · 消息持久化 · 批量发送优化
生产者模式实现Direct/Topic…
06
消费者模式实现
Push模式与Pull模式 · 手动ACK与自动ACK · QoS预取限制
消费者模式实现Push
07
业务接口设计原则
RESTful API设计规范 · 请求校验（validator库） · 统一响应结构
业务接口设计原则RESTful
08
接口与MQ解耦
同步接口异步化改造策略 · 消息体Schema设计（Protob… · 消息路由设计
MQ接口
09
订单创建接口实战
接收HTTP请求 -> 校验参数 -…
订单创建接口实战HTTP
10
消息消费端实现
监听队列 -> 反序列化消息 ->…
消息消费端实现监听队列
11
死信队列与重试机制
消息消费失败处理策略 · 重试次数限制 · 死信队列监控
死信队列重试机制
12
Kafka核心概念
Topic · Partition · Offset
Kafka核心概念
13
Go连接Kafka
使用segmentio/kafka-… · 生产者配置（acks · retries）
GoKafka
14
Kafka生产者实战
同步发送与异步发送 · Keyed消息保证分区顺序 · 批量发送与压缩
Kafka生产者实战
15
Kafka消费者实战
Consumer Group Reb… · 手动提交Offset · Exactly-Once语义实现
Kafka消费者实战
16
Redis Streams实现消息队列
Stream数据结构 · XADD/XREAD/XGROUP命… · 消费者组管理
RedisStreams
17
Go操作Redis Streams
使用go-redis库 · 生产者写入Stream · 消费者读取Pending消息
GoRedis
18
消息去重与幂等性
全局唯一ID生成（Snowflake… · Redis去重表 · 数据库唯一约束
消息去重幂等性
19
消息顺序性保证
单分区/单队列顺序消费 · 全局ID排序 · 业务层面顺序控制
消息顺序性保证单分区
20
分布式事务与最终一致性
本地消息表模式 · 事务消息（RocketMQ） · TCC模式在MQ场景的应用
分布式事务最终一致性
21
消息监控与告警
Prometheus指标暴露（消息积… · 消费延迟 · 失败率）
消息监控告警
22
链路追踪
OpenTelemetry集成 · TraceID在消息中的传递 · Jaeger查看异步调用链
链路追踪OpenTelemetr…
23
单元测试与Mock
MQ客户端Mock（testify/… · 接口测试（httptest） · 消费逻辑测试
Mock单元测试
24
性能压测与调优
pprof性能分析 · Goroutine池优化 · 批量处理
性能压测调优
25
优雅关闭与平滑重启
signal.Notify捕获退出信… · 消费者Drain机制 · 未ACK消息处理
优雅关闭平滑重启
26
多租户消息隔离
Virtual Host（Rabbi… · Topic前缀隔离（Kafka） · Stream分组（Redis）
多租户消息隔离Virtual
27
消息加密与安全
TLS/SSL连接 · 消息体AES加密 · 敏感字段脱敏
消息加密安全
28
日志与审计
结构化日志（zerolog/zap） · 消息轨迹记录 · 审计表设计
日志审计
29
灰度发布与蓝绿部署
消息路由灰度策略 · 消费者版本控制 · 流量切换方案
灰度发布蓝绿部署
30
项目总结与最佳实践
架构演进路线 · 常见坑点总结 · 生产环境配置清单
项目总结最佳实践