取消事务时Neo4j抛出ProtocolException的原因与解决方法

你遇到的ProtocolException本质是竞态条件引发的会话状态冲突：

• ExecuteReadAsync是Neo4j Driver封装的事务管理方法，它会自动处理事务生命周期：回调任务正常完成时自动提交读事务；任务抛出异常（包括取消异常）时，自动回滚事务并将会话置为READY状态。
• 你在Async.OnCancel中手动调用session.CloseAsync()，该操作会尝试回滚会话的活跃事务，但存在两种冲突场景：
  1. 事务已被ExecuteReadAsync的内置逻辑完成（提交/回滚），会话回到READY状态，此时手动触发的回滚找不到活跃事务，抛出异常。
  2. session.CloseAsync与ExecuteReadAsync的事务管理逻辑同时操作会话状态，导致状态判断矛盾。
• 另外use session会在async块结束时自动调用Dispose（内部执行CloseAsync），手动提前关闭属于重复操作，进一步加剧了状态冲突概率。

核心思路是依赖Neo4j Driver的内置事务与会话管理逻辑，避免手动干预会话状态，具体修改如下：

1. 移除手动关闭会话的取消逻辑 #

删除use! holder = Async.OnCancel(fun () -> session.CloseAsync() |> ignore)这一行，原因：

• use session会在async块执行完毕（正常完成、取消或异常）时自动释放会话，调用CloseAsync。
• ExecuteReadAsync会在回调任务取消时自动回滚事务并清理会话状态。

2. 确保取消令牌传递到所有可取消操作 #

检查Neo4j Driver版本，若tx.RunAsync支持带CancellationToken的重载，将令牌传递过去，让取消信号直达查询执行底层：

let! runResult = tx.RunAsync(ReadQuery.value query, queryParams, token)

（若Driver版本无此重载，仅保留ToListAsync(token)的取消逻辑即可）

3. 新增取消异常处理（可选） #

在catch块中捕获OperationCanceledException，转换为自定义错误类型，让上层逻辑更清晰：

修改后的完整readData函数 #

let readData
    (timezone : Timezone)
    idriver
    typeConversions
    (query:ReadQuery)
    (queryParams: QueryParams)
    : Async<Result<seq<Val list>, GraphError>> =
    asyncResult
        {
            use session = getSession AccessMode.Read idriver

            let! token = Async.CancellationToken

            return!
                session.ExecuteReadAsync<Result<Val list seq, GraphError>>(fun tx ->
                    task {
                        try
                            let resultProcessF = asTypes (Timezone.value timezone) typeConversions
                            // 传递令牌给RunAsync（若Driver支持）
                            let! runResult = tx.RunAsync(ReadQuery.value query, queryParams, token)
                            let! results = runResult.ToListAsync(token)
                            let resultsSeq = results |> Seq.map resultProcessF
                            return Ok resultsSeq
                        with
                        | :? OperationCanceledException ->
                            return Error (GraphError.QueryCanceled "Query was canceled by user request")
                        | ex ->
                            return
                                Error (GraphError.ReadError
                                    {
                                        Error = sprintf "Failed to run read data with query: %s" (ReadQuery.value query)
                                        ErrorDetails = ex.Message
                                    })
                    })
        }

• 升级到最新版Neo4j Driver，新版本在事务取消和会话状态管理上有更完善的处理，能减少此类竞态问题。
• 对于重复请求的取消管理，建议在API层（如ASP.NET Core请求管道）直接使用框架提供的CancellationToken，而非手动维护CancellationTokenSource，更自然地关联请求生命周期与取消信号。

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