文档章节

使用Redis解决“树”形数据的复杂查询

qiujiayu
 qiujiayu
发布于 2017/08/08 23:03
字数 1036
阅读 2162
收藏 41

使用Redis解决“树”形数据的复杂查询

最近因业务需要,研究了一下树数据结果的存储及查询解决方案。 最初的想法是使用neo4j,可是在网上看了一下开源的不支持集群,感觉用的人不多。

网上也查了一些 树形结构数据存储方案 但每种实现方案都有它的一定局限性。

想了一短时间后,想出了下面的方案:

一、 因为复杂的查询都由Redis来处理,所以数据库表的设计就变得非常简单:tree 表

字段名称 数据类型 备注说明
id int 主键
parent_id int 上级节点ID

二、Redis的数据存储方案:

把表的数据存储到一个Hash表中,使用表中的id值做为此hash表的key, value值为:

{
   id: 10,
   parentId: 9,
   childIds: [11]
}

代码实现

为了简化测试,这里只演示Redis相关的操作

  1. Tree 类定义

     public class Tree {
         private Integer id;
         private String name;
         private Integer parentId;
         private List<Integer> childIds;
     }
    
  2. 往Redis中添加测试数据:

     [@Test](https://my.oschina.net/azibug)
     public void addTestData() throws Exception {
         String key = "tree-test-key";
         Tree tree = new Tree();
         List<Integer> childIds = new ArrayList<>();
         int max = 100000
         tree.setChildIds(childIds);
         for (int i = 0; i < max; i++) {
             tree.setId(i);
             tree.setName("tree" + i);
             if (i > 0) {
                 tree.setParentId(i - 1);
             }
             childIds.clear();
             if(i < (max - 1)){
                 childIds.add(i + 1);
             }
             redis.setHash(key, "" + i, JsonUtil.toJson(tree));
         }
     }
    
  3. Lua 代码的实现

在Lua中使用递归时,需要使用“尾调用”来优化代码。关于尾调用的知识,大家可以上网去搜索。

获取所有子节点 get-tree-childs.lua

local treeKey = KEYS[1]
local fnodeId  = ARGV[1]

local function getTreeChild(currentnode, t, res)
  if currentnode == nil or t == nil  then
    return res
  end

  local nextNode = nil
  local nextType = nil
  if t == "id" and (type(currentnode) == "number" or type(currentnode) == "string") then
    local treeNode = redis.call("HGET", treeKey, currentnode)
    if treeNode then
      local node = cjson.decode(treeNode)
      table.insert(res, treeNode)
      if node and node.childIds then
        nextNode = node.childIds
        nextType = "childIds"
      end
    end
  elseif t == "childIds" then
    nextNode = {}
    nextType = "childIds"
    local treeNode  = nil
    local node = nil
    local cnt = 0
    for _, val in ipairs(currentnode) do
      treeNode = redis.call("HGET", treeKey, tostring(val))
      if treeNode then
        node = cjson.decode(treeNode)
        table.insert(res, treeNode)
        if node and node.childIds then
          for _, val2 in ipairs(node.childIds) do
            table.insert(nextNode, val2)
            cnt = cnt + 1
          end
        end
      end
    end
    if cnt == 0 then
      nextNode = nil
      nextType = nil
    end
  end
  return getTreeChild(nextNode, nextType, res)
end


if treeKey and fnodeId then
  return getTreeChild(fnodeId, "id", {})
end

return {}

获取所有子节点数目 get-tree-childs-cnt.lua

local treeKey = KEYS[1]
local fnodeId  = ARGV[1]

local function getTreeChildCnt(currentnode, t, res)
  if currentnode == nil or t == nil  then
    return res
  end

  local nextNode = nil
  local nextType = nil
  if t == "id" and (type(currentnode) == "number" or type(currentnode) == "string") then
    local treeNode = redis.call("HGET", treeKey, currentnode)
    if treeNode then
      local node = cjson.decode(treeNode)
      res = res + 1
      if node and node.childIds then
        nextNode = node.childIds
        nextType = "childIds"
      end
    end
  elseif t == "childIds" then
    nextNode = {}
    nextType = "childIds"
    local treeNode  = nil
    local cnt = 0
    for _, val in ipairs(currentnode) do
      treeNode = redis.call("HGET", treeKey, tostring(val))
      if treeNode then
        local node = cjson.decode(treeNode)
        res = res + 1
        if node and node.childIds then
          for _, val2 in ipairs(node.childIds) do
            table.insert(nextNode, val2)
            cnt = cnt + 1
          end
        end
      end
    end
    if cnt == 0 then
      nextNode = nil
      nextType = nil
    end
  end
  return getTreeChildCnt(nextNode, nextType, res)
end


if treeKey and fnodeId then
  return getTreeChildCnt(fnodeId, "id", 0)
end

return 0

获取所有子节点数目 get-tree-parent.lua

local treeKey = KEYS[1]
local nodeId  = ARGV[1]

local function getTreeParent(treeKey, res, nodeId)
  if nodeId == nil or not (type(nodeId) == "number" or type(nodeId) == "string") then
    return res
  end
  local treeNode = redis.call("HGET", treeKey, nodeId)
  local nextNodeId = nil
  if treeNode then
    local node = cjson.decode(treeNode)
    table.insert(res, treeNode)
    if node then
      nextNodeId = node.parentId
    end
  end
  return getTreeParent(treeKey, res, nextNodeId)
end


if treeKey and nodeId then
  return getTreeParent(treeKey, {}, nodeId)
end

return {}

获取所有子节点数目 get-tree-parent-cnt.lua

local treeKey = KEYS[1]
local nodeId  = ARGV[1]

local function getTreeParentCnt(treeKey, nodeId, res)
  if nodeId == nil or not (type(nodeId) == "number" or type(nodeId) == "string") then
    return res
  end
  local treeNode = redis.call("HGET", treeKey, nodeId)
  local nextNodeId = nil
  if treeNode then
    local node = cjson.decode(treeNode)
    res = res + 1
    if node then
      nextNodeId = node.parentId
    end
  end
  return getTreeParentCnt(treeKey, nextNodeId, res)
end


if treeKey and nodeId then
  return getTreeParentCnt(treeKey, nodeId, 0)
end

return 0

以上代码因为使用了“尾调用”,所以变得相对比较复杂

总结

此方案相对比较灵活,能支持相对比较大量的数据。

缺点:过于依赖Redis。数据同步会麻烦些,好在操作不是很复杂。

© 著作权归作者所有

共有 人打赏支持
qiujiayu
粉丝 52
博文 29
码字总数 12610
作品 1
东城
架构师
私信 提问
加载中

评论(10)

无聊的人啊
无聊的人啊
瞎折腾,对比和数据库性能和可用性
lxbzmy
lxbzmy
用嵌套集合模型。
九二妹妹
九二妹妹
没觉得有什么优化的地方
老陌
老陌
存两套,up_{id} = {parent_id}, down_{id} = {child_id} 最底层的 child_id = 0 最上层的 parent_id = 0。 另外应该避免递归吧。
纳兰清风
纳兰清风
这要是树的节点比较多,取一棵树得访问很多次redis吧
开源中国刘德华
开源中国刘德华

引用来自“夜辰”的评论

我们在mysql里面用路径法存的,路径存的也有一定规律。前几天我解决了树形的问题,最后用like解决的,最后distinct一下:trollface:

科普一下
夜辰
夜辰
我们在mysql里面用路径法存的,路径存的也有一定规律。前几天我解决了树形的问题,最后用like解决的,最后distinct一下:trollface:
qiujiayu
qiujiayu

引用来自“BoXuan”的评论

就不能把父节点ID作为key,value为其下的所有直接子节点ID?
不行的,这样没办法获取 父节点之上的节点。
银杏果果
银杏果果
就不能把父节点ID作为key,value为其下的所有直接子节点ID?
梦朝思夕
梦朝思夕
需要进行大量循环,并且需要get redis中的list性能不会很好的
系统参数管理模块

【项目背景】 随着业务系统的增多,一些公共配置信息也随之增多,比如短信开启/关闭、邮件开启/关闭、技能信息数据、行业信息数据、省市区数据等。急需一个统一的服务来进行管理,降低系统参...

network2019
2017/06/02
1
1
Redis读性能优化

首先提一个问题,一个Redis进程每秒能处理的最大请求数目是多少? 答: 能处理的请求数目大概是10W/秒。使用pipeline后,处理请求数目可以达到50W/秒。(具体数值不是我测试的,我谷歌来的) ...

苗永超
2016/04/29
384
7
游戏排行榜算法设计实现比较

  以前在音乐做过一些实时投票,积分排名;单曲、专辑等排行榜;游戏中也有类似的战斗力排行;SNS的游戏又有好友排行等,对于此类的排行算法在此做个总结。   需求背景:   查看前top...

shezjl
2015/10/04
576
1
功能表单之树形选择字段类型的高级使用——JEPLUS软件快速开发平台

JEPLUS功能表单之树形选择字段类型的高级使用 JEPLUS功能表单中树形选择字段类型的目标字段在开发过程中还有一些高级配置和高级应用,如果知晓怎么配置也许能解决我们系统开发过程的大问题,...

JEPLUS
06/13
0
0
Java 程序员必须掌握的 8 道数据结构面试题,你会几道?

瑞士计算机科学家Niklaus Wirth在1976年写了一本书,名为《算法+数据结构=编程》。 40多年后,这个等式仍被奉为真理。这就是为什么在面试过程中,需要考察软件工程师对数据结构的理解。 几乎...

JAVA高级架构开发
10/07
0
0

没有更多内容

加载失败,请刷新页面

加载更多

OSChina 周日乱弹 —— 钱不还,我就当你人不在了

Osc乱弹歌单(2018)请戳(这里) 【今日歌曲】 @莱布妮子 :分享Bigleaf的单曲《小鹿》 《小鹿》- Bigleaf 手机党少年们想听歌,请使劲儿戳(这里) 周日在家做什么? 做手工呀, @poorfis...

小小编辑
今天
24
3
EOS docker开发环境

使用eos docker镜像是部署本地EOS开发环境的最轻松愉快的方法。使用官方提供的eos docker镜像,你可以快速建立一个eos开发环境,可以迅速启动开发节点和钱包服务器、创建账户、编写智能合约....

汇智网教程
今天
19
0
《唐史原来超有趣》的读后感优秀范文3700字

《唐史原来超有趣》的读后感优秀范文3700字: 作者:花若离。我今天分享的内容《唐史原来超有趣》这本书的读后感,我将这本书看了一遍之后就束之高阁了,不过里面的内容一直在在脑海中回放,...

原创小博客
今天
23
0
IC-CAD Methodology知识图谱

CAD (Computer Aided Design),计算机辅助设计,指利用计算机及其图形设备帮助设计人员进行设计工作,这个定义同样可以用来近似描述IC公司CAD工程师这个岗位的工作。 早期IC公司的CAD岗位最初...

李艳青1987
今天
29
0
CompletableFuture get方法一直阻塞或抛出TimeoutException

问题描述 最近刚刚上线的服务突然抛出大量的TimeoutException,查询后发现是使用了CompletableFuture,并且在执行future.get(5, TimeUnit.SECONDS);时抛出了TimeoutException异常,导致接口响...

xiaolyuh
今天
13
0

没有更多内容

加载失败,请刷新页面

加载更多

返回顶部
顶部