部署在Google Cloud Run的NodeJS服务Socket IO事件偶尔无法送达客户端

核心原因分析 #

Cloud Run作为无服务器容器平台，其负载均衡、实例动态调度特性，加上WebSocket长连接的特性，容易触发以下隐性问题：

• 跨实例事件不同步：默认Socket.IO的房间/事件仅在单个实例内生效，若客户端连接到实例A，而事件从实例B发送，客户端会收不到。
• 半开连接未被检测：TCP连接因网络波动或负载均衡超时变为半开状态，但WebSocket默认心跳机制未及时触发断开重连，导致客户端误认为连接正常但实际无法通信。

具体解决与排查方案 #

1. 启用并优化Socket.IO心跳机制 #

默认Socket.IO的心跳参数可能无法适配Cloud Run的网络环境，调整参数确保快速检测死连接：
修改客户端代码的socketOptions：

let socketOptions = {
    transports: ["websocket"],
    pingInterval: 10000, // 每10秒发送一次ping
    pingTimeout: 5000    // 5秒没收到pong则判定连接断开
}

服务器端同步配置：

const io = require('socket.io')(server, {
    pingInterval: 10000,
    pingTimeout: 5000
});

这样一旦连接异常，客户端会触发disconnect并自动重连，避免卡在半开状态。

2. 配置Socket.IO跨实例适配器 #

Cloud Run会根据流量动态扩缩实例，必须用Redis适配器实现跨实例的事件同步：

1. 部署Cloud Memorystore Redis实例（与Cloud Run服务同区域）
2. 服务器端安装并配置socket.io-redis：

const { createAdapter } = require('@socket.io/redis-adapter');
const { createClient } = require('redis');

const pubClient = createClient({ url: 'redis://your-redis-host:6379' });
const subClient = pubClient.duplicate();

Promise.all([pubClient.connect(), subClient.connect()]).then(() => {
    io.adapter(createAdapter(pubClient, subClient));
});

这样所有实例的Socket.IO事件都会通过Redis同步，客户端无论连接到哪个实例都能收到事件。

3. 优化客户端重连后的事件订阅 #

当前客户端单例创建后，若连接断开重连，之前的事件监听器可能失效，需在connect事件中重新订阅业务事件：

socket.on('connect', () => {
    console.log(`Connected to Server`);
    // 重连后重新订阅需要的事件/房间
    socket.emit('join-room', 'your-room-id');
});

4. 添加事件发送确认机制 #

服务器端发送事件时使用回调确认客户端是否收到，便于排查未送达的情况：

socket.emit('your-event', eventData, (ackResponse) => {
    if (!ackResponse) {
        console.error(`Failed to deliver event to client ${socket.id}`);
        // 可添加重试逻辑或告警
    }
});

客户端需实现确认回调：

socket.on('your-event', (data, callback) => {
    console.log('Received event:', data);
    callback(true); // 发送确认给服务器
});

5. 监控Cloud Run实例状态 #

通过Cloud Logging查看以下指标：

• 实例的CPU、内存使用率，排查是否因实例过载导致事件发送阻塞
• Socket.IO的连接数、事件发送日志，对比客户端日志确认事件是否已发送
• Cloud Run的负载均衡日志，查看是否有连接被强制断开的记录

客户端代码优化建议 #

修改后的client_socket.js：

import io from "socket.io-client";

const socketUrl = EndPoints.SOCKET_IO_BASE;
let socketOptions = {
    transports: ["websocket"],
    pingInterval: 10000,
    pingTimeout: 5000,
    reconnection: true, // 显式声明自动重连（默认开启）
    reconnectionAttempts: 10
}
let socket;

if (!socket) {
    socket = io(socketUrl, socketOptions);
    
    socket.on('connect', () => {
        console.log(`Connected to Server`);
        // 重连后重新订阅业务事件
        socket.emit('subscribe-to-business-events');
    });
    
    socket.on('disconnect', () => {
        console.log(`Disconnected from Server`);
    });
    
    socket.on('reconnect_failed', () => {
        console.error('Failed to reconnect to server');
    });
}

export default socket;

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