标签：java
Redis自动补全：1. 自动补全最近联系人
使用List列表结构有序地存储元素，redis主要用于记录联系人列表，而非实际的执行自动补全操作，数据的过滤及补全在客户端执行；对于较短的列表来说可行；
构建最近联系人自动补全列表，如果指定的联系人已经存在，将从列表移除该联系人，将他重新推入列表的最左端；对列表进行修剪，保留位于列表前的100个联系人：
public void addUpdateContact(Jedis conn, String user, String contact) {
String acList = "recent:" + user;
Transaction trans = conn.multi();
trans.lrem(acList, 0, contact);
trans.lpush(acList, contact);
trans.ltrim(acList, 0, 99);
trans.exec();
}
当用户不想再联系某个人，将他从列表删除：
public void removeContact(Jedis conn, String user, String contact) {
conn.lrem("recent:" + user, 0, contact);
}
获取自动补全列表，查找匹配的用户，但实际的自动补全处理是在java里完成的，所以操作首先需要获取整个列表结构：
public List<String> fetchAutocompleteList(Jedis conn, String user, String prefix) {
List<String> candidates = conn.lrange("recent:" + user, 0, -1);
List<String> matches = new ArrayList<String>();
for (String candidate : candidates) {
if (candidate.toLowerCase().startsWith(prefix)){
matches.add(candidate);
}
}
return matches;
}
2. 通讯录自动补全
对于包含非常多元素的列表，必须直接在redis内部完成匹配元素的工作，尽量减少服务器传输给客户端的数据量；使用ZSet有序集合来存储；
（把有序集合里的所有分值都设为0，利用其性质：当所有成员的分值都相同时，zset按照成员的名字来排序；当所有成员的分值都为0时，成员将按照字符串的二进制顺序进行排序。）
（用户输入abc，我们需要向zset插入两个元素，一个在abbz后面，即”abb{“，一个排在abd前面,即”abc{“；用watch监视有序集合zset；根据这两个元素的排名调用zrange命令，最后移除插入的两元素）
根据给定前缀，生成查找范围：
private static final String VALID_CHARACTERS = "`abcdefghijklmnopqrstuvwxyz{";
public String[] findPrefixRange(String prefix) {
int posn = VALID_CHARACTERS.indexOf(prefix.charAt(prefix.length() - 1));
char suffix = VALID_CHARACTERS.charAt(posn > 0 ? posn - 1 : 0);
String start = prefix.substring(0, prefix.length() - 1) + suffix + '{';
String end = prefix + '{';
return new String[]{start, end};
}
自动补全函数：
public Set<String> autocompleteOnPrefix(Jedis conn, String guild, String prefix) {
String[] range = findPrefixRange(prefix);
String start = range[0];
String end = range[1];
String identifier = UUID.randomUUID().toString();
start += identifier;
end += identifier;
String zsetName = "members:" + guild;
conn.zadd(zsetName, 0, start);
conn.zadd(zsetName, 0, end);
Set<String> items = null;
while (true){
conn.watch(zsetName);
int sindex = conn.zrank(zsetName, start).intValue();
int eindex = conn.zrank(zsetName, end).intValue();
int erange = Math.min(sindex + 9, eindex - 2);
Transaction trans = conn.multi();
trans.zrem(zsetName, start);
trans.zrem(zsetName, end);
trans.zrange(zsetName, sindex, erange);
List<Object> results = trans.exec();
if (results != null){
items = (Set<String>)results.get(results.size() - 1);
break;
}
}
for (Iterator<String> iterator = items.iterator(); iterator.hasNext(); ){
if (iterator.next().indexOf('{') != -1){
iterator.remove();
}
}
return items;
}
加入通讯录或移除通讯录：
public void joinGuild(Jedis conn, String guild, String user) {
conn.zadd("members:" + guild, 0, user);
}
public void leaveGuild(Jedis conn, String guild, String user) {
conn.zrem("members:" + guild, user);
}
标签：java
原文地址：http://blog.51cto.com/13580976/2085000
