如何处理套接字时的错误。io发出消息？

Question

我有发送消息的路由。消息首先保存在数据库中，然后广播给房间中的每个聊天订阅者。消息已成功保存，但服务器（节点/快递/打字稿）在命中 socket.io 实例时崩溃。错误是：

错误发送消息错误：回调不支持广播时，在BroadcastOperator.emit（/用户/Myname/桌面/代码/myapp/服务器/node_modules/socket.io/dist/broadcast-operator.js： 107:19）

路线是：

import { Response, Request } from "express";
import { ConversationControler } from "../../controllers/conversation";
import { SocketControler } from "../../controllers/socket";

interface SendMessage extends Request {
  body: {
    conversationName: string;
    userId: string;
    message: string;
  };
}

const sendMessage = async (req: SendMessage, res: Response): Promise<any> => {
  try {
    const { conversationName, userId,  message } = req.body;
    await ConversationControler.sendMessage(
      conversationName,
      userId,
      message
    );
    const io = req.app.locals.io;
    SocketControler.dispatchMessage(io, conversationName, message);
    return res.status(201)
  } catch (err) {
    throw new Error("error.send-message");
  }
};

export default sendMessage;

sendMessage函数是：

static dispatchMessage(
    io: Server,
    conversationName: string,
    message: string
  ) {
    return io
      .in(`chat@${conversationName}`)
      .emit("newMessage", message, (err: Error) => {
        if (err) {
          throw new Error("error.send-message");
        }
      });
  }

如果我删除回调，邮递员中的请求将永远运行。我让它，服务器崩溃。无论如何，消息都保存在数据库中。

如何解决此问题？

Answer 1

不支持广播回调时。只有当您向单个用户发射时，它才有效。

喜欢这个：

// client-side
socket.emit("update item", "1", { name: "updated" }, (response) => {
  console.log(response.status); // ok
});