现在我正在执行writeTransactions按照文档的建议关闭 neo4j 驱动程序 session 。
但是,我还没有找到发生错误时如何处理session.close()
。这可能会导致池的所有连接永远不会关闭,并且在应用程序启动几天后我收到很多这样的错误:
(node:1) UnhandledPromiseRejectionWarning:
Unhandled promise rejection (rejection id: 5725):
Neo4jError: Connection acquisition timed out in 60000 ms.
这是驱动程序配置:
const driver = neo4j.driver(
process.env.NEO4J_URI,
neo4j.auth.basic(process.env.NEO4J_USER, process.env.NEO4J_PASSWORD),
{
maxConnectionLifetime: 60 * 60 * 1000, // 1 hour
maxConnectionPoolSize: 300,
encrypted: "ENCRYPTION_ON",
trust: "TRUST_CUSTOM_CA_SIGNED_CERTIFICATES",
trustedCertificates: [process.env.NEO4J_TRUSTED_CERTS],
logging: {
level: 'debug',
logger: (level, message) => console.log('+++' + level + ' ' + message)
}
}
);
以下是我使用驱动程序进行事务处理的两种方式:
<强>1。使用 async/await 和 catch
const neo4jsession = driver.session();
var result = await neo4jsession.writeTransaction(tx =>
tx.run("Cypher Query")
).catch(err => {
try {
neo4jsession.close();
} finally {
reject(err);
}
});
neo4jsession.close();
// Do something with result if not undefined
<强>2。使用 then/catch
const neo4jsession = driver.session();
var result = neo4jsession.writeTransaction(tx =>
tx.run("Cypher Query")
);
result.then(items => {
neo4jsession.close();
// do something with items
}).catch(error => {
try {
neo4jsession.close();
} finally {
reject(error);
}
});
在这两种情况下我是否正确关闭了 session ?如果不是,那么在这两种情况下关闭 session 的正确方法是什么?
请帮忙,这几天一直很头痛=(
最佳答案
对于您的第一个案例,您可以做一些更简单的事情:
const neo4jsession = driver.session();
try {
let result = await neo4jsession.writeTransaction(tx => tx.run("Cypher Query") )
}
catch( err } {
reject(err);
}
finally {
neo4jsession.close();
}
您可以对第二种情况使用相同的模式。
关于javascript - 使用 neo4j-javascript-driver 关闭 session 的正确方法是什么?,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/55372212/