Go 中并发运行 HTTP 服务器与后台任务的最佳实践

在 Go 应用中，可通过 go 关键字将后台任务（如 Redis 监听、定时检查）作为独立 goroutine 启动，与 http.ListenAndServe 并发执行；但必须避免空循环、合理管理生命周期，并优先使用 channel 或 select{} 等协作式等待机制。

在 Go 应用里，像 Redis 监听、定时巡检这类后台任务，通常可以直接用 go 关键字拉起成独立的 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 服务与后台任务长期稳定共存。