分类导航

程序问答发布时间：2022-06-02 发布网站：大佬教程 code.js-code.com

大佬教程收集整理的这篇文章主要介绍了使用Redis与socket.io和NodeJs建立实时聊天，大佬教程大佬觉得挺不错的，现在分享给大家，也给大家做个参考。

如何解决使用Redis与socket.io和NodeJs建立实时聊天？

开发过程中遇到使用Redis与socket.io和NodeJs建立实时聊天的问题如何解决？下面主要结合日常开发的经验，给出你关于使用Redis与socket.io和NodeJs建立实时聊天的解决方法建议，希望对你解决使用Redis与socket.io和NodeJs建立实时聊天有所启发或帮助；

Redis比键值存储更重要。

因此，您需要以下内容：

聊天消息，
两人讨论，
您没有提及时间限制，因此让我们假设您在一段时间后将邮件存档，
您也不会说是否要在两个人（例如论坛）或连续消息（例如Facebook）之间使用单独的“线程”。我假设是连续的。

对于每个用户，您必须存储他发送的消息。比方说APP_nameSPACE:MESSAGES:<USER_ID>:<MESSAGE_ID>。我们在此处添加userID，以便我们可以轻松检索单个用户发送的所有消息。

并且，对于每两个用户，您需要跟踪他们的对话。作为键，您可以简单地使用他们的用户IDAPP_nameSPACE:CONVERSATIONS:<USER1_ID>-<USER2_ID>。为了确保两个用户始终获得相同的共享对话，可以对他们的ID进行排序，以便用户132和145都将132：145作为对话密钥

那么在“对话”中存储什么呢？让我们使用一个列表：[messageKey, messageKey, messageKey]。

好的，但是messageKey现在是什么？上面的userID和messageID的组合（因此我们可以获得实际的消息）。

因此，基本上，您需要两件事：

存储消息并为其提供ID
将对此消息的引用存储到相关对话中。

使用节点和标准redis / hiredis客户端，这有点像（我将跳过明显的错误等检查，而我将编写ES6。如果您仍然无法阅读ES6，只需将其粘贴到babel即可）：

 // assuming the init connects to redis and exports a redisClIEnt
import redisClIEnt from './redis-init';
import uuID from `node-uuID`;


export function storeMessage(userID, toUserID, message) {

  return new Promise(function(resolve, reject) {

    // give it an ID.
    let messageID = uuID.v4(); // gets us a random uID.
    let messageKey = `${userID}:${messageID}`;
    let key = `MY_APP:MESSAGES:${messageKey}`;
    clIEnt.hmset(key, [
      "message", message,
      "timestamp", new Date(),
      "toUserID", toUserID
    ], function(err) {
      if (err) { return reject(err); }

      // Now we stored the message. But we also want to store a reference to the messageKey
      let convoKey = `MY_APP:CONVERSATIONS:${userID}-${toUserID}`; 
      clIEnt.lpush(convoKey, messageKey, function(err) {
        if (err) { return reject(err); }
        return resolve();
      });
    });
  });
}

// We also need to retreive the messages for the users.

export function getConversation(userID, otherUserID, page = 1, limit = 10) {
  return new Promise(function(resolve, reject) {
    let [userID1, userID2] = [userID, otherUserID].sort();
    let convoKey = `MY_APP:CONVERSATIONS:${userID1}-${userID2}`;
    // lets sort out paging stuff. 
    let start = (page - 1) * limit; // we're zero-based here.
    let stop = page * limit - 1;
    clIEnt.lrange(convoKey, start, stop, function(err, messageKeys) {

      if (err) { return reject(err); }
      // we have message keys, Now get all messages.
      let keys = messageKeys.map(key => `MY_APP:MESSAGES:${key}`);
      let promises = keys.map(key => getMessage(key));
      Promise.all(promises)
      .then(function(messages) {
         // Now we have them. We can sort them too
         return resolve(messages.sort((m1, m2) => m1.timestamp - m2.timestamp));
      })
      .catch(reject);
    }); 
  });
}

// we also need the getMessage here as a promise. We Could also have used some Promisify implementation but hey.
export function getMessage(key) {
  return new Promise(function(resolve, reject)  {
    clIEnt.hgetall(key, function(err, message) {
      if (err) { return reject(err); }
      resolve(message);
    });
  });
}

现在这还很粗糙，还没有经过测试，但这就是您如何做到这一点的要旨。