使用Neo4j进行全栈Web开发_neo4j web_Mlib的博客-程序员秘密

技术标签: web应用  neo4j  Web  数据库  

在开发一个全栈web应用时,作为整个栈的底层,你可以在多种数据库之间进行选择。作为事实的数据源,你当然希望选择一种可靠的数据库,但同时也希望它能够允许你以良好的方式进行数据建模。在本文中,我将为你介绍Neo4j,当你的数据模型包含大量关联数据以及关系时,它可以成为你的web应用栈的基础的一个良好选择。

Neo4j是什么?

图1. Neo4j Web控制台

Neo4j是一个图形数据库,这也就意味着它的数据并非保存在表或集合中,而是保存为节点以及节点之间的关系。在Neo4j中,节点以及关系都能够包含保存值的属性,此外:

  • 可以为节点设置零或多个标签(例如Author或Book)
  • 每个关系都对应一种类型(例如WROTE或FRIEND_OF)
  • 关系总是从一个节点指向另一个节点(但可以在不考虑指向性的情况下进行查询)

为什么要选择Neo4j?

在考虑为web应用选择某个数据库时,我们需要考虑对它有哪些方面的期望,其中最重要的一些条件包括:

  • 它是否易于使用?
  • 它是否允许你方便地回应对需求的变更?
  • 它是否支持高性能查询?
  • 是否能够方便地对其进行数据建模?
  • 它是否支持事务?
  • 它是否支持大规模应用?
  • 它是否足够有趣(很遗憾的是对于数据库的这方面要求经常被忽略)?

