neo4j-jdbc 驱动程序 3.x 线程安全吗

Question

我正在运行一个安装程序，我使用 jdbc API 安装 neo4j-jdbc 驱动程序来连接到 VM 中的 neo4j 数据库，并且在执行一些多线程工作时遇到了死锁问题。我想知道是否有人知道neo4j-jdbc 驱动程序3.x 是否是线程安全的？

错误日志

Exception: java.sql.BatchUpdateException: org.neo4j.driver.v1.exceptions.TransientException: LockClient[4211] can't wait on resource RWLock[NODE(2410), hash=1674994875] since => LockClient[4211] <-[:HELD_BY]- RWLock[NODE(2403), hash=1544505462] <-[:WAITING_FOR]- LockClient[4205] <-[:HELD_BY]- RWLock[NODE(2410), hash=1674994875]
org.neo4j.jdbc.bolt.BoltPreparedStatement.executeBatch(BoltPreparedStatement.java:178)
org.apache.commons.dbcp2.DelegatingStatement.executeBatch(DelegatingStatement.java:345)
org.apache.commons.dbcp2.DelegatingStatement.executeBatch(DelegatingStatement.java:345)
org.apache.beam.sdk.io.jdbc.JdbcIO$Write$WriteFn.finishBundle(JdbcIO.java:480)
Caused By: org.neo4j.driver.v1.exceptions.TransientException: LockClient[4211] can't wait on resource RWLock[NODE(2410), hash=1674994875] since => LockClient[4211] <-[:HELD_BY]- RWLock[NODE(2403), hash=1544505462] <-[:WAITING_FOR]- LockClient[4205] <-[:HELD_BY]- RWLock[NODE(2410), hash=1674994875]
org.neo4j.driver.internal.connector.socket.SocketResponseHandler.handleFailureMessage(SocketResponseHandler.java:71)
org.neo4j.driver.internal.messaging.PackStreamMessageFormatV1$Reader.unpackFailureMessage(PackStreamMessageFormatV1.java:464)
org.neo4j.driver.internal.messaging.PackStreamMessageFormatV1$Reader.read(PackStreamMessageFormatV1.java:425)
org.neo4j.driver.internal.connector.socket.SocketClient.receiveOne(SocketClient.java:130)
org.neo4j.driver.internal.connector.socket.SocketConnection.receiveOne(SocketConnection.java:143)
Stack trace truncated. Please see Cloud Logging for the entire trace.

Answer 1

死锁是存在并发请求时“正常”neo4j 行为的结果。你应该知道 neo4j 的 default locking behavior 和 documentation on deadlocks。

这可能是最有帮助的段落：

遇到频繁的死锁表明并发写入 请求以无法执行的方式发生 他们同时实现了预期的隔离和 一致性。解决方案是确保并发更新发生在 一种合理的方式。例如，给定两个特定节点（A 和 B）， 以随机顺序添加或删除这两个节点的关系 对于每个事务，当有两个或 更多交易同时进行。一种解决方案是使 确保更新总是以相同的顺序发生（先 A，然后 B）。 另一种解决方案是确保每个线程/事务不 与其他节点或关系有任何冲突的写入 并发事务。例如，这可以通过让一个 单个线程执行特定类型的所有更新。