如何在Express中通过Router为Socket.IO自定义端点？请求无响应排查

核心问题 #

1. HTTP请求未响应：/api/gameflow/status的GET接口没有调用res.send()/res.json()等方法返回响应，导致客户端请求一直挂起，最终超时出现socket hang up或返回空内容。
2. Socket.IO事件绑定错误：在HTTP请求处理函数内注册io.on('connection')事件，会导致每次访问该接口都重复绑定连接事件，不仅逻辑错误，还会造成内存泄漏。Socket.IO的连接监听应该在全局初始化时设置，而非路由接口内。

修正后的代码 #

index.js（全局Socket.IO连接处理） #

const express = require("express")
const app = express()
const http = require("http").Server(app)
const io = require("socket.io")(http)

const PORT = process.env.PORT || 8080

const gameflow = require("./modules/gameflow")

// 全局处理Socket.IO连接，只绑定一次
io.on('connection', (socket) => {
    console.log('用户已连接');
    socket.emit("connected", "已连接到服务器");
    
    socket.on('disconnect', () => {
        console.log('用户已断开连接');
    });
})

app.use((req, res, next) => {
    req.io = io
    next();
})

app.use("/api/gameflow", gameflow)

http.listen(PORT, () => {
    console.log(`[SERVER] 后端服务启动于端口 ${PORT}`)
    lcu_hook.riot_cert();
})

/modules/gameflow.js（修复HTTP接口并实现进程监听推送） #

const router = require("express").Router()

// 模拟外部进程状态，实际替换为你的进程检测逻辑
let externalProcessStatus = false;
let processMonitorInterval;

// 中间件：检查外部进程状态
router.use((req, res, next) => {
    // 替换为真实的进程检测代码
    externalProcessStatus = true; // 示例：假设进程正在运行
    if (externalProcessStatus) {
        next()
    } else {
        return res.json({ "error": "APP_NOT_OPEN" })
    }
})

// 获取当前状态的HTTP接口，同时启动进程变化监听
router.get('/status', (req, res) => {
    // 先给HTTP请求返回响应，避免客户端挂起
    res.json({ status: externalProcessStatus ? "RUNNING" : "STOPPED" });
    
    // 避免重复启动监听定时器
    if (!processMonitorInterval) {
        processMonitorInterval = setInterval(() => {
            // 模拟进程状态变化检测，替换为你的真实检测逻辑
            const newStatus = Math.random() > 0.5; 
            if (newStatus !== externalProcessStatus) {
                externalProcessStatus = newStatus;
                // 通过Socket.IO向所有连接的客户端推送状态变化
                req.io.emit('process_status_change', {
                    status: externalProcessStatus ? "RUNNING" : "STOPPED"
                });
            }
        }, 2000); // 每2秒检测一次进程状态
    }
})

module.exports = router

React Native前端Socket.IO连接示例 #

import io from 'socket.io-client';

// 连接后端Socket.IO服务
const socket = io('http://你的后端地址:8080');

socket.on('connect', () => {
    console.log('已连接到后端Socket服务');
});

socket.on('connected', (msg) => {
    console.log(msg);
});

// 监听后端推送的进程状态变化
socket.on('process_status_change', (data) => {
    console.log('进程状态更新:', data);
    // 这里执行前端的相应操作，比如更新UI、触发特定逻辑
});

socket.on('disconnect', () => {
    console.log('与后端Socket服务断开连接');
});

关键说明 #

• Socket.IO的连接监听必须放在全局初始化阶段，确保只绑定一次，避免重复注册导致的逻辑混乱。
• 所有HTTP接口必须明确返回响应，无论成功还是失败，防止客户端请求超时。
• 外部进程的状态监听逻辑应独立封装，通过定时器或事件触发的方式持续检测变化，再通过Socket.IO向所有在线客户端推送更新。

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