Socket.io 如何在服务端事件监听器内部触发emit发送消息

问题根因 #

你对Socket.IO的事件触发逻辑存在误解：

• 服务端通过socket.on()注册的监听器，仅能捕获客户端主动上报到服务端的事件
• 你在setUp回调中调用的io.emit()、socket.emit()、io.sockets.emit()，都是把事件推送给客户端的动作，不会触发服务端自身注册的事件监听器，所以displayBasicText对应的日志自然不会打印。

如果同时存在客户端收不到事件的情况，大概率是客户端事件注册顺序错误：先发送了setUp事件，之后才注册displayBasicText的监听，导致服务端推送的事件被漏掉。

解决方案 #

方案1：抽离公共逻辑复用 #

如果你的需求是在setUp流程中复用displayBasicText的处理逻辑，直接把公共逻辑抽成独立函数调用即可，不要通过事件emit触发服务端自身逻辑：

const express = require("express");
const app = express();
const http = require("http");
const server = http.createServer(app);
const { Server } = require("socket.io");
const io = new Server(server, {
  cors: {
    origin: "*",
    methods: ["GET", "POST", "PUT", "DELETE"]
  }
});

server.listen(3100, () => {
  console.log("listening on *:3100");
});


// CORS
app.use((req, res, next) => {
  res.setHeader("Access-Control-Allow-Origin", "*");
  res.header(
    "Access-Control-Allow-Headers",
    "Origin, X-Requested-With, Content-Type, Accept"
  );
  next();
});

// 抽离displayBasicText公共处理逻辑
function handleDisplayBasicText(data, ackCallback) {
  console.log("Your message is: " + data);
  io.emit("displayBasicText", data);
  if (ackCallback) ackCallback("ack");
}

io.on("connection", (socket) => {
  console.log("a user connected");

  socket.on("disconnect", () => {
    console.log("user disconnected");
  });

  socket.on("setUp", (data) => {
    console.log("Setting up! " + data);
    // 直接调用公共逻辑，无需走事件emit
    handleDisplayBasicText("text");
  });

  socket.on("displayBasicText", (data, fn) => {
    handleDisplayBasicText(data, fn);
  });
});

方案2：修正客户端事件注册顺序 #

如果是客户端收不到setUp触发的推送事件，调整客户端代码顺序，保证先注册监听再发送setUp请求即可：

// 客户端代码示例
// 第一步：先注册displayBasicText监听
socket.on('displayBasicText', (data) => {
  console.log('收到服务端推送：', data)
})
// 第二步：再发送setUp事件
socket.emit('setUp', '初始化参数')

内容的提问来源于stack exchange，提问作者ariel-walley