java - Neo4j 插件中 GraphDatabaseService 的使用

Question

我有一个要求:

1. 跟踪 neo4j 更改并对更改的数据执行异步操作。
2. 将异步过程的结果存储回单独节点中的 Neo。

对于第 1 步，我实现了 TransactionEventHandler 并将其在服务器插件中注册为

public class MyPlugin  extends ServerPlugin{

@Name( "track_change" )
@Description( "Track Neo4j changes")
@PluginTarget( GraphDatabaseService.class )
public void registerEventHandler( @Source GraphDatabaseService graphDb ){       
    graphDb.registerTransactionEventHandler(new MyTransactionEventHandler());
}       
}

这工作得很好。现在，对于步骤 2，我想在 MyTransactionEventHandler 中编写嵌入代码:

private void saveStatus(String status) {

    Transaction tx = graphDb.beginTx();
    try
    {           
        Label label = DynamicLabel.label("Status");
        Node requestNode = graphDb.createNode(label);
        requestNode.setProperty(STATUS, status);                
        tx.success();           
    }catch(Exception e){
        tx.failure();
        logger.severe(e.getMessage());
    }finally{
        tx.close();
    }
    }

为此，我需要在处理程序中使用 GraphDatabaseService 的实例。因此，我应该使用 GraphDatabaseFactory 创建一个新的嵌入式实例，还是通过将其传递给处理程序来使用插件中的实例。 Neo4j 文档指出:

The GraphDatabaseService instance can be shared among multiple threads. Note however that you can’t create multiple instances pointing to the same database.

我尝试通过将插件传递给 MyTransactionEventHandler 的构造函数来使用插件中的一个，但有时这会导致创建节点时出错。

java.lang.IllegalStateException: This transaction has already been completed.

这被理解为异步操作可能需要更长的时间。那么在这种情况下创建 GraphDatabaseService 的另一个实例是否可以？如果没有，那么推荐的方法是什么。

感谢任何帮助。

Answer 1

异常到底出现在哪个 tx-event-handler 方法中？请分享完整的方法/代码。而且你的 tx 上没有 close() 。

此外，您应该在生命周期中注册 tx 处理程序，而不是在 http 方法调用中。

您不会创建 GraphDatabaseService 的新实例，它只是传递给您。