redisを使用して、socket.ioおよびNodeJとのリアルタイムチャットを構築します

Redisは単なるKey-Valueストアではありません。

したがって、次のものが必要です：

チャットメッセージ
2人でのディスカッション
時間の制約について言及していなかったので、しばらくしてからメッセージをアーカイブするとします。
また、フォーラムやFacebookのような継続的なメッセージのように、2人の間に別々の「スレッド」が必要かどうかも言いません。継続的だと思います。

ユーザーごとに、彼が送信するメッセージを保存する必要があります。 APP_NAMESPACE:MESSAGES:<USER_ID>:<MESSAGE_ID>としましょう。ここにuserIdを追加して、1人のユーザーから送信されたすべてのメッセージを簡単に取得できるようにします。

また、2人のユーザーごとに、会話を追跡する必要があります。キーとして、ユーザーID APP_NAMESPACE:CONVERSATIONS:<USER1_ID>-<USER2_ID>を使用するだけです。。 2人のユーザーが常に同じ共有会話を行えるようにするには、IDを巧みに並べ替えて、ユーザー132と145の両方が会話キーとして132：145を持つようにします

。

では、「会話」に何を保存するのでしょうか。リストを使用してみましょう：[messageKey, messageKey, messageKey] 。

わかりました、しかし今messageKeyは何ですか？上記のuserIdとmessageIdの組み合わせ（実際のメッセージを取得できるようにするため）。

つまり、基本的に2つ必要です。

メッセージを保存して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);
    });
  });
}

これは大雑把でテストされていませんが、これを行う方法の要点です。