Node.js Socket.io聊天应用高频请求后服务器卡顿排查求助

架构老林

2026-5-14

排查Node.js + Socket.io聊天应用快速发消息卡顿/断连问题

先从你的代码和场景入手，快速发消息时的卡顿、Socket断连，核心大概率是事件循环阻塞或者HTTP请求堆积导致的，咱们一步步拆解问题：

一、先看你的事件处理逻辑里的几个隐患

先把你的代码片段格式化下，方便分析：

io.on('RequestSendNewMessage', (message)=>{ 
  headers['wh-user-id'] = message.user_id; 
  makeRequest({
    data: message, 
    method: 'POST', 
    url: `${workstream}/v1/workstream/send-message`, 
    headers
  }) 
  .then( async (response) => { 
    const message_count = await makeRequest({
      params: {}, 
      method: 'GET', 
      url: `${workstream}/v1/workstream/message-count`, 
      headers
    }) 
    socket.emit('RespondNewMessageCount', message_count.data.data); 
    socket.emit('RespondSendNewMessage', response.data); 
  }) 
  .catch(error => { 
    console.log('errror', error.response.data); 
    socket.emit('newMessageError', error.response.data) 
  }) 
})

二、具体排查点&解决方案

1. 最可能的原因：HTTP请求并发过载，连接池耗尽

每次收到消息事件，你都会发起2次独立的HTTP请求（POST存消息 + GET统计数量）。当快速发消息时，短时间内会产生大量请求，而Node.js的HTTP客户端（比如axios/fetch）默认有并发连接数限制（一般是5个/域名），超过后后续请求会排队等待，直接阻塞事件循环。

Socket.io依赖心跳包维持连接（默认每25秒发一次心跳，超时60秒判定断开），如果事件循环被请求排队占满，服务器没法及时处理心跳，客户端就会触发断连重连，直到请求队列清空才恢复。

解决办法：

给HTTP客户端加并发限制：比如用axios-concurrency插件，或者自己写简单的请求队列，控制同时发起的请求数（比如最多10个）。
合并请求：让后端send-message接口在返回结果时顺便带上最新的消息数量，减少一次HTTP请求。

2. 事件循环被阻塞（数据库/接口耗时过长）

Node.js是单线程模型，如果你的send-message接口里的数据库操作（比如写入消息）耗时过长（比如没加索引、锁冲突），或者makeRequest本身有同步阻塞逻辑，会直接卡住事件循环，导致Socket.io的核心逻辑（心跳、连接管理）得不到执行。

排查&解决：

用clinic.js工具（Node官方推荐的性能分析工具）启动服务器，分析事件循环阻塞情况，定位长耗时操作。
检查send-message接口的数据库：比如SQL加索引、MongoDB避免写入锁，优化写入性能。

3. Socket.io事件监听的上下文错误

你的代码里用了socket.emit，但事件监听是挂在io（服务器实例）上的，正常应该是在单个socket的连接回调里监听事件：

// 正确的结构应该是这样
io.on('connection', (socket) => {
  socket.on('RequestSendNewMessage', (message) => {
    // 你的处理逻辑
  });
});

如果直接用io.on监听消息事件，会导致所有连接的socket共享同一个上下文，可能出现事件混乱、内存泄漏，加剧卡顿问题。

4. 错误处理不完整，引发未捕获异常

你的catch块里直接访问error.response.data，如果请求是网络错误（比如后端接口挂了），error.response会是undefined，这行代码会抛出新的错误，未捕获的异常会打乱事件循环，甚至导致进程不稳定。

修复：

.catch(error => {
  console.error('发送消息失败:', error);
  // 兼容无response的情况
  const errorData = error.response?.data || { code: 500, message: '网络异常或服务器未响应' };
  socket.emit('newMessageError', errorData);
})

5. 没有做异步消息队列，请求堆积

快速发消息时，所有消息都同步发起HTTP请求，导致服务器压力骤增。可以引入消息队列（比如Bull、Bee-Queue）异步处理：

收到Socket事件后，先把消息放进队列，立刻给客户端返回「消息已接收」
后台从队列里取消息，调用接口存数据库，完成后再通知客户端消息发送成功

示例代码（用Bull）：

// 初始化消息队列
const messageQueue = new Bull('chat-message-queue');

// 后台处理队列任务
messageQueue.process(async (job) => {
  const { message, headers } = job.data;
  try {
    const saveRes = await makeRequest({
      data: message,
      method: 'POST',
      url: `${workstream}/v1/workstream/send-message`,
      headers
    });
    const countRes = await makeRequest({
      method: 'GET',
      url: `${workstream}/v1/workstream/message-count`,
      headers
    });
    // 根据user_id找到对应的socket（需要提前把socket.id和user_id存在Redis/内存里）
    const targetSocket = io.sockets.sockets.get(socketId);
    if (targetSocket) {
      targetSocket.emit('RespondNewMessageCount', countRes.data.data);
      targetSocket.emit('RespondSendNewMessage', saveRes.data);
    }
  } catch (err) {
    console.error('队列处理失败:', err);
  }
});

// Socket事件处理
io.on('connection', (socket) => {
  socket.on('RequestSendNewMessage', (message) => {
    const headers = { 'wh-user-id': message.user_id };
    // 加入队列，立刻响应客户端
    messageQueue.add({ message, headers });
    socket.emit('MessageReceived', { msgId: message.id });
  });
});

三、优先排查顺序

先确认Socket.io的事件监听是不是在connection回调里，避免上下文错误
用clinic.js排查事件循环是否被阻塞，重点看数据库写入耗时
给HTTP请求加并发限制，或者合并请求
完善错误处理，避免未捕获异常
引入消息队列，异步处理消息存储，降低实时压力

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