我以前从未使用过 Redis,但我一直想用,而且我当前的用例似乎很合适。
我实际上是在尝试构建一个消息传递应用程序。当一个用户向另一个用户发送消息时,发送到服务器的数据如下所示:
{ from_user: 'alice', for_user: 'bob', payload: 'hello!', timestamp: 1404695488 }
然后我希望能够做的是:
给定 alice,查看所有向 alice 发送了一条 alice 尚未阅读的消息的用户
给定 alice 和 bob,返回 bob 发送给 alice 的所有消息的列表,我可以从中弹出 alice 已阅读的内容。一旦 alice 阅读了 bob 发送给她的所有消息,#1 将不会返回 bob。
如果我还不够清楚,请告诉我。此外,我选择 Redis 的另一部分原因是因为这是一个消息传递应用程序,我想利用 Pub/Sub 功能。
最佳答案
解决此问题的一种方法是在发送消息时更新以下数据结构:
未读消息:为存储他/她的未读消息的每个用户保留一个排序集。使用时间戳作为分数并将时间戳和有效负载连接为成员,例如:
ZADD unread-messages:bob:alice 1404695488 "1404695488:hello!"
未读消息的发件人:为存储发件人的每个用户保留一个集合,即:
SADD unread-senders:bob alice
。`
要向 Bob 显示所有向他发送消息但他尚未阅读的用户,请执行 SMEMBERS unread-senders:bob
。
当 Bob 阅读消息时:
- 将其从未读排序集中移除 -
ZREM unread-messages:bob:alice "1404695488:hello!"
。 - 使用
EXISTS unread-messages:bob:alice
检查 unread-messages 键是否存在 - 如果没有任何消息,Redis 将删除它。如果 key 被删除,则从未读发件人集中删除相关用户:SREM unread-senders:bob alice
。
注意:您想要执行实现添加未读消息并以原子方式删除它的操作,因此为此目的使用 MULTI/EXEC block 或 Lua 脚本。
关于redis - 构建redis键,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/24601987/