Crow项目WebSocket连接异常处理最佳实践

问题背景

在使用Crow框架开发WebSocket服务时，开发者经常会遇到移动设备休眠导致的连接异常问题。当移动客户端(如iPhone Safari)进入休眠状态后，服务器尝试向这些"僵尸连接"发送消息时，会抛出"remote_endpoint: Bad file descriptor"错误，导致工作线程崩溃。

问题本质分析

这个问题的核心在于WebSocket连接状态管理。移动设备休眠时，TCP连接实际上已经中断，但服务器端的连接对象仍然存在。当服务器尝试向这些失效的连接写入数据时，底层系统会返回错误描述符(Bad file descriptor)错误。

解决方案

1. 实现onerror回调

关键点在于正确处理连接错误事件。Crow框架提供了.onerror回调接口，开发者应该实现这个回调来及时清理无效连接：

CROW_WEBSOCKET_ROUTE(app, "/ws")
    .onopen([&](crow::websocket::connection& conn){
        // 添加新连接到集合
        connections.insert(&conn);
    })
    .onerror([&](crow::websocket::connection& conn){
        // 立即从连接集合中移除
        connections.erase(&conn);
    })
    .onclose([&](crow::websocket::connection& conn, const std::string& reason, uint16_t status_code){
        // 这里处理正常关闭
        connections.erase(&conn);
    });

2. 错误处理与连接清理的时序

需要注意的是，.onerror和.onclose回调的触发时序：

1. 连接出现错误时，首先触发.onerror
2. 之后才会触发.onclose
3. 在这两个事件之间，其他代码可能仍会尝试向该连接发送消息

因此，仅在.onclose中清理连接是不够的，必须在.onerror中就立即处理，才能完全避免向无效连接发送消息的问题。

进阶建议

1. 连接健康检查机制

除了依赖错误回调外，还可以实现主动的健康检查：

// 定期检查连接是否活跃
std::chrono::seconds interval(30);
std::thread([&](){
    while(true) {
        std::this_thread::sleep_for(interval);
        for(auto& conn : connections) {
            try {
                conn->send_ping();
            } catch(...) {
                connections.erase(conn);
            }
        }
    }
}).detach();

2. 线程安全考虑

当使用多线程时，对连接集合的操作需要加锁：

std::mutex connections_mutex;

.onopen([&](crow::websocket::connection& conn){
    std::lock_guard<std::mutex> lock(connections_mutex);
    connections.insert(&conn);
})

.onerror([&](crow::websocket::connection& conn){
    std::lock_guard<std::mutex> lock(connections_mutex);
    connections.erase(&conn);
})

3. 连接超时设置

可以设置连接超时时间，自动关闭不活跃的连接：

app.loglevel(crow::LogLevel::Warning);
app.port(18080)
    .multithreaded()
    .timeout(5) // 5秒超时
    .run();

总结

在Crow框架中处理WebSocket连接异常时，关键在于：

1. 实现.onerror回调并立即清理无效连接
2. 理解错误事件和关闭事件的时序关系
3. 考虑多线程环境下的线程安全问题
4. 可选的健康检查机制增强鲁棒性

通过以上措施，可以构建出稳定可靠的WebSocket服务，能够优雅地处理移动设备休眠等异常场景。