使用redisbuild立与socket.io和NodeJs的实时聊天
我想为我的项目构build一个实时聊天系统，但实际上我有一些Redis问题，因为我希望我的数据尽可能地保存。
我的问题：
我想使用Socket Io在一个封闭的组（两个人）中进行实时聊天，但是如何存储消息？
Redis是一个关键的价值商店，这意味着如果我想存储的东西，我需要添加一个唯一的关键，我的数据才能被存储。
如果同一个用户发布多个消息，我将在redis中使用哪些密钥？ 我正在考虑独特的ID作为唯一的密钥，但因为我想能够获取这个评论，当用户login聊天页面，但如果我这样做，我需要写另一个数据库聊天ID与发布的用户信息
我忘了什么吗？ 有没有最好的方法来做到这一点？
对不起，我的英语不好。
Redis不仅仅是重要的商店。
所以你需要以下内容：
- 聊天消息，
- 两人讨论，
- 你没有提到时间限制，所以我们假设你在一段时间之后存档消息，
- 你也不会说如果你想两个人之间分开的“线索”，如论坛或连续消息，如Facebook。 我假设连续。
对于每个用户，你必须存储他发送的消息。 假设APP_NAMESPACE:MESSAGES:<USER_ID>:<MESSAGE_ID> 。 我们在这里添加userId，以便我们可以轻松地检索单个用户发送的所有消息。
而且，对于每两个用户，您需要跟踪他们的对话。 作为一个关键，您可以简单地使用它们的用户APP_NAMESPACE:CONVERSATIONS:<USER1_ID>-<USER2_ID> 。 为了确保你总是得到两个用户相同的共享对话，你可以对他们的ID进行sorting，这样用户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); }); }); }
现在这是粗糙和未经testing，但这是你如何做到这一点的要点。
redis是你项目中的一个限制吗？