从这几个方面来说,Neo4j是一个合适的选择。Neo4j……

  • 自带一套易于学习的查询语言(名为 Cypher
  • 不使用schema,因此可以满足你的任何形式的需求
  • 与关系型数据库相比,对于高度关联的数据(图形数据)的查询快速要快上许多
  • 它的实体与关系结构非常自然地切合人类的直观感受
  • 支持兼容ACID的事务操作
  • 提供了一个高可用性模型,以支持大规模数据量的查询,支持备份、数据局部性以及冗余
  • 提供了一个可视化的查询控制台,你不会对它感到厌倦的

什么时候不应使用Neo4j?

作为一个图形NoSQL数据库,Neo4j提供了大量的功能,但没有什么解决方案是完美的。在以下这些用例中,Neo4j就不是非常适合的选择:

  • 记录大量基于事件的数据(例如日志条目或传感器数据)
  • 对大规模分布式数据进行处理,类似于Hadoop
  • 二进制数据存储
  • 适合于保存在关系型数据库中的结构化数据

在上面的示例中,你看到了由Author、City、Book和Category以及它们之间的关系所组成的一个图形。如果你希望通过Cypher语句在Neo4j web控制台中列出这些数据结果,可以执行以下语句:

MATCH
   (city:City)<-[:LIVES_IN]-(:Author)-[:WROTE]->
   (book:Book)-[:HAS_CATEGORY]->(category:Category)
 WHERE city.name = “ChicagoRETURN *

请注意这种ASCII风格的语法,它在括号内表示节点名称,并用箭头表示一个节点指向另一个节点的关系。Cypher通过这种方式允许你匹配某个指定的子图形模式。

当然,Neo4j的功能不仅仅在于展示漂亮的图片。如果你希望按照作者所处的地点(城市)计算书籍的分类数目,你可以通过使用相同的MATCH模式,返回一组不同的列,例如:

MATCH
   (city:City)<-[:LIVES_IN]-(:Author)-[:WROTE]->
   (book:Book)-[:HAS_CATEGORY]->(category:Category)
 RETURN city.name, category.name, COUNT(book)

执行这条语句将返回以下结果:

city.name category.name COUNT(category)
Chicago Fantasy 1
Chicago Non-Fiction 2

虽然Neo4j也能够处理“大数据”,但它毕竟不是Hadoop、HBase或Cassandra,通常来说不会在Neo4j数据库中直接处理海量数据(以PB为单位)的分析。但如果你乐于提供关于某个实体及其相邻数据关系(比如你可以提供一个web页面或某个API返回其结果),那么它是一种良好的选择。无论是简单的CRUD访问,或是复杂的、深度嵌套的资源视图都能够胜任。

你应该选择哪种技术栈以配合Neo4j?

所有主流的编程语言都通过HTTP API的方式支持Neo4j,或者采用基本的HTTP类库,或是通过某些原生的类库提供更高层的抽象。此外,由于Neo4j是以Java语言编写的,因此所有包含JVM接口的语言都能够充分利用Neo4j中的高性能API。

Neo4j本身也提供了一个“技术栈”,它允许你选择不同的访问方式,包括简单访问乃至原生性能等等。它提供的特性包括:

  • 通过一个HTTP API执行Cypher查询,并获取JSON格式的结果
  • 一种“非托管扩展”机制,允许你为Neo4j数据库编写自己的终结点
  • 通过一个高层Java API指定节点与关系的遍历
  • 通过一个低层的批量加载API处理海量初始数据的获取
  • 通过一个核心Java API直接访问节点与关系,以获得最大的性能

一个应用程序示例

最近我正好有机会将一个项目扩展为基于Neo4j的应用程序。该应用程序(可以访问graphgist.neo4j.com查看)是关于GraphGist的一个门户网站。GraphGist是一种通过交互式地渲染(在你的浏览器中)生成的文档,它基于一个简单的文本文件(AsciiDoctor),其中用文字描述以及图片描述了整个数据模型、架构以及用例查询,可以在线执行它们,并使它们保持可视化。它非常类似一个iPython notebook或是一张交互式的白纸。GraphGist也允许读者在浏览器中编写自己定义的查询,以查看整个数据集。

Neo4j的原作者Neo Technology希望为GraphGist提供一个由社区创建的展示项目。当然,后端技术选用了Neo4j,而整个技术栈的其余部分,我的选择是:

所有代码都已开源,可以在GitHub上任意浏览。

从概念上讲,GraphGist门户网站是一个简单的应用,它提供了一个GraphGist列表,允许用户查看每个GraphGist的详细内容。数据领域是由Gist、Keyword/Domain/Use Case(作为Gist分类)以及Person(作为Gist的作者)所组成的:

现在你已经熟悉这个模型了,在继续深入学习之前,我想为你快速地介绍一下Cypher这门查询语言。举例来说,如果我们需要返回所有的Gist和它们的关键字,可以通过以下语句实现:

MATCH (gist:Gist)-[:HAS_KEYWORD]->(keyword:Keyword)
RETURN gist.title, keyword.name

这段语句将返回一张表,其中的每一行是由每个Gist和Keyword的组合构成的,正如同SQL join的行为一样。现在我们更深入一步,假设我们想要找到某个人所编写的Gist对应的所有Domain,我们可以执行下面这条查询语句:

MATCH (person:Person)-[:WRITER_OF]->(gist:Gist)-[:HAS_DOMAIN]->(domain:Domain)
WHERE person.name = “John DoeRETURN domain.name, COUNT(gist)

该语句将返回另一个结果表,其中的每一行包含Domain的名称,以及这个Person对于这一Domain所编写的全部Gist的数量。这里无需使用GROUP BY语句,因为当我们使用例如COUNT()这样的聚合函数时,Neo4j会自动在RETURN语句中对其它列进行分组操作。

现在你对Cypher已经有一点感觉了吧?那么让我们来看一个来自实际应用中的查询。在创建这个门户时,如果能够通过某种方式,只需对数据库进行一次请求就能够返回我们所需的所有数据,并且以一种我们需要的格式进行结构组织,那将十分有用。

让我们开始创建这个用于门户的API(可以在GitHub上找到)的查询吧。首先,我们需要按照Gist的title属性进行匹配,并匹配所有相关的Gist节点:

// Match Gists based on title
 MATCH (gist:Gist) WHERE gist.title =~ {search_query}
 // Optionally match Gists with the same keyword
 // and pass on these related Gists with the
 // most common keywords first
 OPTIONAL MATCH (gist)-[:HAS_KEYWORD]->(keyword)<-[:HAS_KEYWORD]-(related_gist)

这里有几个要注意的地方。首先,WHERE语句是通过一个正则表达式(即=~操作符)和一个参数对title属性进行匹配的。参数(Parameter)是Neo4j的一项特性,它能够将查询与其所代表的数据进行分离。使用参数能够让Neo4j对查询和查询计划进行缓存,这也意味着你无需担心遭遇查询注入攻击。其次,我们在这里使用了一个OPTIONAL MATCH语句,它表示我们希望始终返回原始的Gist,即使它并没有相关的Gist。

现在让我们对之前的查询进行扩展,将RETURN语句替换为WITH语句:

MATCH (gist:Gist) WHERE gist.title =~ {search_query}
 OPTIONAL MATCH (gist)-[:HAS_KEYWORD]->(keyword)<-[:HAS_KEYWORD]-(related_gist)
 WITH gist, related_gist, COUNT(DISTINCT keyword.name) AS keyword_count
 ORDER BY keyword_count DESC

 RETURN
   gist,
   COLLECT(DISTINCT {related: { id: related_gist.id, title: 
related_gist.title, poster_image: related_gist.poster_image, url: 
related_gist.url }, weight: keyword_count }) AS related

RETURN语句中的COLLECT()作用是将由Gist和相关Gist所组成的节点转换为一个结果集,让其中每一行Gist只出现一次,并对应一个相关Gist的节点数组。在COLLECT()语句中,我们在相关Gist中仅指定了所需的部分数据,以减小整个响应的大小。

最后,我们将产生这样一条查询语句,这也是最后一次使用WITH语句了:

MATCH (gist:Gist) WHERE gist.title =~ {search_query}
 OPTIONAL MATCH (gist)-[:HAS_KEYWORD]->(keyword)<-[:HAS_KEYWORD]-(related_gist)
 WITH gist, related_gist, COUNT(DISTINCT keyword.name) AS keyword_count
 ORDER BY keyword_count DESC

 WITH
   gist,
   COLLECT(DISTINCT {related: { id: related_gist.id, title: related_gist.title, poster_image: related_gist.poster_image, url: related_gist.url }, weight: keyword_count }) AS related

 // Optionally match domains, use cases, writers, and keywords for each Gist
 OPTIONAL MATCH (gist)-[:HAS_DOMAIN]->(domain:Domain)
 OPTIONAL MATCH (gist)-[:HAS_USECASE]->(usecase:UseCase)
 OPTIONAL MATCH (gist)<-[:WRITER_OF]-(writer:Person)
 OPTIONAL MATCH (gist)-[:HAS_KEYWORD]->(keyword:Keyword)

 // Return one Gist per row with arrays of domains, use cases, writers, and keywords
 RETURN
   gist,
   related,
   COLLECT(DISTINCT domain.name) AS domains,
   COLLECT(DISTINCT usecase.name) AS usecases,
   COLLECT(DISTINCT keyword.name) AS keywords
   COLLECT(DISTINCT writer.name) AS writers,
 ORDER BY gist.title

在这个查询中,我们将选择性地匹配所有相关的Domain、Use Case、Keyword和Person节点,并且将它们全部收集起来,与我们对相关Gist的处理方式相同。现在我们的结果不再是平坦的、反正规化的,而是包含一列Gist,其中每个Gist都对应着相关Gist的数组,形成了一种“has many”的关系,并且没有任何重复数据。太酷了!

不仅如此,如果你觉得用表的形式返回数据太老土,那么Cypher也可以返回对象:

RETURN
   {
gist: gist,
    domains: collect(DISTINCT domain.name) AS domains,
    usecases: collect(DISTINCT usecase.name) AS usecases,
    writers: collect(DISTINCT writer.name) AS writers,
    keywords: collect(DISTINCT keyword.name) AS keywords,
    related_gists: related
   }
 ORDER BY gist.title

通常来说,在稍具规模的web应用程序中,需要进行大量的数据库调用以返回HTTP响应所需的数据。虽然你可以并行地执行查询,但通常来说你需要首先返回某个查询的结果集,才能发送另一个数据库请求以获取相关的数据。在SQL中,你可以通过生成复杂的、开销很大的表join语句,通过一个查询从多张表中返回结果。但只要你在同一个查询中进行了多次SQL join,这个查询的复杂性将会飞快地增长。更不用说数据库仍然需要进行表或索引扫描才能够获得相应的数据了。而在Neo4j中,通过关系获取实体的方式是直接使用对应于相关节点的指针,因此服务器可以随意进行遍历。

尽管如此,这种方式也存在着诸多缺陷。虽然这种方式能够通过一个查询返回所有数据,但这个查询会相当长。我至今也没有找到一种方式能够对进行模块化以便重用。进一步考虑:我们可以在其它场合同样调用这个终结点,但让它显示相关Gist的更多信息。我们可以选择修改这个查询以返回更多的数据,但也意味着对于原始的用例来说,它返回了额外的不必要数据。

我们是幸运的,因为有这么多优秀的数据库可以选择。虽然关系型数据库对于保存结构化数据来说依然是最佳的选择,但NoSQL数据库更适合于管理半结构化数据、非结构化数据以及图形数据。如果你的数据模型中包括大量的关联数据,并且希望使用一种直观的、有趣的并且快速的数据库进行开发,那么你就应当尝试一下Neo4j。

本文由Brian Underwood撰写,而Michael Hunger也为本文作出了许多贡献。

关于作者

Brian Underwood是一位软件工程师,喜爱任何与数据相关的东西。作为一名Neo4j 的Developer Advocate,以及neo4j ruby gem的维护者,Brian经常通过一些演讲,以及在他的博客上的文章宣传图形数据库的强大与简洁。Brian如今正与他的妻儿在全球旅行。可以在Twitter 上找到Brian,或在LinkedIn上联系他。

查看英文原文:Full Stack Web Development Using Neo4j

版权声明:本文为博主原创文章,遵循 CC 4.0 BY-SA 版权协议,转载请附上原文出处链接和本声明。
本文链接:https://blog.csdn.net/u010983881/article/details/53106862

智能推荐

OpenCV4每日一练day11:单目位姿估计_单目相机位姿估计_笑鸿的学习笔记的博客-程序员秘密

一.单目位姿估计  根据相机成像模型,如果已知相机的内参矩阵、世界坐标系中若干空间点的三维坐标和空间点在图像中投影的二维坐标,那么可以计算出世界坐标系到相机坐标系的旋转向量和平移向量。如图所示,当知道点ci在世界坐标系下的三维坐标和这些点在图像中对应点的二维坐标时,结合相机的内参矩阵和畸变系数,就可以计算出世界坐标系变换到相机坐标系的旋转向量和平移向量。  在这种情况下,可以估计相机在世界坐标系中的位姿。如果将世界坐标系看成前一时刻的相机坐标系姿态,ci在世界坐标系下的三维坐标看成ci在前一时刻相机坐

c语言函数变量指针定义数组,C语言数组指针指向数组的指针变量—数组名作函数参数.doc..._Victor.ZZ的博客-程序员秘密

C语言数组指针指向数组的指针变量—数组名作函数参数C语言数组指针和指向数组的指针变量—数组名作函数参数数组名可以作函数的实参和形参。如:main(){int array[10];…………f(array,10);…………}f(int arr[],int n);{…………}array为实参数组名,arr为形参数组名。在学习指针变量之后就更容易理解这个问题了。数组名就是数组的首地址,实参向形参传送数组名...

apollo配置中心的组件_如何使用Apollo的全新查询组件来管理本地状态_cumian8165的博客-程序员秘密

apollo配置中心的组件Note: This article deals with utilizing Apollo’s brand new Query and Mutation components, instead of the HOCs. For those that have read the original article here, be aware that the two ar...

Java 实现模板方法(TemplateMethod)模式_匆忙拥挤repeat的博客-程序员秘密

类图/** * 业务流程模板,提供基本框架 * @author stone * */public abstract class BaseTemplate { public abstract void part1(); public abstract void part2(); public abstract void part3(); //这里为了严格实验结

Java多线程学习之路(1) -- 内存可见性_weixin_30907935的博客-程序员秘密

什么叫内存可见性: 一个线程对共享变量值的修改,能够及时的被其他线程看到。什么又叫共享变量: 如果一个变量在多个线程的工作内存中都存在副本,那么这个变量就是这几个线程的共享变量在Java中,所有实例域、静态域和数组元素都存储在堆内存中,堆内存在线程之间共享。 局部变量(Local Variables),方法定义参数和异常处理器参数(不会在线...

Tomcat :“localhost:8080”报错401:Unauthorized_get http://localhost:8080/user/getinfo 401 (unauth_韩小兔修媛史的博客-程序员秘密

总结一下第一次遇到的Unauthorized:401错误,其实呢很简单的一个错:运行tomcat的时候,当我输入localhost:8080时,弹出一个提示框:需要用户名密码登录,也就是没有访问权限,点击取消时:报错401:Unauthorized分析任何客户端 ( 例如您的浏览器) ,都需要通过以下循环:从站点的 IP 名称 ( 即您站点的网址-URL, 不带起始的 ‘http://’) 获得一个 IP 地址。这个对应关系 ( 即由 IP 名称向 IP 地址转换的对应关系 ) 由域名服务器 (

随便推点

sum函数的用法(matlab)_sum(x,1)_夜歌乘年少丶的博客-程序员秘密

摘自matlabsum Sum of elements.S = sum(X) is the sum of the elements of the vector X. If X is a matrix,S is a row vector with the sum over each column. For N-D arrays,sum(X) operates along the first ...

CUDA 编程 之 CUDA-MEMCHECK 工具 简介_cuda memcheck___DARK__的博客-程序员秘密

CUDA-MEMCHECK1.IntroductionCUDA-MEMCHECK是一个在CUDA toolkit 中的功能性的正确性检查组件。**这个**suite有4个工具 :memcheckThe memcheck tool is capable of precisely detecting and attributing out of bounds and misaligned memory

java base64 图片_java base64 图片_花旗甲比丹的博客-程序员秘密

package com.xx.xx.xx;import org.apache.commons.io.FileUtils;import org.apache.commons.io.IOUtils;import sun.misc.BASE64Decoder;import sun.misc.BASE64Encoder;import java.io.File;import java.io.FileInpu...

匈牙利算法_weixin_30437481的博客-程序员秘密

简单地说,就是一张图里的所有点可以分为两组(如上图),并且每条边都跨越两组。这样的图就是二分图。一个图为二分图仅当:没有奇数圈;点色数为 2。交替路(也叫交错路):从一个未匹配点出发,依次经过非匹配边、匹配边、非匹配边……形成的路径叫交替路。增广路:从一个未匹配点出发,走交替路,以另一个未匹配点为结尾(出发的点不算),则这条交替路称为增广路增广路定理:任意一个非最大匹配的...

wireshark之显示过滤_过滤出抓取的数据包是什么意思_ChuMeng19990324的博客-程序员秘密

目录预备知识实验目的实验环境实验步骤一实验步骤二实验步骤三预备知识本实验在完成实验《wireshark之文件还原》后进行,该实验涉及了wireshark的基本操作,里面涉及了较为基础的数据包显示过滤语句。Wireshark本质上是对网络数据流的记录,因此,您在实验前,最好对常见的网络协议有一定的了解。如果您不是很了解也没关系,我们会在实验中有较为基础的讲解。Wireshark过滤器表达式的比较操作符:wireshark过滤器表达式的逻辑操作符:实验目的1.掌握常见的包显示过滤语句。2.会

error C2440: “static_cast”: 无法从“void (__thiscall ClientDlg::* )_choutangu6494的博客-程序员秘密

解决方法如下: 首先,把原来的消息函数返回值类型改为LRESULT,函数内可以随便写个return TRUE; 然后消息函数的参数必须改写成(WPARAM wParam,LPARAM lParam)而不论这两个参数是否用得到;最后,消息映射如ON_MESSAGE(WM_message,&am...

推荐文章

热门文章

相关标签