分布式事务内存数据库 --MemDB

[common]home=/usr/local/memdb #运行目录thread_num=4 #线程数量store_type=bdb #存储engine类型sock_buf_kbyte=8192 #数据同步的socket bufmax_chunk_kbyte=1024 #数据同步最大的chunk大小store_flush_num=10000 #多少条数据必须sync 存储host=172.168.1.8 #主机标示，为内部同步的host ip地址idc=yf #所属的idc名字group=1 #所属的分组名字trans_conn_num=20 #内部消息转发的连接数量sync_conn_num=20 #内部数据同步的连接树立write_cache_mbyte=256 #写cache的大小read_cache_mbyte=2048 #读cache的大read_cache_max_key_num=20000000 #读cache的最大key数量master_lost_binlog=100000 #slave变为master，运行丢失的最大binlog数量。max_write_queue_messge=500000 #写队列排队消息的最大数量，超过则写失败。max_trans_message=100000 #并发master转发消息的最大数量，超过则失败。monitor=:9900 #监控端口enable_expire=yes/no #是否支持key的expire，yes：支持；no：不支持。expire_default=3600 #若没有指定expire，缺省的expire值，单位为s。expire_concurrent = 100 #expire检查的并发消息数量。
[inner_dispatch]user=async #内部分发的连接用户名passwd=async_passwd #内部分发的用户口令listen=:9903 #内部分发的监听地址
[outer_dispatch]user=async #外部分发的连接用户名passwd=async_passwd #外部分发的用户口令listen=:9903 #外部分发的监听地址
[zk]server=172.16.42.1:2181 #zookeeper的连接auth= #zk的认证root=/memdb #zookeeper配置信息的root目录
[binlog]path=/data2/kv_data/data/binlog #binlog文件的路径file_prefix=binlog #binlog文件的前缀file_max_mbyte=1024 #binlog文件的最大大小max_file_num=24 #维护的binlog文件的数量del_out_file=yes #是否删除不维护的binlong文件cache=no #对接受的到binlog是否cache，cache的话，若程序以外down会丢失flush_log_num=100000 #多少条日志flush binlog文件flush_log_second=100 #多少秒必须flsuh binlog文件
[bdb] #bdb存储engine的配置env_home=/data3/bdb_home #bdb的env home目录db_path=/data4/bdb_data #bdb的db目录compress=yes #bdb是否压缩cache_msize=3000 #bdb的cache大小page_ksize=32 #bdb的page大小[bdbc] #海量、高效、动态可配多计数值的计数器引擎配置env_home=/data3/bdb_home #bdb的env home目录db_path=/data4/bdb_data #bdb的db目录compress=yes #bdb是否压缩cache_msize=3000 #bdb的cache大小page_ksize=32 #bdb的page大小key_type=int64 #key的类型。可为int32/int64/int128/int256/charint32_hex=no/yes #对于int32的key，返回时是否以16进制表示int64_hex=yes/no #对于int64的key，返回时是否以16进制表示hex_upper=yes/no #对于返回的16进制的key，是否大写a-fgroup_start_time_bit =0 #bdb文件分组的key的group bit32值的开始bit位group_end_time_bit=5 #bdb文件分组的key的group bit32值的结束bit位counter_def_file=/usr/home//unistor/bin/counter_def.dat #key的计数器名字配置文件

var memdb = require('memdb-client');var P = memdb.Promise;var mdbgoose = memdb.goose;// Define player schemavar playerSchema = new mdbgoose.Schema({    _id : String,    name : String,    areaId : Number,    deviceType : Number,    deviceId : String,    items : [mdbgoose.SchemaTypes.Mixed],}, {collection : 'player'});// Define player modelvar Player = mdbgoose.model('player', playerSchema);var main = P.coroutine(function*(){    // Connect to memdb    yield mdbgoose.connectAsync({        shards : { // specify all shards here            s1 : {host : '127.0.0.1', port: 31017},            s2 : {host : '127.0.0.1', port: 31018},        }    });    // Make a transaction in s1    yield mdbgoose.transactionAsync(P.coroutine(function*(){        var player = new Player({            _id : 'p1',            name: 'rain',            areaId : 1,            deviceType : 1,            deviceId : 'id1',            items : [],        });        // insert a player        yield player.saveAsync();        // find player by id        var doc = yield Player.findByIdAsync('p1');        console.log('%j', doc);        // find player by areaId, return array of players        var docs = yield Player.findAsync({areaId : 1});        console.log('%j', docs);        // find player by deviceType and deviceId        player = yield Player.findOneAsync({deviceType : 1, deviceId : 'id1'});        // update player        player.areaId = 2;        yield player.saveAsync();        // remove the player        yield player.removeAsync();    }), 's1');});if (require.main === module) {    main().finally(process.exit);}