From a71339483f29cee28f3462d289e448da4c907c28 Mon Sep 17 00:00:00 2001
From: Cherokee <successage@gmail.com>
Date: Tue, 3 Jun 2014 16:28:51 +0800
Subject: [PATCH] =?UTF-8?q?=E4=BF=AE=E5=A4=8D=E5=A4=9A=E4=B8=AA=E8=BF=9E?=
 =?UTF-8?q?=E6=8E=A5=E4=B8=8B=E7=9A=84=E9=97=AE=E9=A2=98?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

上一版本的代码不支持同时连接多个ssdb，原因是因为net连接的部分作为一个module的普通方法，被进程中的其他js共用了，因此申明多个连接时前面的net连接会被后面的覆盖。

解决：
参照redis nodejs client，将net连接及监听的代码独立出来，每次connect的时候new 一个实例，同时支持多个连接，直接在SSDB.js上修改，调用方式不变。
---
 SSDB.js | 882 ++++++++++++++++++++++++++++----------------------------
 1 file changed, 443 insertions(+), 439 deletions(-)

diff --git a/SSDB.js b/SSDB.js
index 2280ae0..e0330b5 100644
--- a/SSDB.js
+++ b/SSDB.js
@@ -11,447 +11,451 @@ var net = require('net');
 
 // timeout: microseconds, if ommitted, it will be treated as listener
 // callback(err, ssdb)
