Node.js环境下Express与Socket.io同端口集成及报错处理

报错原因 #

你的报错由两个问题共同导致：

• 拼写错误：Socket.io 提供的方法名是listen不是listend
• 调用对象错误：Socket.io 不能直接绑定 Express 实例，需要绑定到 Node 原生 HTTP Server 实例上

方案合理性说明 #

Express 和 Socket.io 共用同一端口是生产环境常用的合理方案，Socket.io 会自动识别 WebSocket 握手请求和普通 HTTP 请求，普通请求会正常走 Express 原有路由逻辑，不会产生冲突。

完整修改后的代码 #

const express = require('express');
const morgan = require('morgan');
const cors = require('cors');
const mongoose = require('mongoose');
// 新增：引入Node原生http模块
const http = require('http');
// 新增：引入Socket.io
const { Server } = require('socket.io');

require('dotenv').config();

const app = express();
const port = process.env.port || 5050;

// 新增：用http模块包裹express实例，创建server
const server = http.createServer(app);
// 新增：初始化Socket.io，绑定到server上，配置CORS和原有服务保持一致
const io = new Server(server, {
  cors: {
    origin: "*", // 可以根据你的业务需求调整允许的源，和你原有cors配置保持一致即可
    methods: ["GET", "POST"]
  }
});

app.use(morgan('dev'));

app.use(cors());
app.use(express.json());
app.use(express.urlencoded({ extended:true }));

const uri = process.env.ATLAS_URI;
mongoose.connect(uri, {useNewUrlParser:true});

const connection = mongoose.connection;
connection.once('open', () => console.log('Connected'));

const routes = require(#every routes);
app.use(routes);//all created routes

// 新增：Socket.io基础连接监听，在这里写你的实时业务逻辑
io.on('connection', (socket) => {
  console.log('新客户端连接:', socket.id);
  
  // 示例：监听客户端发送的自定义事件
  socket.on('custom_event', (data) => {
    console.log('收到客户端数据：', data);
    // 给当前客户端回发消息
    socket.emit('response_event', '收到你的消息了');
    // 给所有连接的客户端广播消息
    io.emit('broadcast_event', '全体通知');
  });

  // 监听客户端断开连接
  socket.on('disconnect', () => {
    console.log('客户端断开连接:', socket.id);
  });
});

// 修改：把原来的app.listen改成server.listen，用http server监听端口
server.listen(port, () => {console.log(`Server listening on port ${port}`)});

注意事项 #

• 原有 Express 的所有路由、中间件逻辑完全不需要修改，可以正常运行
• 前端连接 Socket.io 时直接使用原服务地址即可，不需要额外加端口，示例：const socket = io('http://你的服务地址:5050')
• 生产环境建议把 Socket.io 的 CORS 配置中的origin改成你前端的实际域名，不要用*，避免安全风险

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