我使用php和cassandra构建了一个事件api。
最近,我编写了一个node.js+helenus来替换相同的api。完成后,我开始使用ab工具对node.js代码进行基准测试。但是,在cassandra上插入1000+后,连接可能会丢失,故障转移代码也会运行。在每次请求发生后,我都会向cassandra插入async。
当节点应用程序启动时,我正在实例化ConnectionPool
对象。但是,我在每个请求中都使用pool.connect()
函数。
pool.connect()
是从ConnectionPool
对象启动新连接还是绑定现有连接?
注:
在phpcassa中,我没有遇到这样的问题,可能是因为我正在插入到cassandra sync。
我使用5个cassandra节点
是的,pool.connect()
每次被调用时都会创建一个到池的新连接,因此您通常只需要在应用程序启动时调用它一次,并将该连接传递给任何需要它的模块或方法。
我通常用一个模块来做这个
module.exports = function(app, cb) {
var domain = require('domain'),
d = domain.create(),
helenus = require('helenus'),
d.run(function() {
var pool = new helenus.ConnectionPool({
hosts : ['localhost:9160'],
user : "",
password : "",
keyspace : 'something',
cqlVersion : '3.0.0'
});
pool.connect(function(err, keyspace){
if(err){
cb(err, null);
} else {
cb(null, pool);
}
});
pool.on('error', function(err) {
cb(err, null);
});
});
d.on('error', function(err) {
console.log('error', err.stack);
cb(err, null);
});
}
并称之为我的应用程序,类似于这样(真正简化的)
var express = require('express');
var app = this.express();
var database = require('db');
database(app, function(err, conn) {
if (err==null) {
// connected, do stuff
conn.cql("SELECT * FROM table WHERE KEY = ?", [what], function(err, result) {
if (err==null) {
// get result
}
});
}
});
我已经将其用于数百万条记录、连续插入和大量查找,没有任何问题,Cassandra对我来说比我尝试过的任何其他DB都要好。