在main中使用goroutine后Go程序无法正常退出的问题排查

核心问题分析与修复 #

1. 数据库事务错误（导致数据库锁与goroutine异常） #

原WatchExpirations函数在遍历cursor的循环内提交事务，这是严重错误：

• 事务提交后，对应的cursor和bucket会立即失效，后续c.Next()调用会引发未处理的错误，导致goroutine卡住或进入异常状态
• 错误的事务处理会长期占用数据库连接，造成其他操作（如discordgo的/deploy、/return命令）无法获取数据库锁，最终超时失败，用户收到“The application did not respond”

修复代码：

func WatchExpirations(ctx context.Context, db *bbolt.DB, bkt string) error {
    timeout := time.After(time.Second * 5)
    for {
        select {
        case <-timeout:
            // 每次超时启动一个新事务处理所有过期条目
            err := db.Update(func(tx *bbolt.Tx) error {
                bucket := tx.Bucket([]byte(bkt))
                if bucket == nil {
                    return fmt.Errorf("bucket %s not found", bkt)
                }
                c := bucket.Cursor()
                // 收集需要删除的key（避免在遍历中修改bucket）
                var toDelete [][]byte
                for k, v := c.First(); k != nil; k, v = c.Next() {
                    // 替换为你的过期检查逻辑
                    // if isExpired(v) {
                    //     toDelete = append(toDelete, k)
                    // }
                    fmt.Println(v)
                }
                // 批量删除目标条目
                for _, k := range toDelete {
                    if err := bucket.Delete(k); err != nil {
                        return err
                    }
                }
                return nil
            })
            if err != nil {
                return fmt.Errorf("bolt: failed to process expirations: %w", err)
            }
            timeout = time.After(time.Second * 5)
        case <-ctx.Done():
            return ctx.Err()
        }
    }
}

2. Defer中的Panic导致程序无法正常退出 #

原代码在defer的db.Close()错误处理中使用log.Panicf，这会在main函数退出时触发panic，中断正常的退出流程，导致程序卡住。

修复代码：

defer func() {
    if err := db.Close(); err != nil {
        log.Printf("error closing db conn: %v", err) // 用普通日志替代Panic，避免中断退出
    }
}()

3. Goroutine未及时响应Context取消 #

原WatchExpirations函数在进入timeout分支后，会忽略ctx的取消信号，直到当前事务处理完成。需要在事务处理的循环中加入ctx检查，确保收到取消信号时立即退出。

优化后的事务处理逻辑：

err := db.Update(func(tx *bbolt.Tx) error {
    bucket := tx.Bucket([]byte(bkt))
    if bucket == nil {
        return fmt.Errorf("bucket %s not found", bkt)
    }
    c := bucket.Cursor()
    var toDelete [][]byte
    for k, v := c.First(); k != nil; k, v = c.Next() {
        // 检查ctx是否已取消，确保及时响应退出信号
        select {
        case <-ctx.Done():
            return ctx.Err()
        default:
        }
        // 替换为你的过期检查逻辑
        fmt.Println(v)
    }
    for _, k := range toDelete {
        if err := bucket.Delete(k); err != nil {
            return err
        }
    }
    return nil
})

4. Discordgo命令处理器异常的根源 #

所有与数据库交互的命令失效，本质是数据库被错误的事务操作锁住。修复上述数据库事务问题后，命令处理器就能正常获取数据库连接，完成存储/删除操作，用户也能收到预期响应。

总结修复要点 #

• 永远不要在cursor遍历循环内提交事务，应在一个事务中完成所有批量操作，或每次操作开启独立事务
• Defer中避免使用Panic，防止中断正常退出流程
• 长时间运行的goroutine必须在关键循环点检查Context状态，确保及时响应取消信号
• 数据库操作要遵循boltDB的事务规范，避免长期持有锁导致其他操作超时

内容的提问来源于stack exchange，提问作者mcv_dev