能否在Express路由中实现Socket.IO连接？支付回调实时更新需求

我实现了一个依赖Express路由作为回调的支付服务：用户发起支付时会被重定向至与前后端域名不同的支付服务链接，支付成功后跳转至我的Express GET回调路由，在此路由中为用户发放资产后跳转至前端。
需求是：用户完成购买后，前端无需刷新即可向其他用户实时展示该购买的相关详情。
我尝试用Socket.IO解决此问题，在路由中添加Socket连接以向前端推送数据，但经过大量研究后仍无法解决。以下是简化后的代码：

server.js #

const express = require("express")
const app = express()
const http = require("http")
const cors = require("cors")
const session = require("express-session")
const { Server } = require("socket.io")

app.use(cors())
app.use(express.json())

const server = http.createServer(app)

server.listen(3004, () => {
  console.log("SERVER IS RUNNING")
})
const io = new Server(server, {
  cors: {
    origin: "http://localhost:3000",
    methods: ["GET", "POST"],
  },
})

const postRoute = require("./routes/postData")(io)
app.use("/post-data", postRoute)

postData路由 #

module.exports = function (io) {
  const router = require("express").Router();
  router.post("/", async (req, res) => { 
    const data = req?.body?.data.message
    const room = req?.body?.data?.room

    io.on("connection", (socket) => {
      console.log("Socket Running...")
      socket.to(room).emit("the_message", data)
    })

    console.log("Under socket...")
    return res.status(200).json({ data: req.body.data })
  })

  return router
}

问题是postData路由中的console.log("Socket Running...")日志未打印，无法实现实时推送。

更新：支付网关配置代码如下：

const { body } = await got.post("https://payment-provider-link", {
  headers: { Authorization: "Bearer token for payment" },
  json: {
    email: "email@gmail.com",
    amount: amount * 100,
    initiate_type: "inline",
    callback_url: `${BackendBaseUrl}/payment-callback`, // <<<============
  },
})

核心问题：错误在路由回调内监听connection事件 #

io.on("connection")是用来监听新Socket客户端连接的，应该在服务器启动时仅注册一次，而非每次API请求都重复注册。当前每次调用/post-data接口都会添加新的监听器，且该监听器仅在新客户端连接时触发——支付回调触发API时并没有新Socket客户端连接，因此console.log("Socket Running...")不会执行。

正确实现步骤 #

1. 将Socket连接监听移至路由外
   在server.js中单独处理Socket连接，维护客户端房间信息：

   // server.js中新增
   io.on("connection", (socket) => {
     console.log(`客户端 ${socket.id} 已连接`);
     // 接收前端发送的房间加入请求
     socket.on("join_room", (room) => {
       socket.join(room);
       console.log(`客户端 ${socket.id} 加入房间 ${room}`);
     });
     socket.on("disconnect", () => {
       console.log(`客户端 ${socket.id} 已断开连接`);
     });
   });
   

2. 修改路由代码，直接通过io推送消息
   无需在路由内监听connection，直接使用io.to(room).emit()向指定房间推送消息：

   // postData路由修改后
   module.exports = function (io) {
     const router = require("express").Router();
     router.post("/", async (req, res) => { 
       const data = req?.body?.data.message;
       const room = req?.body?.data?.room;
   
       // 直接向目标房间推送消息
       if (room) {
         io.to(room).emit("the_message", data);
         console.log(`已向房间 ${room} 推送消息: ${data}`);
       }
   
       console.log("Under socket...");
       return res.status(200).json({ data: req.body.data });
     });
     return router;
   };
   

3. 前端配合加入目标房间
   前端连接Socket后，需主动发送join_room事件加入对应房间，才能接收推送：

   // 前端示例代码
   import { io } from "socket.io-client";
   const socket = io("http://localhost:3004");
   
   // 连接成功后加入目标房间（如商品ID、活动ID作为房间标识）
   socket.on("connect", () => {
     const targetRoom = "商品或活动的唯一ID";
     socket.emit("join_room", targetRoom);
   });
   
   // 监听后端推送的购买详情
   socket.on("the_message", (purchaseData) => {
     console.log("收到实时购买消息:", purchaseData);
     // 更新页面展示逻辑
   });
   

4. 适配支付回调场景
   支付回调为GET路由，需调整逻辑实现实时推送：

   • 用户支付成功后，支付网关跳转至/payment-callback GET路由
   • 在该路由内完成资产发放逻辑
   • 提取购买详情（如商品ID、购买信息），确定推送目标房间
   • 调用io.to(目标房间ID).emit("purchase_success", 购买详情)
   • 最后跳转回前端页面

额外注意事项 #

• 确保Socket.IO的CORS配置正确，允许前端域名访问
• 房间ID需前后端保持一致（建议使用商品ID、活动ID等唯一标识）
• 若需用户认证，可在Socket连接时传递身份信息，验证通过后再允许加入房间

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