我想为我的项目建立一个实时聊天系统,但实际上我在Redis方面遇到了一些问题,因为我希望我的数据存储得尽可能好。
我的问题:
我想使用Socket Io在一个封闭的小组(由两个人组成)中进行实时聊天,但如何存储消息?
Redis是一个键值存储,这意味着如果我想存储一些东西,我需要在存储之前向我的数据添加一个唯一的键。
如果同一个用户发布多条消息,我会在redis中使用哪些密钥?我认为唯一的ID是唯一的密钥,但由于我希望能够在用户登录聊天页面时获取这些评论,但如果我这样做了,我需要编写另一个数据库,将聊天ID与发布该消息的用户关联起来
我忘了什么吗?有最好的方法吗?
抱歉我英语不好。
Redis不仅仅是键值存储。
所以你想要以下内容:
- 聊天消息
- 两人讨论
- 您没有提到时间限制,所以假设您在一段时间后归档消息
- 你也没有说你是否想要两个人之间的独立"线程",比如论坛或连续消息,比如facebook。我假设是连续的
对于每个用户,您必须存储他发送的消息。比方说APP_NAMESPACE:MESSAGES:<USER_ID>:<MESSAGE_ID>
。我们在这里添加userId,这样我们就可以很容易地检索单个用户发送的所有消息。
而且,对于每两个用户,您都需要跟踪他们的对话。作为密钥,您可以简单地使用他们的用户ID APP_NAMESPACE:CONVERSATIONS:<USER1_ID>-<USER2_ID>
。为了确保您总是为两个用户获得相同的共享会话,您可以对他们的ID进行分类,这样用户132和145都将132:145作为会话密钥
那么,在"对话"中存储什么呢?让我们使用一个列表:[messageKey, messageKey, messageKey]
。
好的,但是现在的消息Key是什么?上面的userId和messageId的组合(这样我们就可以得到实际的消息)。
所以基本上,你需要两件事:
- 存储邮件并为其提供ID
- 将对此邮件的引用存储到相关对话中
对于node和标准的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);
});
});
}
现在,这是粗糙和未经测试的,但这是如何做到这一点的要点。
redis是项目中的一个约束吗?
你可以通过这个http://autobahn.ws/python/wamp/programming.html