节点 GeoFire 内存泄漏?
Node GeoFire memory leak?
我在 Node 上似乎有一些非常基本的 firebase + firebase-queue + GeoFire 代码 运行,这似乎会导致内存泄漏,但我不相信我没有搞砸某处有东西。
'use strict';
if (!process.env.FIREBASE_PROJECT_ID) {
require('dotenv').config({ silent: true });
}
let fbConfig = require('./firebase-config');
let fbNodes = fbConfig.NODES;
let Queue = require('firebase-queue');
let admin = require("firebase-admin");
let GeoFire = require('geofire');
admin.initializeApp({
credential: admin.credential.cert(fbConfig.FIREBASE_SERVICE_ACCOUNT),
databaseURL: fbConfig.APP_SETTINGS.databaseURL
});
let db = admin.database();
let queueRef = db.ref(fbNodes.QUEUE);
let geoFire = new GeoFire(db.ref(fbNodes.GEOFIRE));
var q = new Queue(queueRef, function (data, progress, resolve, reject) {
let geoQuery = geoFire.query({
center: data.queryCenter,
radius: data.maxDistanceKm
});
// fires for every key returned by the geoQuery
let listener = geoQuery.on('key_entered', function (key, loc, dist) {
// do nothing
});
// This will fire once the initial data is loaded, so now we can cancel
// the "key_entered" event listener
geoQuery.on('ready', function () {
listener.cancel();
resolve();
});
});
这是内存使用情况的内存消耗图表,显示此代码在大约 10 分钟后吞噬了 1.5 GB 的内存,并解决了 1100 个任务,直到崩溃。
知道这里发生了什么吗?
这是 运行 时间:
- 节点 6.7.0
- firebase-admin 4.0.4
- firebase-queue 1.6.1
- geofire 4.1.1
泄漏是由 GeoFire 查询引起的。每次处理队列中的任务时,都会创建一个查询,但这些查询永远不会被取消 - 只有它们的侦听器才会被取消。
要堵住漏洞,完成后对查询调用 cancel
。例如:
geoQuery.on('ready', function () {
listener.cancel();
geoQuery.cancel();
resolve();
});
我在 Node 上似乎有一些非常基本的 firebase + firebase-queue + GeoFire 代码 运行,这似乎会导致内存泄漏,但我不相信我没有搞砸某处有东西。
'use strict';
if (!process.env.FIREBASE_PROJECT_ID) {
require('dotenv').config({ silent: true });
}
let fbConfig = require('./firebase-config');
let fbNodes = fbConfig.NODES;
let Queue = require('firebase-queue');
let admin = require("firebase-admin");
let GeoFire = require('geofire');
admin.initializeApp({
credential: admin.credential.cert(fbConfig.FIREBASE_SERVICE_ACCOUNT),
databaseURL: fbConfig.APP_SETTINGS.databaseURL
});
let db = admin.database();
let queueRef = db.ref(fbNodes.QUEUE);
let geoFire = new GeoFire(db.ref(fbNodes.GEOFIRE));
var q = new Queue(queueRef, function (data, progress, resolve, reject) {
let geoQuery = geoFire.query({
center: data.queryCenter,
radius: data.maxDistanceKm
});
// fires for every key returned by the geoQuery
let listener = geoQuery.on('key_entered', function (key, loc, dist) {
// do nothing
});
// This will fire once the initial data is loaded, so now we can cancel
// the "key_entered" event listener
geoQuery.on('ready', function () {
listener.cancel();
resolve();
});
});
这是内存使用情况的内存消耗图表,显示此代码在大约 10 分钟后吞噬了 1.5 GB 的内存,并解决了 1100 个任务,直到崩溃。
知道这里发生了什么吗?
这是 运行 时间:
- 节点 6.7.0
- firebase-admin 4.0.4
- firebase-queue 1.6.1
- geofire 4.1.1
泄漏是由 GeoFire 查询引起的。每次处理队列中的任务时,都会创建一个查询,但这些查询永远不会被取消 - 只有它们的侦听器才会被取消。
要堵住漏洞,完成后对查询调用 cancel
。例如:
geoQuery.on('ready', function () {
listener.cancel();
geoQuery.cancel();
resolve();
});