在 Go 应用中，可通过 go 关键字将后台任务（如 Redis 监听、定时检查）作为独立 goroutine 启动，与 http.ListenAndServe 并发执行；但必须避免空循环、合理管理生命周期，并优先使用 channel 或 select{} 等协作式等待机制。
在 go 应用中，可通过 go 关键字将后台任务（如 redis 监听、定时检查）作为独立 goroutine 启动，与 http.listenandserve 并发执行；但必须避免空循环、合理管理生命周期，并优先使用 channel 或 select{} 等协作式等待机制。
在构建典型 Go 后端服务时，常需“一边提供 HTTP 接口，一边持续监听外部事件（如 Redis Pub/Sub、消息队列或定时任务）”。这种双轨并行模式正是 Go 并发模型的典型应用场景——无需复杂框架，仅靠原生 goroutine 即可优雅实现。
✅ 正确做法：将后台任务封装为函数，并用 go 启动
如监听 Redis 的 checkExpire 函数，应启动为独立 goroutine，且内部必须包含非忙等阻塞机制（如 time.Sleep、pubsub.Receive() 或 select），避免 CPU 空转：
func listenRedis(rdb *redis.Client, channel string) {
pubsub := rdb.Subscribe(context.Background(), channel)
defer pubsub.Close() // 防止连接泄漏
for {
msg, err := pubsub.ReceiveMessage(context.Background())
if err != nil {
log.Printf("Redis subscription error: %v", err)
return // 或重连逻辑
}
log.Printf("Received on %s: %s", msg.Channel, msg.Payload)
// ✅ 在此处触发数据更新、通知或业务处理
}
}
func main() {
rdb := redis.NewClient(&redis.Options{
Addr: "localhost:6379",
PoolSize: 1, // Pub/Sub 推荐独占连接
})
// 启动后台监听 goroutine
go listenRedis(rdb, "key_changes")
// 同时启动 HTTP 服务（net/http 自动为每个请求分配 goroutine）
http.HandleFunc("/health", func(w http.ResponseWriter, _ *http.Request) {
w.WriteHeader(http.StatusOK)
w.Write([]byte("OK"))
})
log.Println("HTTP server starting on :8080")
log.Fatal(http.ListenAndServe(":8080", nil))
}⚠️ 关键注意事项：
-
禁止空循环
for{}：它会 100% 占用一个 CPU 核心，应始终配合time.Sleep、channel 接收或select使用； -
Pub/Sub 连接需专用 client：避免与普通命令（
GET/SET）共享连接池，否则易因连接耗尽导致订阅超时（推荐PoolSize: 1+IdleCheckFrequency: -1）； -
资源清理不可少：
defer pubsub.Close()必须在 goroutine 内调用，否则连接泄漏将导致 Redis 侧 SUBSCRIBE 积压； -
解耦消息处理与接收：高并发场景下，建议用带缓冲 channel（如
ch := make(chan *redis.Message, 100)）接收消息，另起 goroutine 消费，防止接收阻塞导致丢消息； -
主 goroutine 不可退出：
http.ListenAndServe是阻塞调用；若需优雅关闭，应结合http.Server+context.WithTimeout+srv.Shutdown()实现。
总结而言，Go 的轻量级 goroutine 天然适配“服务常驻 + 多任务协同”架构。只要遵循单职责封装、阻塞式等待、显式资源管理三原则，即可安全、高效地让 HTTP 服务与后台任务长期稳定共存。
