Mongoose HTTP Server多线程队列处理请求的连接句柄与失效处理疑问

一、正确获取并传递客户端连接句柄 #

在Mongoose的事件处理器里，你可以直接拿到当前请求对应的mg_connection结构体指针——这就是核心的客户端连接句柄。要把它带到后续线程的任务中，你可以这么做：

1. 封装请求上下文：自定义一个结构体，把要处理的JSON数据和连接句柄打包在一起，再加入输入队列。比如：

typedef struct {
  mg_connection *conn;
  char *json_payload;
  // 还可以按需添加请求ID、超时时间戳等上下文信息
} RequestTask;

⚠️ 注意：不要直接修改mg_connection内部字段，所有对连接的操作都要通过Mongoose提供的线程安全API完成。

2. 线程安全操作连接：后续线程使用连接句柄前，必须先调用mg_lock_connection(c)加锁，操作完成后调用mg_unlock_connection(c)解锁，避免多线程竞争引发的异常。

二、处理连接失效的场景 #

当客户端断开连接、请求超时或Mongoose主动销毁连接时，你需要避免对无效连接执行操作，具体方案如下：

1. 监听连接关闭事件，清理待处理任务 #

在你的事件处理器中，新增对MG_EV_CLOSE事件的处理逻辑：

void event_handler(struct mg_connection *c, int ev, void *ev_data) {
  if (ev == MG_EV_CLOSE) {
    // 遍历输入、输出队列，找到所有关联此连接的任务
    // 将这些任务标记为已取消，或直接从队列中移除
    cancel_pending_tasks(c);
  }
  // 其他事件处理逻辑...
}

这样能提前终止对已失效请求的处理，减少无效操作。

2. 发送响应前检查连接状态 #

第三个线程准备发送响应时，先确认连接是否还处于活跃状态：

void response_sender_thread(void *arg) {
  ResponseTask *task = arg;
  mg_connection *c = task->conn;

  mg_lock_connection(c);
  // 检查连接是否存活：通过c->is_closing判断，或使用Mongoose提供的mg_is_connection_alive()
  if (!c->is_closing) {
    // 格式化并发送响应
    mg_http_reply(c, 200, "Content-Type: application/json\r\n", task->response_json);
  }
  mg_unlock_connection(c);

  // 释放自定义资源
  free(task->response_json);
  free(task);
}

如果c->is_closing为true，说明连接正在关闭，直接跳过发送即可。

3. 补充超时机制 #

给每个请求任务设置超时时间戳，处理线程定期检查任务是否超时：若超时，标记任务为取消状态，若连接仍存活则返回超时响应，否则直接丢弃任务。

关键注意事项 #

• 不要长时间持有连接锁：非事件线程持有锁过久会阻塞Mongoose的事件循环，影响整体服务性能。
• 及时释放资源：无论连接是否有效，处理完任务后都要释放自定义分配的内存（如JSON数据、任务结构体），避免内存泄漏。
• 队列操作必须线程安全：输入、输出队列的读写都要加互斥锁（如pthread_mutex_t），防止并发访问导致队列损坏。

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