使用 Neo4j 查找或创建与多线程

Question

在我的基于 Neo4j 的应用程序中，我有一个经典的查找或创建用例：我询问 neo4j 是否已经存在与其他节点具有特殊关系的节点。如果没有，那么我将在同一事务中创建一个。没什么特别的...但是如果我将此方法称为多线程（或连接到同一个数据库的 n 个客户端），那么有时我会遇到一个异常，指出有多个元素与我的查询匹配。这意味着在不久之前有两个线程都创建了相同的“对”节点。 Java 级别的同步不是一种选择（因为请求可以来自多个客户端/服务器）。

除了捕获异常并删除重复的节点之外，我该如何解决这些问题？

我使用 Spring Data Neo4j 2.3.3 和 Neo4j 1.9.5。

这是我的查询：

START expected=node({0}), actual=node({1}) MATCH (expected)<-[:EXPECTED]- (pair) -[:ACTUAL]->(actual) RETURN pair

顺便说一句。在这种情况下抛出的异常是NoSuchElementException，至少对我来说这有点令人困惑。

WARN  [00:32.31,962] de.xxx.web.AbstractExceptionHandlers: error.NoSuchElementException
java.util.NoSuchElementException: More than one element in org.neo4j.cypher.PipeExecutionResult$$anon$1@8f0dc23. First element is '{pair=Node[20001]}' and the second element is '{pair=Node[20000]}'
    at org.neo4j.helpers.collection.IteratorUtil.singleOrNull(IteratorUtil.java:122)
    at org.neo4j.helpers.collection.IteratorUtil.singleOrNull(IteratorUtil.java:289)
    at org.springframework.data.neo4j.conversion.QueryResultBuilder$1.singleOrNull(QueryResultBuilder.java:94)
    at org.springframework.data.neo4j.repository.query.GraphRepositoryQuery.dispatchQuery(GraphRepositoryQuery.java:108)
    at org.springframework.data.neo4j.repository.query.GraphRepositoryQuery.execute(GraphRepositoryQuery.java:81)
    at org.springframework.data.repository.core.support.RepositoryFactorySupport$QueryExecutorMethodInterceptor.invoke(RepositoryFactorySupport.java:337)
    at org.springframework.aop.framework.ReflectiveMethodvocation.proceed(ReflectiveMethodvocation.java:172)
    at org.springframework.transaction.interceptor.TransactionInterceptor$1.proceedWithvocation(TransactionInterceptor.java:96)
    at org.springframework.transaction.interceptor.TransactionAspectSupport.invokeWithinTransaction(TransactionAspectSupport.java:260)
    at org.springframework.transaction.interceptor.TransactionInterceptor.invoke(TransactionInterceptor.java:94)
    at org.springframework.aop.framework.ReflectiveMethodvocation.proceed(ReflectiveMethodvocation.java:172)
    at org.springframework.dao.support.PersistenceExceptionTranslationInterceptor.invoke(PersistenceExceptionTranslationInterceptor.java:155)
    at org.springframework.aop.framework.ReflectiveMethodvocation.proceed(ReflectiveMethodvocation.java:172)
    at org.springframework.aop.framework.JdkDynamicAopProxy.invoke(JdkDynamicAopProxy.java:204)
    at com.sun.proxy.$Proxy63.findByAttributes(Unknown Source)
    at de.xxx.core_service.attribute.AttributeManagerImpl.findOrCreatePair_aroundBody32(AttributeManagerImpl.java:212)
    at de.xxx.core_service.attribute.AttributeManagerImpl$AjcClosure33.run(AttributeManagerImpl.java:1)

Answer 1

您必须为此手动锁定，否则您会进入典型的竞争条件。

锁定有问题的两个节点可能最简单。

Neo4j Transaction 上有一个锁管理 API，但您也可以只删除一个不存在的属性，该属性也需要一个写锁。

我们可能不得不在某个时候公开 SDN 中的锁定。 如果您认为这是个好主意，请提出 JIRA 问题。