SSDB是一个快速的用来存储十亿级别列表数据的开源 Nosql 数据库。

特性

• 替代 Redis 数据库,Redis 的 100 倍容量
• LevelDB 网络支持,使用 C/C++ 开发
• Redis API 兼容,支持 Redis 客户端
• 适合存储集合数据,如 list,hash,zset...
• 客户端 API 支持的语言包括: C++、PHP、Python、Cpy、Java、NodeJS、Ruby、Go。
• 持久化的队列服务
• 主从复制,负载均衡

性能

1000请求：

writeseq  :    0.546 ms/op      178.7 MB/s
writerand :    0.519 ms/op      188.1 MB/s
readseq   :    0.304 ms/op      321.6 MB/s
readrand  :    0.310 ms/op      315.0 MB/s

并发：

========== set ==========
qps: 44251,time: 0.226 s
========== get ==========
qps: 55541,time: 0.180 s
========== del ==========
qps: 46080,time: 0.217 s
========== hset ==========
qps: 42338,time: 0.236 s
========== hget ==========
qps: 55601,time: 0.180 s
========== hdel ==========
qps: 46529,time: 0.215 s
========== zset ==========
qps: 37381,time: 0.268 s
========== zget ==========
qps: 41455,time: 0.241 s
========== zdel ==========
qps: 38792,time: 0.258 s

在MacBook Pro 13 （Retina屏幕）上运行。

与redis的比较：

性能数据使用 ssdb-bench(SSDB) 和 redis-benchmark(Redis) 来获取。

架构

安装

下载压缩包，解压缩

wget --no-check-certificate https://github.com/ideawu/ssdb/archive/master.zip
unzip master
cd ssdb-master

编译

make

安装（可选）

sudo make install

运行

./ssdb-server ssdb.conf

或者以后台的方式运行

./ssdb-server -d ssdb.conf

ssdb命令行

./tools/ssdb-cli -p 8888

停止ssdb-server

kill `cat ./var/ssdb.pid`

使用

PHP

<?PHP
include_once('SSDB.PHP');
try{
    $ssdb = new SimpleSSDB('127.0.0.1',8888);
}catch(Exception $e){
    die(__LINE__ . ' ' . $e->getMessage());
}
$ret = $ssdb->set('key','value');
if($ret === false){
    // error!
}
echo $ssdb->get('key');

Python

使用pyssdb

>>> import pyssdb
>>> c = pyssdb.Client()
>>> c.set('key','value')
1
>>> c.get('key')
'value'
>>> c.hset('hash','item','value')
1
>>> c.hget('hash','item')
'value'
>>> c.hget('hash','not exist') is None
True
>>> c.incr('counter')
1
>>> c.incr('counter')
2
>>> c.incr('counter')
3
>>> c.keys('a','z',1)
['counter']
>>> c.keys('a',10)
['counter','key']

Ruby

使用ssdb-rb

require "ssdb"

ssdb = SSDB.new url: "ssdb://1.2.3.4:8889"

ssdb.set("mykey","hello world")
# => true

ssdb.get("mykey")
# => "hello world"

ssdb.batch do
  ssdb.set "foo","5"
  ssdb.get "foo"
  ssdb.incr "foo"
end
# => [true,"5",6]

Go

package main

import (
        "fmt"
        "os"
        "./ssdb"
       )

func main(){
    ip := "127.0.0.1";
    port := 8888;
    db,err := ssdb.Connect(ip,port);
    if(err != nil){
        os.Exit(1);
    }

    var val interface{};
    db.Set("a","xxx");
    val,err = db.Get("a");
    fmt.Printf("%s\n",val);
    db.Del("a");
    val,val);

    db.Do("zset","z","a",3);
    db.Do("multi_zset","b",-2,"c",5,"d",3);
    resp,err := db.Do("zrange",10);
    if err != nil{
        os.Exit(1);
    }
    if len(resp) % 2 != 1{
        fmt.Printf("bad response");
        os.Exit(1);
    }

    fmt.Printf("Status: %s\n",resp[0]);
    for i:=1; i<len(resp); i+=2{
        fmt.Printf("  %s : %3s\n",resp[i],resp[i+1]);
    }
    return;

ngx_lua

使用lua-resty-ssdb

lua_package_path "/path/to/lua-resty-ssdb/lib/?.lua;;";

server {
    location /test {
        content_by_lua '
            local ssdb = require "resty.ssdb"
            local db = ssdb:new()

            db:set_timeout(1000) -- 1 sec

            local ok,err = db:connect("127.0.0.1",8888)
            if not ok then
                ngx.say("Failed to connect: ",err)
                return
            end

            ok,err = db:set("dog","an animal")
            if not ok then
                ngx.say("Failed to set dog: ",err)
                return
            end

            ngx.say("set result: ",ok)

            local res,err = db:get("dog")
            if not res then
                ngx.say("Failed to get dog: ",err)
                return
            end

            if res == ngx.null then
                ngx.say("dog not found.")
                return
            end

            ngx.say("dog: ",res)

            db:init_pipeline()
            db:set("cat","Marry")
            db:set("horse","Bob")
            db:get("cat")
            db:get("horse")
            local results,err = db:commit_pipeline()
            if not results then
                ngx.say("Failed to commit the pipelined requests: ",err)
                return
            end

            for i,res in ipairs(results) do
                if type(res) == "table" then
                    if not res[1] then
                        ngx.say("Failed to run command ",i,": ",res[2])
                    else
                        -- process the table value
                    end
                else
                    -- process the scalar value
                end
            end

            -- put it into the connection pool of size 100,-- with 0 idle timeout
            local ok,err = db:set_keepalive(0,100)
            if not ok then
                ngx.say("Failed to set keepalive: ",err)
                return
            end

            -- or just close the connection right away:
            -- local ok,err = db:close()
            -- if not ok then
            --     ngx.say("Failed to close: ",err)
            --     return
            -- end
        ';
    }
}

C++

#include <stdio.h>
#include <stdlib.h>
#include <string>
#include <vector>
#include "SSDB.h"

int main(int argc,char **argv){
    const char *ip = (argc >= 2)? argv[1] : "127.0.0.1";
    int port = (argc >= 3)? atoi(argv[2]) : 8888;

    ssdb::Client *client = ssdb::Client::connect(ip,port);
    if(client == NULL){
        printf("fail to connect to server!\n");
        return 0;
    }

    ssdb::Status s;
    s = client->set("k","hello ssdb!");
    if(s.ok()){
        printf("k = hello ssdb!\n");
    }else{
        printf("error!\n");
    }

    delete client;
    return 0;
}

项目主页

编撰 SegmentFault