如何让Neo4j中执行取消书签查询的事务按顺序执行？

问题本质 #

你的场景中，并发取消收藏请求导致计数错误，核心原因是Neo4j默认的读已提交隔离级别：未提交的事务修改对其他并发事务不可见。第一个事务删除BOOKMARKED_POST关系后，在提交前，第二个事务仍能匹配到该关系，进而重复执行DELETE和计数减1操作，最终出现计数负数或偏差。

有效解决方案 #

1. 用FOR UPDATE强制锁定数据 #

在匹配用户、帖子及收藏关系时添加FOR UPDATE子句，获取排他锁，确保同一时间只有一个事务能修改这些数据。其他事务会等待锁释放，待第一个事务提交后，第二个事务将无法匹配到已删除的关系，自然终止后续操作。

修改后的Cypher查询：

MATCH (user:User { id: $userId })-[bookmarkRel:BOOKMARKED_POST]->(post:Post { id: $postId }) FOR UPDATE
DELETE bookmarkRel
SET post.noOfBookmarks = post.noOfBookmarks - 1,
    user.noOfBookmarks = user.noOfBookmarks - 1
RETURN post { .* }

FOR UPDATE会对匹配到的节点和关系加排他锁，彻底阻断并发事务的可见性问题，确保操作的原子性。

2. 重构计数逻辑（长期最优解） #

放弃在节点上维护noOfBookmarks冗余属性，改为实时统计关系数量：

// 查询用户收藏总数
MATCH (user:User { id: $userId })-[:BOOKMARKED_POST]->()
RETURN count(*) AS noOfBookmarks

// 查询帖子被收藏总数
MATCH (:User)-[:BOOKMARKED_POST]->(post:Post { id: $postId })
RETURN count(*) AS noOfBookmarks

这种方式从根源上消除并发计数错误，因为计数是实时计算的。如果担心性能，可给BOOKMARKED_POST关系创建索引，或定期更新统计节点（需权衡实时性与性能）。

3. APOC幂等性校验（备选方案） #

若环境允许使用APOC扩展，可通过校验关系存在性确保操作幂等，但此方案仍存在极小并发窗口，优先级低于加锁方案：

MATCH (user:User { id: $userId })
MATCH (post:Post { id: $postId })
OPTIONAL MATCH (user)-[bookmarkRel:BOOKMARKED_POST]->(post)
WITH user, post, bookmarkRel
CALL apoc.util.validate(bookmarkRel IS NULL, 'Bookmark does not exist', [])
DELETE bookmarkRel
SET post.noOfBookmarks = post.noOfBookmarks - 1,
    user.noOfBookmarks = user.noOfBookmarks - 1
RETURN post { .* }

为何之前的锁尝试失效？ #

你之前通过设置属性获取写锁未生效，大概率是因为锁操作与后续MATCH关系的操作无原子性关联，或锁的覆盖范围不足。FOR UPDATE直接在匹配目标数据时加锁，确保后续所有操作基于锁定的状态，彻底避免并发可见性问题。

内容的提问来源于stack exchange，提问作者Emmanuel