java neo4j 查询后进程不会停止

java process won't stop after neo4j query

我正在使用来自 neo4j OGM 的 ConfigrationSourceSessionFactory 连接到远程 neo4j 数据库,如下所示:

private final static ConfigurationSource props = new ClasspathConfigurationSource("neo4j-connection.properties");
    private final static Configuration configuration = new Configuration.Builder(props).build();
    private final static SessionFactory sessionFactory = new SessionFactory(configuration, "domain");

然后我 运行 一个密码查询并取回映射到带有 OGM 注释的 neo4j 节点的 POJO 的 Iterable

private final LinkedBlockingQueue<Session> sessionPool = new LinkedBlockingQueue<>(8192);
@Override
    public Iterable<Location> findAll() {
        try {
            return session.loadAll(Location.class, 1);
        } finally {
            closeSession(session);
        }
    }
private void closeSession(Session session) {
        if (session != null) {
            try {
                sessionPool.offer(session, 100, TimeUnit.MILLISECONDS);
            } catch (Throwable e) {
                e.printStackTrace();
            }
        }
    }

一切正常,在我的主要方法中,我使用 neo4j 值创建了我的 POJO 对象

public static void main(String[] args) {
        LocationServiceImpl locationService = new LocationServiceImpl();
        Iterable<Location> locations = locationService.findAll();
        for(Location location : locations) {
            System.out.println(location.getSubType());//eg. prints Floor, Building etc
        }
        System.out.println("End");
    }

但在 main 方法完成后,应用程序不会停止。上面的“结束”字符串正在打印。所以有些线程挂在某处,我不知道在哪里以及为什么。

我尝试关闭 neo4j ogm 会话,但没有成功。

我的 neo4j ogm pom 依赖关系

 <dependency>
            <groupId>org.neo4j</groupId>
            <artifactId>neo4j-ogm-bolt-driver</artifactId>
            <version>3.1.2</version>
            <scope>runtime</scope>
        </dependency>
 <dependency>
            <groupId>org.neo4j</groupId>
            <artifactId>neo4j-jdbc-driver</artifactId>
            <version>3.4.0</version>
        </dependency>
<dependency>
            <groupId>org.neo4j</groupId>
            <artifactId>neo4j-ogm-core</artifactId>
            <version>3.1.3</version>
        </dependency>

从可视虚拟机打印屏幕

您还必须关闭 SessionFactory

一些背景知识:我假设您正在使用 Bolt 协议进行连接。创建 SessionFactory 的实例还将创建一个 java (bolt) 驱动程序实例及其所有连接池等。要有一个干净的关闭调用 sessionFactory.close() 也将关闭/关闭驱动程序。