Socket.IO单设备产生双连接问题及io实例导出方案咨询

按优先级从高到低排查：

• 客户端重复初始化连接：这是最高发的原因。如果是React Native、Flutter WebView承载的H5应用，开发环境严格模式会导致组件挂载副作用执行两次，如果连接逻辑写在挂载钩子里、且未配置断开连接的清理逻辑，会直接生成两条独立连接。此外应用切前台重连、页面重复跳转时未销毁旧socket实例，也会触发重复连接。可以在connection回调里打印socket.handshake携带的自定义用户ID、设备标识、连接时间戳，对比两条连接的参数差异快速定位。
• 传输协议降级导致重复连接：Socket.IO默认优先使用HTTP长轮询建立连接，再升级为WebSocket。如果服务端反向代理（Nginx等）、网关配置错误导致WebSocket升级失败，客户端会自动fallback重新发起连接，此时服务端会收到两条有效连接。可以临时在初始化IO时加配置transports: ['websocket']强制仅使用WebSocket传输，测试双连接问题是否消失，如果消失即可定位为传输链路配置问题。
• 服务端事件重复绑定：检查全量代码中io.on('connection', 回调)的调用位置，确认没有在路由、中间件逻辑里重复绑定连接事件，避免一次连接触发多次日志打印，误判为两条连接。
• 移动端网络环境影响：部分安卓机型的内置网络优化、VPN/抓包代理工具会自动重发WebSocket握手请求，导致服务端收到两次同设备的连接请求，可以切换纯流量/不同WiFi环境测试验证。

你当前的导出写法逻辑可行，核心要规避循环依赖问题，按以下方式调整即可：

1. 修正socketio.js实现 #

确保IO实例只初始化一次，统一管理连接逻辑：

import { Server as WebSocketServer } from "socket.io";
import http from "http";
import app from "../app";

const httpServer = http.createServer(app);
const io = new WebSocketServer(httpServer, {
  cors: {
    // 生产环境替换为实际业务域名，不要使用通配符
    origin: "*",
    methods: ["GET", "POST"]
  }
});

// 统一在这里绑定连接事件，避免多处重复绑定
io.on("connection", (socket) => {
  console.log("新连接建立，socketID：", socket.id);
  // 示例：用户登录后加入专属房间，方便后续定向推送
  socket.on("bind_user", (userId) => {
    socket.join(`user_${userId}`);
  });
});

export {
  httpServer,
  io,
}

2. 调整index.js加载顺序 #

必须先初始化IO实例，再加载路由、启动服务，避免循环依赖导致拿到的IO实例为undefined：

require("dotenv").config();
// 最先引入初始化好的http服务和IO实例
import { httpServer, io } from "./middlewares/socketio";
import "./database";
// IO实例初始化完成后再引入路由
import businessRouter from "./routes";
import express from "express";

const admin = require("firebase-admin");
const serviceAccount = require("./deliveram-test-firebase-adminsdk-vqinw-368ea4a624.json");

admin.initializeApp({
  credential: admin.credential.cert(serviceAccount),
});

const app = express();
// 挂载业务路由
app.use(businessRouter);

httpServer.listen(process.env.PORT || 3000, () => {
  console.log(`服务运行端口：${process.env.PORT || 3000}`);
});

3. 路由中调用IO实例推送消息 #

直接在路由文件中引入导出的io对象即可调用推送方法：

import express from "express";
const orderRouter = express.Router();
// 直接引入IO实例
import { io } from "../middlewares/socketio";
import Order from "../models/Order";

// 新订单创建接口
orderRouter.post("/order/create", async (req, res) => {
  const newOrder = await Order.create(req.body);
  // 给对应配送员推送新订单通知，配送员上线时已加入对应user_id的房间
  io.to(`user_${newOrder.deliveryUserId}`).emit("new_order", newOrder);
  res.json({ code: 0, data: newOrder });
});

// 订单接单接口
orderRouter.post("/order/accept", async (req, res) => {
  const { orderId, deliveryUserId } = req.body;
  const updatedOrder = await Order.findByIdAndUpdate(orderId, {
    status: "accepted",
    deliveryUserId
  }, { new: true });
  // 给下单用户推送接单通知
  io.to(`user_${updatedOrder.customerUserId}`).emit("order_accepted", updatedOrder);
  res.json({ code: 0, data: updatedOrder });
});

export default orderRouter;

注意：如果路由中引入io时拿到undefined，100%是循环依赖导致，检查文件引入链路，确保socketio.js没有间接引入未初始化完成的路由文件即可。

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