AliCloudDB for redis应用场景之存储最新N条聊天记录
场景介绍
在各种IM通信工具中,常常需要展示最新的聊天记录,这种数据写入频繁,对响应时间要求高。一般情况,这种场景通常会选择持久化存储存储全量数据,用于历史查询,再选择缓存类产品加速访问。对于这种展示最新数据的场景,使用AliCloudDB for redis的list结构存储是比较合适的选择
业务设计
假设A用户发信息给B用户,那么A用户和B用户的value列表中都应该添加这条信息。因此这样的数据结构就可以做如下设计:
key: 用户ID
value: 聊天信息列表
由于缓存空间有限,因此只会缓存最新的N条数据,这就用到队列的先进先出的特性。使用lpush和ltrim就可以保证队列长度在N条之内
代码示例
package com.aliyun;
import java.util.List;
import redis.clients.jedis.Jedis;
public class SampleMessageQueue {
static int MAX_MESSAGE_QUEUE = 10;
public void SaveMessage(Jedis jedis, String userId, String message)
{
jedis.lpush(userId, message);
jedis.ltrim(userId, 0, MAX_MESSAGE_QUEUE);
}
public void PrintRecentMessage(Jedis jedis, String userId)
{
long end = jedis.llen(userId);
List<String> messageList = jedis.lrange(userId, 0, end);
for (int i = 0; i < messageList.size(); ++i)
{
System.out.println(messageList.get(i));
}
}
public void SAMPLE_MessageQueue()
{
String host = "127.0.0.1";
int port = 6728;
try {
Jedis jedis = new Jedis(host, port);
String authString = jedis.auth("INSTANCEID:PASSWORD");
if (!authString.equals("OK"))
{
//log.error("AUTH Failed: " + authString);
return;
}
String userId = "TEST";
for (int i = 0; i < 1000; i++)
{
String message = "Hello World " + i + " !";
SaveMessage(jedis, userId, message);
PrintRecentMessage(jedis, userId);
}
jedis.quit();
jedis.close();
} catch (Exception e) {
// TODO: handle exception
e.printStackTrace();
}
}
}