一种基于Spark和Ignite的分布式实时图构建和查询的方法及系统

摘要

本发明涉及一种基于Spark和Ignite的分布式实时图构建和查询的方法及系统，其中的方法包括：启动Spark实时图构建和图查询任务，从数据库加载待查询图的点和边的字段到Ignite的数据集中，对所述字段进行缓存，并为所述字段创建索引；将前端发起的请求中的请求参数使用加密算法生成对应的请求参数主题，并监听所述请求参数主题；将所述请求参数主题放入所述请求参数，发送给请求主题，并监听所述请求主题；获取数据进行计算，将计算结果发送给所述请求参数主题；将获取到的结果数据返回给前端。本发明借助Spark和Ignite的分布式图构建和存储功能，可以对亿级甚至百亿级的数据实时进行图构建和图查询，可以有效的缩短图查询的时间。