基于Redis的实时搜索

一直想把前期做的一种完全基于redis的实时搜索功能的实现方式总结一下，但是一直没有合适的时间，今天终于可以坐下来把整个思路理一下了。还是先看下整体效果，如下图所示。

该搜索是整个瑞知社区的一个功能项，瑞知社区类似于知乎，一个垂直问答社区，为了提高用户体验，所以希望在搜索功能上可以体验更好，可以逐字匹配搜索，可以按照拼音(不是拼音首字母)模糊搜索。由于该项目没有考虑使用关系型数据库，所以决定把所有的索引数据都放在内存中，获取查找目标过程完全基于内存，这样速度更快。

下面说说整个过程的实现思路，还有很多不完善的地方，敬请指教！

搜索的过程简单点说就是建立索引和按照索引取值的过程，对需要搜索的目标数据进行索引，然后将索引结果放入redis中，索引结果的数据结构可以根据实际情况来决定，比如我这里没有用到关系数据库，全部使用的是redis来存储，包括搜索目标数据，所以索引的数据结构是搜索关键词作为key，value中存入的是搜索目标在redis中存入时的key值；如果你使用的关系型数据库，比如mysql，那么这里的value可能存的就是对应数据库中记录的id值。当用户输入关键词进行搜索的时候，首先会对用户输入的关键词进行分词，再根据分词结果查询索引，命中目标后，根据索引获取最终的查询目标数据。

以上就是整个搜索的大致流程，下面我们来把他剖开来分析，看看每个过程如何实现。

当用户提出一个问题，或者回答问题时，系统都会实时的建立索引(这里可以考虑使用异步建立索引，因为查询新内容不是实时的)，索引的数据结构为Sorted Set，score值全部设为1，这样索引排序时就可以按照字母表顺序自然排序。key为分词后的值(使用的分词器是lucene中的IKAnalyzer)，value保存的是对应搜索目标实体redis中存储的key值； 如果同种类型的多个关键词分词后有重复的分词值，就将实体key值存在同一个分词集合中，如，某2个问题进行分词后，都包含【争夺】这个分词值，那么这2个问题的实体key值都会作为index:question:[争夺]的value值。如下图所示：

对于逐字匹配搜索的需求，我们的索引在建立时，也需要区别对待，当我们输入关键词时，并不希望输入完整的关键词后才能检索出相关内容，而是输入部分关键词时立刻出现相关结果，也即是瞬时响应效果。如下图所示：

那就要求我们在建立索引时，需要对每个分词后的值再按字或者字母建立索引值，这种索引我们称之为逐字匹配索引，或者前缀匹配索引，用Sorted Set来存储(key为index:prefix:key)，其值为分词按字截取后的值，存储时其score值设为相同值1，那么所有的值会按照字母表的顺序进行排列，这样就使得逐字匹配索引中相近分词值会集中排列；当你搜索关键词时会搜出一定范围内（该范围的值会直接影响性能）的所有相似索引值。前缀匹配索引数据结构如下图所示：

对于中文，前缀匹配索引数据结构如下图所示：

对于中文用户，希望通过汉语拼音直接搜索，那就需要在对中文分词结果索引的同时，进行汉语拼音的转译，然后将转译后的汉语拼音作为key值，所有同音词的中文分词都作为value，存储在set中，这种方式可以确保检索出汉语拼音对应的所有中文分词。数据结构如下图所示：

从以上我们可以看出，在建立索引数据时，我们对同一个分词进行了三种索引。

当用户在输入每个关键词的每个字时，首先对输入的关键词进行分词操作，然后会同时检索前缀和中文拼音索引，获取该关键词以及相关类似的关键词，然后除掉重复的关键词，最后根据搜索目标的类型，构建【普通关键词索引】的key值，求并集获取结果。

我们以一个例子来说明整个过程，比如我们输入的关键词是“南京”，经过检索前缀和中文拼音索引后，返回的关键词如下图所示：

然后根据搜索目标类型，构建的【普通关键词索引】的key值如下图所示：

这样，就可以根据question类型的索引key值找到对应的question实体的对应key，求并集，最终返回json数据给前端即可。整个流程就是这样。

最终结果如下图所示：

Object[] resultArr = jedisTemplate.zrange(IConstant.INDEX_SEARCH_PREFIX_KEY, t, t + IConstant.SEARCH_PREFIX_MATCH_MAXRESULT_COUNT * 60).toArray();

是不是需要对关键词同时建立三种索引； 在搜索的准确性上，需要对分词器进行优化； 可以灵活设定结果集的排序字段。