+
+var SSDBConnect = function(host, port, timeout, listener){
+    var self = this;
+    var recv_buf = new Buffer(0);
+    var callbacks = [];
+    var connected = false;
+
+    if(typeof(timeout) == 'function'){
+        listener = timeout;
+        timeout = 0;
+    }
+    listener = listener || function(){};
+
+    var sock = new net.Socket();
+    sock.on('error', function(e){
+        if(!connected){
+            listener('connect_failed', e);
+        }else{
+            var callback = callbacks.shift();
+            if(callback)callback(['error']);
+        }
+    });
+    sock.connect(port, host, function(){
+        connected = true;
+        sock.setNoDelay(true);
+        sock.setKeepAlive(true);
+        sock.setTimeout(timeout);
+        listener(0, self);
+    });
+
+    self.close = function(){
+        sock.end();
+    }
+
+    self.request = function(cmd, params, callback){
+        var arr = [cmd].concat(params);
+        self.send_request(arr);
+        callbacks.push(callback || function(){});
+    }
+
+    function build_buffer(arr){
+        var bs = [];
+        var size = 0;
+        for(var i = 0; i < arr.length; i++){
+            var arg = arr[i];
+            if(arg instanceof Buffer){
+                //
+            }else{
+                arg = new Buffer(arg.toString());
+            }
+            bs.push(arg);
+            size += arg.length;
+        }
+        var ret = new Buffer(size);
+        var offset = 0;
+        for(var i=0; i<bs.length; i++){
+            bs[i].copy(ret, offset);
+            offset += bs[i].length;
+        }
+        return ret;
+    }
+
+    self.send_request = function(params){
+        var bs = [];
+        for(var i=0;i<params.length;i++){
+            var p = params[i];
+            var len = 0;
+            if(!(p instanceof Buffer)){
+                p = p.toString();
+                bs.push(Buffer.byteLength(p));
+            }else{
+                bs.push(p.length);
+            }
+            bs.push('\n');
+            bs.push(p);
+            bs.push('\n');
+        }
+        bs.push('\n');
+        var req = build_buffer(bs);
+        sock.write(req);
+        //console.log('write ' + req.length + ' bytes');
+        //console.log('write: ' + req);
+    }
+
+    sock.on('data', function(data){
+        recv_buf = build_buffer([recv_buf, data]);
+        while(recv_buf.length > 0){
+            var resp = parse();
+            if(!resp){
+                break;
+            }
+            resp[0] = resp[0].toString();
+            var callback = callbacks.shift();
+            callback(resp);
+        }
+    });
+
+    function memchr(buf, ch, start){
+        start = start || 0;
+        ch = typeof(ch) == 'string'? ch.charCodeAt(0) : ch;
+        for(var i=start; i<buf.length; i++){
+            if(buf[i] == ch){
+                return i;
+            }
+        }
+        return -1;
+    }
+
+    function parse(){
+        var ret = [];
+        var spos = 0;
+        var pos;
+        //console.log('parse: ' + recv_buf.length + ' bytes');
+        while(true){
+            //pos = recv_buf.indexOf('\n', spos);
+            pos = memchr(recv_buf, '\n', spos);
+            if(pos == -1){
+                // not finished
+                return null;
+            }
+            var line = recv_buf.slice(spos, pos).toString();
+            spos = pos + 1;
+            line = line.replace(/^\s+(.*)\s+$/, '\1');
+            if(line.length == 0){
+                // parse end
+                //recv_buf = recv_buf.substr(spos);
+                recv_buf = recv_buf.slice(spos);
+                break;
+            }
+            var len = parseInt(line);
+            if(isNaN(len)){
+                // error
+                console.log('error 1');
+                return null;
+            }
+            if(spos + len > recv_buf.length){
+                // not finished
+                //console.log(spos + len, recv_buf.length);
+                //console.log('not finish');
+                return null;
+            }
+            //var data = recv_buf.substr(spos, len);
+            var data = recv_buf.slice(spos, spos + len);
+            spos += len;
+            ret.push(data);
+
+            //pos = recv_buf.indexOf('\n', spos);
+            pos = memchr(recv_buf, '\n', spos);
+            if(pos == -1){
+                // not finished
+                console.log('error 3');
+                return null;
+            }
+            // '\n', or '\r\n'
+            //if(recv_buf.charAt(spos) != '\n' && recv_buf.charAt(spos) != '\r' && recv_buf.charAt(spos+1) != '\n'){
+            var cr = '\r'.charCodeAt(0);
+            var lf = '\n'.charCodeAt(0);
+            if(recv_buf[spos] != lf && recv_buf[spos] != cr && recv_buf[spos+1] != lf){
+                // error
+                console.log('error 4 ' + recv_buf[spos]);
+                return null;
+            }
+            spos = pos + 1;
+        }
+        return ret;
+    }
+
+    // callback(err, val);
+    // err: 0 on sucess, or error_code(string) on error
+    self.get = function(key, callback){
+        self.request('get', [key], function(resp){
+            if(callback){
+                var err = resp[0] == 'ok'? 0 : resp[0];
+                var val = resp[1];
+                callback(err, val);
+            }
+        });
+    }
+
+    // callback(err);
+    self.set = function(key, val, callback){
+        self.request('set', [key, val], function(resp){
+            if(callback){
+                var err = resp[0] == 'ok'? 0 : resp[0];
+                callback(err);
+            }
+        });
+    }
+
+    // callback(err);
+    self.del = function(key, callback){
+        self.request('del', [key], function(resp){
+            if(callback){
+                var err = resp[0] == 'ok'? 0 : resp[0];
+                callback(err);
+            }
+        });
+    }
+
+    // callback(err, {index:[], items:{key:score}})
+    self.scan = function(key_start, key_end, limit, callback){
+        self.request('scan', [key_start, key_end, limit], function(resp){
+            if(callback){
+                var err = resp[0] == 'ok'? 0 : resp[0];
+                if(resp.length % 2 != 1){
+                    callback('error');
+                }else{
+                    var data = {index: [], items: {}};
+                    for(var i=1; i<resp.length; i+=2){
+                        var k = resp[i].toString();
+                        var v = resp[i+1].toString();
+                        data.index.push(k);
+                        data.items[k] = v;
+                    }
+                    callback(err, data);
+                }
+            }
+        });
+    }
+
+    // callback(err, [])
+    self.keys = function(key_start, key_end, limit, callback){
+        self.request('keys', [key_start, key_end, limit], function(resp){
+            if(callback){
+                var err = resp[0] == 'ok'? 0 : resp[0];
+                var data = [];
+                for(var i=1; i<resp.length; i++){
+                    var k = resp[i].toString();
+                    data.push(k);
+                }
+                callback(err, data);
+            }
+        });
+    }
+
+    //////////////////////////////////////////////
+
+    // callback(score)
+    self.zget = function(name, key, callback){
+        self.request('zget', [name, key], function(resp){
+            if(callback){
+                var err = resp[0] == 'ok'? 0 : resp[0];
+                if(resp.length == 2){
+                    var score = parseInt(resp[1]);
+                    callback(err, score);
+                }else{
+                    var score = 0;
+                    callback('error');
+                }
+            }
+        });
+    }
+
+    // callback(size)
+    self.zsize = function(name, callback){
+        self.request('zsize', [name], function(resp){
+            if(callback){
+                var err = resp[0] == 'ok'? 0 : resp[0];
+                if(resp.length == 2){
+                    var size = parseInt(resp[1]);
+                    callback(err, size);
+                }else{
+                    var score = 0;
+                    callback('error');
+                }
+            }
+        });
+    }
+
+    // callback(err);
+    self.zset = function(name, key, score, callback){
+        self.request('zset', [name, key, score], function(resp){
+            if(callback){
+                var err = resp[0] == 'ok'? 0 : resp[0];
+                callback(err);
+            }
+        });
+    }
+
+    // callback(err);
+    self.zdel = function(name, key, callback){
+        self.request('zdel', [name, key], function(resp){
+            if(callback){
+                var err = resp[0] == 'ok'? 0 : resp[0];
+                callback(err);
+            }
+        });
+    }
+
+    // callback(err, {index:[], items:{key:score}})
+    self.zscan = function(name, key_start, score_start, score_end, limit, callback){
+        self.request('zscan', [name, key_start, score_start, score_end, limit], function(resp){
+            if(callback){
+                var err = resp[0] == 'ok'? 0 : resp[0];
+                if(resp.length % 2 != 1){
+                    callback('error');
+                }else{
+                    var data = {index: [], items: {}};
+                    for(var i=1; i<resp.length; i+=2){
+                        var k = resp[i].toString();
+                        var v = parseInt(resp[i+1]);
+                        data.index.push(k);
+                        data.items[k] = v;
+                    }
+                    callback(err, data);
+                }
+            }
+        });
+    }
+
+    // callback(err, [])
+    self.zlist = function(name_start, name_end, limit, callback){
+        self.request('zlist', [name_start, name_end, limit], function(resp){
+            if(callback){
+                var err = resp[0] == 'ok'? 0 : resp[0];
+                var data = [];
+                for(var i=1; i<resp.length; i++){
+                    var k = resp[i].toString();
+                    data.push(k);
+                }
+                callback(err, data);
+            }
+        });
+    }
+
+    // callback(err,sum)
+    self.zsum = function(name, score_start, score_end, callback){
+        self.request('zsum', [name,score_start,score_end], function(resp){
+            if(callback){
+                var err = resp[0] == 'ok'? 0 : resp[0];
+                if(resp.length == 2){
+                    var size = parseInt(resp[1]);
+                    callback(err, size);
+                }else{
+                    callback('error');
+                }
+            }
+        });
+    }
+
+    //////////////////////////////////////////////
+
+    // callback(val)
+    self.hget = function(name, key, callback){
+        self.request('hget', [name, key], function(resp){
+            if(callback){
+                var err = resp[0] == 'ok'? 0 : resp[0];
+                if(resp.length == 2){
+                    callback(err, resp[1]);
+                }else{
+                    callback('error');
+                }
+            }
+        });
+    }
+
+    // callback(err);
+    self.hset = function(name, key, val, callback){
+        self.request('hset', [name, key, val], function(resp){
+            if(callback){
+                var err = resp[0] == 'ok'? 0 : resp[0];
+                callback(err);
+            }
+        });
+    }
+
+    // callback(err);
+    self.hdel = function(name, key, callback){
+        self.request('hdel', [name, key], function(resp){
+            if(callback){
+                var err = resp[0] == 'ok'? 0 : resp[0];
+                callback(err);
+            }
+        });
+    }
+
+    // callback(err, {index:[], items:{key:score}})
+    self.hscan = function(name, key_start, key_end, limit, callback){
+        self.request('hscan', [name, key_start, key_end, limit], function(resp){
+            if(callback){
+                var err = resp[0] == 'ok'? 0 : resp[0];
+                if(resp.length % 2 != 1){
+                    callback('error');
+                }else{
+                    var data = {index: [], items: {}};
+                    for(var i=1; i<resp.length; i+=2){
+                        var k = resp[i].toString();
+                        var v = resp[i+1].toString();
+                        data.index.push(k);
+                        data.items[k] = v;
+                    }
+                    callback(err, data);
+                }
+            }
+        });
+    }
+
+    // callback(err, [])
+    self.hlist = function(name_start, name_end, limit, callback){
+        self.request('hlist', [name_start, name_end, limit], function(resp){
+            if(callback){
+                var err = resp[0] == 'ok'? 0 : resp[0];
+                var data = [];
+                for(var i=1; i<resp.length; i++){
+                    var k = resp[i].toString();
+                    data.push(k);
+                }
+                callback(err, data);
+            }
+        });
+    }
+
+    // callback(size)
+    self.hsize = function(name, callback){
+        self.request('hsize', [name], function(resp){
+            if(callback){
+                var err = resp[0] == 'ok'? 0 : resp[0];
+                if(resp.length == 2){
+                    var size = parseInt(resp[1]);
+                    callback(err, size);
+                }else{
+                    var score = 0;
+                    callback('error');
+                }
+            }
+        });
+    }
+
+    return self;
+}
+
 exports.connect = function(host, port, timeout, listener){
-	var self = this;
-	var recv_buf = new Buffer(0);
-	var callbacks = [];
-	var connected = false;
-
-	if(typeof(timeout) == 'function'){
-		listener = timeout;
-		timeout = 0;
-	}
-	listener = listener || function(){};
-
-	var sock = new net.Socket();
-	sock.on('error', function(e){
-		if(!connected){
-			listener('connect_failed', e);
-		}else{
-			var callback = callbacks.shift();
-			callback(['error']);
-		}
-	});
-	sock.connect(port, host, function(){
-		connected = true;
-		sock.setNoDelay(true);
-		sock.setKeepAlive(true);
-		sock.setTimeout(timeout);
-		listener(0, self);
-	});
-
-	self.close = function(){
-		sock.end();
-	}
-
-	self.request = function(cmd, params, callback){
-		var arr = [cmd].concat(params);
-		self.send_request(arr);
-		callbacks.push(callback || function(){});
-	}
-
-	function build_buffer(arr){
-		var bs = [];
-		var size = 0;
-		for(var i = 0; i < arr.length; i++){
-			var arg = arr[i];
-			if(arg instanceof Buffer){
-				//
-			}else{
-				arg = new Buffer(arg.toString());
-			}
-			bs.push(arg);
-			size += arg.length;
-		}
-		var ret = new Buffer(size);
-		var offset = 0;
-		for(var i=0; i<bs.length; i++){
-			bs[i].copy(ret, offset);
-			offset += bs[i].length;
-		}
-		return ret;
-	}
-
-	self.send_request = function(params){
-		var bs = [];
-		for(var i=0;i<params.length;i++){
-			var p = params[i];
-			var len = 0;
-			if(!(p instanceof Buffer)){
-				p = p.toString();
-				bs.push(Buffer.byteLength(p));
-			}else{
-				bs.push(p.length);
-			}
-			bs.push('\n');
-			bs.push(p);
-			bs.push('\n');
-		}
-		bs.push('\n');
-		var req = build_buffer(bs);
-		sock.write(req);
-		//console.log('write ' + req.length + ' bytes');
-		//console.log('write: ' + req);
-	}
-
-	sock.on('data', function(data){
-		recv_buf = build_buffer([recv_buf, data]);
-		while(recv_buf.length > 0){
-			var resp = parse();
-			if(!resp){
-				break;
-			}
-			resp[0] = resp[0].toString();
-			var callback = callbacks.shift();
-			callback(resp);
-		}
-	});
-
-	function memchr(buf, ch, start){
-		start = start || 0;
-		ch = typeof(ch) == 'string'? ch.charCodeAt(0) : ch;
-		for(var i=start; i<buf.length; i++){
-			if(buf[i] == ch){
-				return i;
-			}
-		}
-		return -1;
-	}
-
-	function parse(){
-		var ret = [];
-		var spos = 0;
-		var pos;
-		//console.log('parse: ' + recv_buf.length + ' bytes');
-		while(true){
-			//pos = recv_buf.indexOf('\n', spos);
-			pos = memchr(recv_buf, '\n', spos);
-			if(pos == -1){
-				// not finished
-				return null;
-			}
-			var line = recv_buf.slice(spos, pos).toString();
-			spos = pos + 1;
-			line = line.replace(/^\s+(.*)\s+$/, '\1');
-			if(line.length == 0){
-				// parse end
-				//recv_buf = recv_buf.substr(spos);
-				recv_buf = recv_buf.slice(spos);
-				break;
-			}
-			var len = parseInt(line);
-			if(isNaN(len)){
-				// error
-				console.log('error 1');
-				return null;
-			}
-			if(spos + len > recv_buf.length){
-				// not finished
-				//console.log(spos + len, recv_buf.length);
-				//console.log('not finish');
-				return null;
-			}
-			//var data = recv_buf.substr(spos, len);
-			var data = recv_buf.slice(spos, spos + len);
-			spos += len;
-			ret.push(data);
-
-			//pos = recv_buf.indexOf('\n', spos);
-			pos = memchr(recv_buf, '\n', spos);
-			if(pos == -1){
-				// not finished
-				console.log('error 3');
-				return null;
-			}
-			// '\n', or '\r\n'
-			//if(recv_buf.charAt(spos) != '\n' && recv_buf.charAt(spos) != '\r' && recv_buf.charAt(spos+1) != '\n'){
-			var cr = '\r'.charCodeAt(0);
-			var lf = '\n'.charCodeAt(0);
-			if(recv_buf[spos] != lf && recv_buf[spos] != cr && recv_buf[spos+1] != lf){
-				// error
-				console.log('error 4 ' + recv_buf[spos]);
-				return null;
-			}
-			spos = pos + 1;
-		}
-		return ret;
-	}
-
-	// callback(err, val);
-	// err: 0 on sucess, or error_code(string) on error
-	self.get = function(key, callback){
-		self.request('get', [key], function(resp){
-			if(callback){
-				var err = resp[0] == 'ok'? 0 : resp[0];
-				var val = resp[1];
-				callback(err, val);
-			}
-		});
-	}
-
-	// callback(err);
-	self.set = function(key, val, callback){
-		self.request('set', [key, val], function(resp){
-			if(callback){
-				var err = resp[0] == 'ok'? 0 : resp[0];
-				callback(err);
-			}
-		});
-	}
-
-	// callback(err);
-	self.del = function(key, callback){
-		self.request('del', [key], function(resp){
-			if(callback){
-				var err = resp[0] == 'ok'? 0 : resp[0];
-				callback(err);
-			}
-		});
-	}
-
-	// callback(err, {index:[], items:{key:score}})
-	self.scan = function(key_start, key_end, limit, callback){
-		self.request('scan', [key_start, key_end, limit], function(resp){
-			if(callback){
-				var err = resp[0] == 'ok'? 0 : resp[0];
-				if(resp.length % 2 != 1){
-					callback('error');
-				}else{
-					var data = {index: [], items: {}};
-					for(var i=1; i<resp.length; i+=2){
-						var k = resp[i].toString();
-						var v = resp[i+1].toString();
-						data.index.push(k);
-						data.items[k] = v;
-					}
-					callback(err, data);
-				}
-			}
-		});
-	}
-
-	// callback(err, [])
-	self.keys = function(key_start, key_end, limit, callback){
-		self.request('keys', [key_start, key_end, limit], function(resp){
-			if(callback){
-				var err = resp[0] == 'ok'? 0 : resp[0];
-				var data = [];
-				for(var i=1; i<resp.length; i++){
-					var k = resp[i].toString();
-					data.push(k);
-				}
-				callback(err, data);
-			}
-		});
-	}
-
-	//////////////////////////////////////////////
-
-	// callback(score)
-	self.zget = function(name, key, callback){
-		self.request('zget', [name, key], function(resp){
-			if(callback){
-				var err = resp[0] == 'ok'? 0 : resp[0];
-				if(resp.length == 2){
-					var score = parseInt(resp[1]);
-					callback(err, score);
-				}else{
-					var score = 0;
-					callback('error');
-				}
-			}
-		});
-	}
-
-	// callback(size)
-	self.zsize = function(name, callback){
-		self.request('zsize', [name], function(resp){
-			if(callback){
-				var err = resp[0] == 'ok'? 0 : resp[0];
-				if(resp.length == 2){
-					var size = parseInt(resp[1]);
-					callback(err, size);
-				}else{
-					var score = 0;
-					callback('error');
-				}
-			}
-		});
-	}
-
-	// callback(err);
-	self.zset = function(name, key, score, callback){
-		self.request('zset', [name, key, score], function(resp){
-			if(callback){
-				var err = resp[0] == 'ok'? 0 : resp[0];
-				callback(err);
-			}
-		});
-	}
-
-	// callback(err);
-	self.zdel = function(name, key, callback){
-		self.request('zdel', [name, key], function(resp){
-			if(callback){
-				var err = resp[0] == 'ok'? 0 : resp[0];
-				callback(err);
-			}
-		});
-	}
-
-	// callback(err, {index:[], items:{key:score}})
-	self.zscan = function(name, key_start, score_start, score_end, limit, callback){
-		self.request('zscan', [name, key_start, score_start, score_end, limit], function(resp){
-			if(callback){
-				var err = resp[0] == 'ok'? 0 : resp[0];
-				if(resp.length % 2 != 1){
-					callback('error');
-				}else{
-					var data = {index: [], items: {}};
-					for(var i=1; i<resp.length; i+=2){
-						var k = resp[i].toString();
-						var v = parseInt(resp[i+1]);
-						data.index.push(k);
-						data.items[k] = v;
-					}
-					callback(err, data);
-				}
-			}
-		});
-	}
-
-	// callback(err, [])
-	self.zlist = function(name_start, name_end, limit, callback){
-		self.request('zlist', [name_start, name_end, limit], function(resp){
-			if(callback){
-				var err = resp[0] == 'ok'? 0 : resp[0];
-				var data = [];
-				for(var i=1; i<resp.length; i++){
-					var k = resp[i].toString();
-					data.push(k);
-				}
-				callback(err, data);
-			}
-		});
-	}
-	
-	// callback(err,sum)
-	self.zsum = function(name, score_start, score_end, callback){
-		self.request('zsum', [name,score_start,score_end], function(resp){
-			if(callback){
-				var err = resp[0] == 'ok'? 0 : resp[0];
-				if(resp.length == 2){
-					var size = parseInt(resp[1]);
-					callback(err, size);
-				}else{
-					callback('error');
-				}
-			}
-		});
-	}
-
-	//////////////////////////////////////////////
-
-	// callback(val)
-	self.hget = function(name, key, callback){
-		self.request('hget', [name, key], function(resp){
-			if(callback){
-				var err = resp[0] == 'ok'? 0 : resp[0];
-				if(resp.length == 2){
-					callback(err, resp[1]);
-				}else{
-					callback('error');
-				}
-			}
-		});
-	}
-
-	// callback(err);
-	self.hset = function(name, key, val, callback){
-		self.request('hset', [name, key, val], function(resp){
-			if(callback){
-				var err = resp[0] == 'ok'? 0 : resp[0];
-				callback(err);
-			}
-		});
-	}
-
-	// callback(err);
-	self.hdel = function(name, key, callback){
-		self.request('hdel', [name, key], function(resp){
-			if(callback){
-				var err = resp[0] == 'ok'? 0 : resp[0];
-				callback(err);
-			}
-		});
-	}
-
-	// callback(err, {index:[], items:{key:score}})
-	self.hscan = function(name, key_start, key_end, limit, callback){
-		self.request('hscan', [name, key_start, key_end, limit], function(resp){
-			if(callback){
-				var err = resp[0] == 'ok'? 0 : resp[0];
-				if(resp.length % 2 != 1){
-					callback('error');
-				}else{
-					var data = {index: [], items: {}};
-					for(var i=1; i<resp.length; i+=2){
-						var k = resp[i].toString();
-						var v = resp[i+1].toString();
-						data.index.push(k);
-						data.items[k] = v;
-					}
-					callback(err, data);
-				}
-			}
-		});
-	}
-
-	// callback(err, [])
-	self.hlist = function(name_start, name_end, limit, callback){
-		self.request('hlist', [name_start, name_end, limit], function(resp){
-			if(callback){
-				var err = resp[0] == 'ok'? 0 : resp[0];
-				var data = [];
-				for(var i=1; i<resp.length; i++){
-					var k = resp[i].toString();
-					data.push(k);
-				}
-				callback(err, data);
-			}
-		});
-	}
-
-	// callback(size)
-	self.hsize = function(name, callback){
-		self.request('hsize', [name], function(resp){
-			if(callback){
-				var err = resp[0] == 'ok'? 0 : resp[0];
-				if(resp.length == 2){
-					var size = parseInt(resp[1]);
-					callback(err, size);
-				}else{
-					var score = 0;
-					callback('error');
-				}
-			}
-		});
-	}
-
-	return self;
+    return new SSDBConnect(host, port, timeout, listener);
 }
 
 
 /*
-example:
-var SSDB = require('./SSDB.js');
-var ssdb = SSDB.connect(host, port, function(err){
-	if(err){
-		return;
-	}
-	ssdb.set('a', new Date(), function(){
-		console.log('set a');
-	});
-});
-*/
-
+ example:
+ var SSDB = require('./SSDB.js');
+ var ssdb = SSDB.connect(host, port, function(err){
+ if(err){
+ return;
+ }
+ ssdb.set('a', new Date(), function(){
+ console.log('set a');
+ });
+ });
+ */