向房间发送消息的 SocketIO 无法正常工作

Question

我正在创建一个允许用户与其他个人用户进行对话的应用。 作为应用程序的用户，每当我与之交谈的人连接到应用程序时，我都希望收到一条消息，提醒我他在线。 为此，我将 node.js 与 socketIO 一起使用并做出反应。

我在服务器中实现以下内容的方式是：

const socketio = require('socket.io');
const io = socketio(server);

io.on('connection', async (socket) => {
    const { user } = socket.request;

    const userConversationIds = user.conversations;
    socket.join(conversationIds);

    let ioToConversations = io;
    userConversationIds.forEach((conversationId) => {
        ioToConversations = ioToConversations.to(conversationId);
    });

    ioToConversations.emit('online', `${user.firstName} ${user.lastName} is now online!`);
});

在客户端：

import io from 'socket.io-client';
const socket = io();

componentDidMount () => {
    socket.on('online', (messageText) => {
        console.log(messageText); // eslint-disable-line 
    });
};

以上所有都导致了“用户现在在线”消息，只发送给now-connected-user本身。 我希望对话中的其他用户拥有该消息，而连接的用户本身没有。

我在这里做错了什么？

Answer 1

一个错误可能是您没有正确连接到服务器，您需要使用此代码进行连接，并将<port> 替换为您的端口号，假设您在本地运行： io.connect("http://localhost:<port>")

另一个错误可能是您没有同时使用.io() 和.emit() 方法。我的意思是你在 forEach 循环之后使用了.emit() 方法。您可以尝试这样做：

io.on("connection", async (socket) => {
  const { user } = socket.request;
  const userConversationIds = user.conversations;

  let ioToConversations = io;

  userConversationIds.forEach((conversationId) => {
    ioToConversations = ioToConversations
      .to(conversationId)
      .emit("online", `${user.firstName} ${user.lastName} is now online!`);
  });
});

另一个错误可能是因为您没有使用.join() 方法使每个用户的套接字加入特定房间。您可以通过以下方式做到这一点：

userConversationIds.forEach((conversationId) => {
    socket.join(conversationId);
  });

此代码应放在发出消息的forEach 循环之前。 你也可以同时加入和发射，但是我没有测试过以下内容：

userConversationIds.forEach((conversationId) => {
    socket.join(conversationId);

    ioToConversations = ioToConversations
      .to(conversationId)
      .emit("online", `${user.firstName} ${user.lastName} is now online!`);
  });