Pika支持的命令列表
pika_admin.h/cc管理类命令实现，包括:
slaveof设置当前server的master server
trysync尝试与master server同步
auth认证命令
bgsave后台dump数据库
bgsaveoff
compact
purgelogsto
ping ping命令
select选择db
flushall清空数据库
readonly当前server设置为只读
client
shutdown
info 当前redis的info
config
monitor
pika_kv.h/cc kv数据结构实现,包括:
set
get
del
incr
incrby
incrbyfloat
decr
decrby
getset
append
mget
keys
setnx
setex
mset
msetnx
getrange
setrange
strlen
exists
expire
pexpire
expireat
pexpireat
ttl
pttl
persist
type
scan
pika_list.h/cclist数据结构实现,包括:
lindex
linsert
llen
lpop
lpush
lpushx
lrange
lrem
lset
ltrim
rpop
rpoplpush
rpush
rpushx
pika_hash.h/cchash数据结构实现,包括:
hdel
hset
hget
hgetall
hexists
hincrby
hincrbyfloat
hkeys
hlen
hmget
hmset
hsetnx
hstrlen
hvals
hscan
pika_set.h/ccset数据结构实现,包括:
sadd
spop
scard
smembers
sscan
srem
sunion
sunionstore
sinter
sinterstore
sismember
sdiff
sdiffstore
smove
srandmember
pika_zset.h/cczset数据结构实现,包括:
zadd
zcard
zscan
zincrby
zrange
zrangebyscore
zcount
zrem
zunionstore
zinterstore
zrank
zrevrank
zscore
zrevrange
zrevrangebyscore
zrangebylex
zrevrangebylex
zlexcount
zremrangebyrank
zremrangebylex
zremrangebyscore
pika_bit.h/ccbitmap相关实现,包括:
setbit
getbit
bitpos
bitop
bitcount
Pika命令属性
CmdInfo类是所有命令实现类的基类，主要用来确定每个命令的属性（只读、写等），以及每个命令所需要的参数个数，在执行每个命令之前，首先调用CheckArg校验参数的个数是否合法，每个命令当arity_成员变量大于0的时候，表示参数个数必须等于它，小于0的时候表示参数个数至少是其绝对值大小，否则直接返回错误。
class CmdInfo {
public:
CmdInfo(const std::string _name, int _num, uint16_t _flag)
: name_(_name), arity_(_num), flag_(_flag) {}
bool CheckArg(int num) const {
if ((arity_ > 0 && num != arity_) || (arity_ < 0 && num < -arity_)) {
return false;
}
return true;
}
bool is_write() const {
return ((flag_ & kCmdFlagsMaskRW) == kCmdFlagsWrite);
}
uint16_t flag_type() const {
return flag_ & kCmdFlagsMaskType;
}
bool is_local() const {
return ((flag_ & kCmdFlagsMaskLocal) == kCmdFlagsLocal);
}
// Others need to be suspended when a suspend command run
bool is_suspend() const {
return ((flag_ & kCmdFlagsMaskSuspend) == kCmdFlagsSuspend);
}
bool is_prior() const {
return ((flag_ & kCmdFlagsMaskPrior) == kCmdFlagsPrior);
}
// Must with admin auth
bool is_admin_require() const {
return ((flag_ & kCmdFlagsMaskAdminRequire) == kCmdFlagsAdminRequire);
}
std::string name() const {
return name_;
}
private:
std::string name_;
int arity_;
uint16_t flag_;
CmdInfo(const CmdInfo&);
CmdInfo& operator=(const CmdInfo&);
};
void InitCmdInfoTable() {
/////////////////////////Admin////////////////////////
////slaveof
CmdInfo* slaveofptr = new CmdInfo(kCmdNameSlaveof, -3, kCmdFlagsRead | kCmdFlagsAdmin);
cmd_infos.insert(std::pair<std::string, CmdInfo*>(kCmdNameSlaveof, slaveofptr));
////trysync
CmdInfo* trysyncptr = new CmdInfo(kCmdNameTrysync, 5, kCmdFlagsRead | kCmdFlagsAdmin | kCmdFlagsSuspend | kCmdFlagsAdminRequire);
cmd_infos.insert(std::pair<std::string, CmdInfo*>(kCmdNameTrysync, trysyncptr));
//auth
CmdInfo* authptr = new CmdInfo(kCmdNameAuth, 2, kCmdFlagsRead | kCmdFlagsAdmin);
cmd_infos.insert(std::pair<std::string, CmdInfo*>(kCmdNameAuth, authptr));
//bgsave
CmdInfo* bgsaveptr = new CmdInfo(kCmdNameBgsave, 1, kCmdFlagsRead | kCmdFlagsAdmin | kCmdFlagsSuspend);
cmd_infos.insert(std::pair<std::string, CmdInfo*>(kCmdNameBgsave, bgsaveptr));
//bgsaveoff
CmdInfo* bgsaveoffptr = new CmdInfo(kCmdNameBgsaveoff, 1, kCmdFlagsRead | kCmdFlagsAdmin);
cmd_infos.insert(std::pair<std::string, CmdInfo*>(kCmdNameBgsaveoff, bgsaveoffptr));
//compact
CmdInfo* compactptr = new CmdInfo(kCmdNameCompact, 1, kCmdFlagsRead | kCmdFlagsAdmin);
cmd_infos.insert(std::pair<std::string, CmdInfo*>(kCmdNameCompact, compactptr));
//purgelogsto
CmdInfo* purgelogptr = new CmdInfo(kCmdNamePurgelogsto, 2, kCmdFlagsRead | kCmdFlagsAdmin);
cmd_infos.insert(std::pair<std::string, CmdInfo*>(kCmdNamePurgelogsto, purgelogptr));
//ping
CmdInfo* pingptr = new CmdInfo(kCmdNamePing, 1, kCmdFlagsRead | kCmdFlagsAdmin);
cmd_infos.insert(std::pair<std::string, CmdInfo*>(kCmdNamePing, pingptr));
//select
CmdInfo* selectptr = new CmdInfo(kCmdNameSelect, 2, kCmdFlagsWrite | kCmdFlagsAdmin);
cmd_infos.insert(std::pair<std::string, CmdInfo*>(kCmdNameSelect, selectptr));
//flushall
CmdInfo* flushallptr = new CmdInfo(kCmdNameFlushall, 1, kCmdFlagsWrite | kCmdFlagsSuspend | kCmdFlagsAdmin);
cmd_infos.insert(std::pair<std::string, CmdInfo*>(kCmdNameFlushall, flushallptr));
//readonly
CmdInfo* readonlyptr = new CmdInfo(kCmdNameReadonly, 2, kCmdFlagsRead | kCmdFlagsSuspend | kCmdFlagsAdmin);
cmd_infos.insert(std::pair<std::string, CmdInfo*>(kCmdNameReadonly, readonlyptr));
//client
CmdInfo* clientptr = new CmdInfo(kCmdNameClient, -2, kCmdFlagsRead | kCmdFlagsAdmin);
cmd_infos.insert(std::pair<std::string, CmdInfo*>(kCmdNameClient, clientptr));
//shutdown
CmdInfo* shutdownptr = new CmdInfo(kCmdNameShutdown, 1, kCmdFlagsRead | kCmdFlagsLocal | kCmdFlagsAdmin);
cmd_infos.insert(std::pair<std::string, CmdInfo*>(kCmdNameShutdown, shutdownptr));
//info
CmdInfo* infoptr = new CmdInfo(kCmdNameInfo, -1, kCmdFlagsRead | kCmdFlagsAdmin);
cmd_infos.insert(std::pair<std::string, CmdInfo*>(kCmdNameInfo, infoptr));
//config
CmdInfo* configptr = new CmdInfo(kCmdNameConfig, -2, kCmdFlagsRead | kCmdFlagsAdmin);
cmd_infos.insert(std::pair<std::string, CmdInfo*>(kCmdNameConfig, configptr));
//monitor
CmdInfo* monitorptr = new CmdInfo(kCmdNameMonitor, -1, kCmdFlagsRead | kCmdFlagsAdmin);
cmd_infos.insert(std::pair<std::string, CmdInfo*>(kCmdNameMonitor, monitorptr));
///////////////////////////Kv////////////////////////////
////SetCmd
CmdInfo* setptr = new CmdInfo(kCmdNameSet, -3, kCmdFlagsWrite | kCmdFlagsKv);
cmd_infos.insert(std::pair<std::string, CmdInfo*>(kCmdNameSet, setptr));
////GetCmd
CmdInfo* getptr = new CmdInfo(kCmdNameGet, 2, kCmdFlagsRead | kCmdFlagsKv);
cmd_infos.insert(std::pair<std::string, CmdInfo*>(kCmdNameGet, getptr));
////DelCmd
CmdInfo* delptr = new CmdInfo(kCmdNameDel, -2, kCmdFlagsWrite | kCmdFlagsKv); //whethre it should be kCmdFlagsKv
cmd_infos.insert(std::pair<std::string, CmdInfo*>(kCmdNameDel, delptr));
////IncrCmd
CmdInfo* incrptr = new CmdInfo(kCmdNameIncr, 2, kCmdFlagsWrite | kCmdFlagsKv);
cmd_infos.insert(std::pair<std::string, CmdInfo*>(kCmdNameIncr, incrptr));
////IncrbyCmd
CmdInfo* incrbyptr = new CmdInfo(kCmdNameIncrby, 3, kCmdFlagsWrite | kCmdFlagsKv);
cmd_infos.insert(std::pair<std::string, CmdInfo*>(kCmdNameIncrby, incrbyptr));
////IncrbyfloatCmd
CmdInfo* incrbyfloatptr = new CmdInfo(kCmdNameIncrbyfloat, 3, kCmdFlagsWrite | kCmdFlagsKv);
cmd_infos.insert(std::pair<std::string, CmdInfo*>(kCmdNameIncrbyfloat, incrbyfloatptr));
////Decr
CmdInfo* decrptr = new CmdInfo(kCmdNameDecr, 2, kCmdFlagsWrite | kCmdFlagsKv);
cmd_infos.insert(std::pair<std::string, CmdInfo*>(kCmdNameDecr, decrptr));
////Decrby
CmdInfo* decrbyptr = new CmdInfo(kCmdNameDecrby, 3, kCmdFlagsWrite | kCmdFlagsKv);
cmd_infos.insert(std::pair<std::string, CmdInfo*>(kCmdNameDecrby, decrbyptr));
////Getset
CmdInfo* getsetptr = new CmdInfo(kCmdNameGetset, 3, kCmdFlagsWrite | kCmdFlagsKv);
cmd_infos.insert(std::pair<std::string, CmdInfo*>(kCmdNameGetset, getsetptr));
////Append
CmdInfo* appendptr = new CmdInfo(kCmdNameAppend, 3, kCmdFlagsWrite | kCmdFlagsKv);
cmd_infos.insert(std::pair<std::string, CmdInfo*>(kCmdNameAppend, appendptr));
////Mget
CmdInfo* mgetptr = new CmdInfo(kCmdNameMget, -2, kCmdFlagsRead | kCmdFlagsKv);
cmd_infos.insert(std::pair<std::string, CmdInfo*>(kCmdNameMget, mgetptr));
////Keys
CmdInfo* keysptr = new CmdInfo(kCmdNameKeys, 2, kCmdFlagsRead | kCmdFlagsKv);
cmd_infos.insert(std::pair<std::string, CmdInfo*>(kCmdNameKeys, keysptr));
////Setnx
CmdInfo* setnxptr = new CmdInfo(kCmdNameSetnx, 3, kCmdFlagsWrite | kCmdFlagsKv);
cmd_infos.insert(std::pair<std::string, CmdInfo*>(kCmdNameSetnx, setnxptr));
////Setex
CmdInfo* setexptr = new CmdInfo(kCmdNameSetex, 4, kCmdFlagsWrite | kCmdFlagsKv);
cmd_infos.insert(std::pair<std::string, CmdInfo*>(kCmdNameSetex, setexptr));
////MSet
CmdInfo* msetptr = new CmdInfo(kCmdNameMset, -3, kCmdFlagsWrite | kCmdFlagsKv);
cmd_infos.insert(std::pair<std::string, CmdInfo*>(kCmdNameMset, msetptr));
////MSetnx
CmdInfo* msetnxptr = new CmdInfo(kCmdNameMsetnx, -3, kCmdFlagsWrite | kCmdFlagsKv);
cmd_infos.insert(std::pair<std::string, CmdInfo*>(kCmdNameMsetnx, msetnxptr));
////Getrange
CmdInfo* getrangeptr = new CmdInfo(kCmdNameGetrange, 4, kCmdFlagsRead | kCmdFlagsKv);
cmd_infos.insert(std::pair<std::string, CmdInfo*>(kCmdNameGetrange, getrangeptr));
////Setrange
CmdInfo* setrangeptr = new CmdInfo(kCmdNameSetrange, 4, kCmdFlagsWrite | kCmdFlagsKv);
cmd_infos.insert(std::pair<std::string, CmdInfo*>(kCmdNameSetrange, setrangeptr));
////Strlen
CmdInfo* strlenptr = new CmdInfo(kCmdNameStrlen, 2, kCmdFlagsRead | kCmdFlagsKv);
cmd_infos.insert(std::pair<std::string, CmdInfo*>(kCmdNameStrlen, strlenptr));
////Exists
CmdInfo* existsptr = new CmdInfo(kCmdNameExists, -2, kCmdFlagsRead | kCmdFlagsKv);
cmd_infos.insert(std::pair<std::string, CmdInfo*>(kCmdNameExists, existsptr));
////Expire
CmdInfo* expireptr = new CmdInfo(kCmdNameExpire, 3, kCmdFlagsWrite | kCmdFlagsKv);
cmd_infos.insert(std::pair<std::string, CmdInfo*>(kCmdNameExpire, expireptr));
////Pexpire
CmdInfo* pexpireptr = new CmdInfo(kCmdNamePexpire, 3, kCmdFlagsWrite | kCmdFlagsKv);
cmd_infos.insert(std::pair<std::string, CmdInfo*>(kCmdNamePexpire, pexpireptr));
////Expireat
CmdInfo* expireatptr = new CmdInfo(kCmdNameExpireat, 3, kCmdFlagsWrite | kCmdFlagsKv);
cmd_infos.insert(std::pair<std::string, CmdInfo*>(kCmdNameExpireat, expireatptr));
////Pexpireat
CmdInfo* pexpireatptr = new CmdInfo(kCmdNamePexpireat, 3, kCmdFlagsWrite | kCmdFlagsKv);
cmd_infos.insert(std::pair<std::string, CmdInfo*>(kCmdNamePexpireat, pexpireatptr));
////Ttl
CmdInfo* ttlptr = new CmdInfo(kCmdNameTtl, 2, kCmdFlagsRead | kCmdFlagsKv);
cmd_infos.insert(std::pair<std::string, CmdInfo*>(kCmdNameTtl, ttlptr));
////Pttl
CmdInfo* pttlptr = new CmdInfo(kCmdNameTtl, 2, kCmdFlagsRead | kCmdFlagsKv);
cmd_infos.insert(std::pair<std::string, CmdInfo*>(kCmdNamePttl, pttlptr));
////Persist
CmdInfo* persistptr = new CmdInfo(kCmdNamePersist, 2, kCmdFlagsWrite | kCmdFlagsKv);
cmd_infos.insert(std::pair<std::string, CmdInfo*>(kCmdNamePersist, persistptr));
////Persist
CmdInfo* typeptr = new CmdInfo(kCmdNameType, 2, kCmdFlagsRead | kCmdFlagsKv);
cmd_infos.insert(std::pair<std::string, CmdInfo*>(kCmdNameType, typeptr));
////Scan
CmdInfo* scanptr = new CmdInfo(kCmdNameScan, -2, kCmdFlagsRead | kCmdFlagsKv);
cmd_infos.insert(std::pair<std::string, CmdInfo*>(kCmdNameScan, scanptr));
//////////////////////////////Hash////////////////////////
////HDel
CmdInfo* hdelptr = new CmdInfo(kCmdNameHDel, -3, kCmdFlagsWrite | kCmdFlagsKv);
cmd_infos.insert(std::pair<std::string, CmdInfo*>(kCmdNameHDel, hdelptr));
////HSet
CmdInfo* hsetptr = new CmdInfo(kCmdNameHSet, 4, kCmdFlagsWrite | kCmdFlagsKv);
cmd_infos.insert(std::pair<std::string, CmdInfo*>(kCmdNameHSet, hsetptr));
////HGet
CmdInfo* hgetptr = new CmdInfo(kCmdNameHGet, 3, kCmdFlagsRead | kCmdFlagsKv);
cmd_infos.insert(std::pair<std::string, CmdInfo*>(kCmdNameHGet, hgetptr));
////HGetall
CmdInfo* hgetallptr = new CmdInfo(kCmdNameHGetall, 2, kCmdFlagsRead | kCmdFlagsKv);
cmd_infos.insert(std::pair<std::string, CmdInfo*>(kCmdNameHGetall, hgetallptr));
////HExists
CmdInfo* hexistsptr = new CmdInfo(kCmdNameHExists, 3, kCmdFlagsRead | kCmdFlagsKv);
cmd_infos.insert(std::pair<std::string, CmdInfo*>(kCmdNameHExists, hexistsptr));
////HIncrby
CmdInfo* hincrbyptr = new CmdInfo(kCmdNameHIncrby, 4, kCmdFlagsWrite | kCmdFlagsKv);
cmd_infos.insert(std::pair<std::string, CmdInfo*>(kCmdNameHIncrby, hincrbyptr));
////HIncrbyfloat
CmdInfo* hincrbyfloatptr = new CmdInfo(kCmdNameHIncrbyfloat, 4, kCmdFlagsWrite | kCmdFlagsKv);
cmd_infos.insert(std::pair<std::string, CmdInfo*>(kCmdNameHIncrbyfloat, hincrbyfloatptr));
////HKeys
CmdInfo* hkeysptr = new CmdInfo(kCmdNameHKeys, 2, kCmdFlagsRead | kCmdFlagsKv);
cmd_infos.insert(std::pair<std::string, CmdInfo*>(kCmdNameHKeys, hkeysptr));
///HLen
CmdInfo* hlenptr = new CmdInfo(kCmdNameHLen, 2, kCmdFlagsRead | kCmdFlagsKv);
cmd_infos.insert(std::pair<std::string, CmdInfo*>(kCmdNameHLen, hlenptr));
///HMget
CmdInfo* hmgetptr = new CmdInfo(kCmdNameHMget, -3, kCmdFlagsRead | kCmdFlagsKv);
cmd_infos.insert(std::pair<std::string, CmdInfo*>(kCmdNameHMget, hmgetptr));
///HMset
CmdInfo* hmsetptr = new CmdInfo(kCmdNameHMset, -4, kCmdFlagsWrite | kCmdFlagsKv);
cmd_infos.insert(std::pair<std::string, CmdInfo*>(kCmdNameHMset, hmsetptr));
///HMset
CmdInfo* hsetnxptr = new CmdInfo(kCmdNameHSetnx, 4, kCmdFlagsWrite | kCmdFlagsKv);
cmd_infos.insert(std::pair<std::string, CmdInfo*>(kCmdNameHSetnx, hsetnxptr));
///HStrlen
CmdInfo* hstrlenptr = new CmdInfo(kCmdNameHStrlen, 3, kCmdFlagsRead | kCmdFlagsKv);
cmd_infos.insert(std::pair<std::string, CmdInfo*>(kCmdNameHStrlen, hstrlenptr));
///HVals
CmdInfo* hvalsptr = new CmdInfo(kCmdNameHVals, 2, kCmdFlagsRead | kCmdFlagsKv);
cmd_infos.insert(std::pair<std::string, CmdInfo*>(kCmdNameHVals, hvalsptr));
///HScan
CmdInfo* hscanptr = new CmdInfo(kCmdNameHScan, -3, kCmdFlagsRead | kCmdFlagsKv);
cmd_infos.insert(std::pair<std::string, CmdInfo*>(kCmdNameHScan, hscanptr));
////////////////////////////////List////////////////////
////LIndex
CmdInfo* lindexptr = new CmdInfo(kCmdNameLIndex, 3, kCmdFlagsRead | kCmdFlagsList);
cmd_infos.insert(std::pair<std::string, CmdInfo*>(kCmdNameLIndex, lindexptr));
CmdInfo* linsertptr = new CmdInfo(kCmdNameLInsert, 5, kCmdFlagsWrite | kCmdFlagsList);
cmd_infos.insert(std::pair<std::string, CmdInfo*>(kCmdNameLInsert, linsertptr));
CmdInfo* llenptr = new CmdInfo(kCmdNameLLen, 2, kCmdFlagsRead | kCmdFlagsList);
cmd_infos.insert(std::pair<std::string, CmdInfo*>(kCmdNameLLen, llenptr));
CmdInfo* lpopptr = new CmdInfo(kCmdNameLPop, 2, kCmdFlagsWrite | kCmdFlagsList);
cmd_infos.insert(std::pair<std::string, CmdInfo*>(kCmdNameLPop, lpopptr));
CmdInfo* lpushptr = new CmdInfo(kCmdNameLPush, -3, kCmdFlagsWrite | kCmdFlagsList);
cmd_infos.insert(std::pair<std::string, CmdInfo*>(kCmdNameLPush, lpushptr));
CmdInfo* lpushxptr = new CmdInfo(kCmdNameLPushx, 3, kCmdFlagsWrite | kCmdFlagsList);
cmd_infos.insert(std::pair<std::string, CmdInfo*>(kCmdNameLPushx, lpushxptr));
CmdInfo* lrangeptr = new CmdInfo(kCmdNameLRange, 4, kCmdFlagsRead | kCmdFlagsList);
cmd_infos.insert(std::pair<std::string, CmdInfo*>(kCmdNameLRange, lrangeptr));
CmdInfo* lremptr = new CmdInfo(kCmdNameLRem, 4, kCmdFlagsWrite | kCmdFlagsList);
cmd_infos.insert(std::pair<std::string, CmdInfo*>(kCmdNameLRem, lremptr));
CmdInfo* lsetptr = new CmdInfo(kCmdNameLSet, 4, kCmdFlagsWrite | kCmdFlagsList);
cmd_infos.insert(std::pair<std::string, CmdInfo*>(kCmdNameLSet, lsetptr));
CmdInfo* ltrimptr = new CmdInfo(kCmdNameLTrim, 4, kCmdFlagsWrite | kCmdFlagsList);
cmd_infos.insert(std::pair<std::string, CmdInfo*>(kCmdNameLTrim, ltrimptr));
CmdInfo* rpopptr = new CmdInfo(kCmdNameRPop, 2, kCmdFlagsWrite | kCmdFlagsList);
cmd_infos.insert(std::pair<std::string, CmdInfo*>(kCmdNameRPop, rpopptr));
CmdInfo* rpoplpushptr = new CmdInfo(kCmdNameRPopLPush, 3, kCmdFlagsWrite | kCmdFlagsList);
cmd_infos.insert(std::pair<std::string, CmdInfo*>(kCmdNameRPopLPush, rpoplpushptr));
CmdInfo* rpushptr = new CmdInfo(kCmdNameRPush, -3, kCmdFlagsWrite | kCmdFlagsList);
cmd_infos.insert(std::pair<std::string, CmdInfo*>(kCmdNameRPush, rpushptr));
CmdInfo* rpushxptr = new CmdInfo(kCmdNameRPushx, 3, kCmdFlagsWrite | kCmdFlagsList);
cmd_infos.insert(std::pair<std::string, CmdInfo*>(kCmdNameRPushx, rpushxptr));
///////////////////////////Zset/////////////////////
////ZAdd
CmdInfo* zaddptr = new CmdInfo(kCmdNameZAdd, -4, kCmdFlagsWrite | kCmdFlagsList);
cmd_infos.insert(std::pair<std::string, CmdInfo*>(kCmdNameZAdd, zaddptr));
////ZCard
CmdInfo* zcardptr = new CmdInfo(kCmdNameZCard, 2, kCmdFlagsWrite | kCmdFlagsList);
cmd_infos.insert(std::pair<std::string, CmdInfo*>(kCmdNameZCard, zcardptr));
////ZScan
CmdInfo* zscanptr = new CmdInfo(kCmdNameZScan, -3, kCmdFlagsRead | kCmdFlagsList);
cmd_infos.insert(std::pair<std::string, CmdInfo*>(kCmdNameZScan, zscanptr));
////ZIncrby
CmdInfo* zincrbyptr = new CmdInfo(kCmdNameZIncrby, 4, kCmdFlagsWrite | kCmdFlagsList);
cmd_infos.insert(std::pair<std::string, CmdInfo*>(kCmdNameZIncrby, zincrbyptr));
////ZRange
CmdInfo* zrangeptr = new CmdInfo(kCmdNameZRange, -4, kCmdFlagsRead | kCmdFlagsList);
cmd_infos.insert(std::pair<std::string, CmdInfo*>(kCmdNameZRange, zrangeptr));
////ZRevrange
CmdInfo* zrevrangeptr = new CmdInfo(kCmdNameZRevrange, -4, kCmdFlagsRead | kCmdFlagsList);
cmd_infos.insert(std::pair<std::string, CmdInfo*>(kCmdNameZRevrange, zrevrangeptr));
////ZRangebyscore
CmdInfo* zrangebyscoreptr = new CmdInfo(kCmdNameZRangebyscore, -4, kCmdFlagsRead | kCmdFlagsList);
cmd_infos.insert(std::pair<std::string, CmdInfo*>(kCmdNameZRangebyscore, zrangebyscoreptr));
////ZRevrangebyscore
CmdInfo* zrevrangebyscoreptr = new CmdInfo(kCmdNameZRevrangebyscore, -4, kCmdFlagsRead | kCmdFlagsList);
cmd_infos.insert(std::pair<std::string, CmdInfo*>(kCmdNameZRevrangebyscore, zrevrangebyscoreptr));
////ZCount
CmdInfo* zcountptr = new CmdInfo(kCmdNameZCount, 4, kCmdFlagsRead | kCmdFlagsList);
cmd_infos.insert(std::pair<std::string, CmdInfo*>(kCmdNameZCount, zcountptr));
////ZRem
CmdInfo* zremptr = new CmdInfo(kCmdNameZRem, -3, kCmdFlagsWrite | kCmdFlagsList);
cmd_infos.insert(std::pair<std::string, CmdInfo*>(kCmdNameZRem, zremptr));
////ZUnionstore
CmdInfo* zunionstoreptr = new CmdInfo(kCmdNameZUnionstore, -4, kCmdFlagsWrite | kCmdFlagsList);
cmd_infos.insert(std::pair<std::string, CmdInfo*>(kCmdNameZUnionstore, zunionstoreptr));
////ZInterstore
CmdInfo* zinterstoreptr = new CmdInfo(kCmdNameZInterstore, -4, kCmdFlagsWrite | kCmdFlagsList);
cmd_infos.insert(std::pair<std::string, CmdInfo*>(kCmdNameZInterstore, zinterstoreptr));
////ZRank
CmdInfo* zrankptr = new CmdInfo(kCmdNameZRank, 3, kCmdFlagsRead | kCmdFlagsList);
cmd_infos.insert(std::pair<std::string, CmdInfo*>(kCmdNameZRank, zrankptr));
////ZRevrank
CmdInfo* zrevrankptr = new CmdInfo(kCmdNameZRevrank, 3, kCmdFlagsRead | kCmdFlagsList);
cmd_infos.insert(std::pair<std::string, CmdInfo*>(kCmdNameZRevrank, zrevrankptr));
////ZScore
CmdInfo* zscoreptr = new CmdInfo(kCmdNameZScore, 3, kCmdFlagsRead | kCmdFlagsList);
cmd_infos.insert(std::pair<std::string, CmdInfo*>(kCmdNameZScore, zscoreptr));
////ZRangebylex
CmdInfo* zrangebylexptr = new CmdInfo(kCmdNameZRangebylex, -4, kCmdFlagsRead | kCmdFlagsList);
cmd_infos.insert(std::pair<std::string, CmdInfo*>(kCmdNameZRangebylex, zrangebylexptr));
////ZRevrangebylex
CmdInfo* zrevrangebylexptr = new CmdInfo(kCmdNameZRevrangebylex, -4, kCmdFlagsRead | kCmdFlagsList);
cmd_infos.insert(std::pair<std::string, CmdInfo*>(kCmdNameZRevrangebylex, zrevrangebylexptr));
////ZLexcount
CmdInfo* zlexcountptr = new CmdInfo(kCmdNameZLexcount, 4, kCmdFlagsRead | kCmdFlagsList);
cmd_infos.insert(std::pair<std::string, CmdInfo*>(kCmdNameZLexcount, zlexcountptr));
////ZRemrangebyrank
CmdInfo* zremrangebyrankptr = new CmdInfo(kCmdNameZRemrangebyrank, 4, kCmdFlagsWrite | kCmdFlagsList);
cmd_infos.insert(std::pair<std::string, CmdInfo*>(kCmdNameZRemrangebyrank, zremrangebyrankptr));
////ZRemrangebyscore
CmdInfo* zremrangebyscoreptr = new CmdInfo(kCmdNameZRemrangebyscore, 4, kCmdFlagsWrite | kCmdFlagsList);
cmd_infos.insert(std::pair<std::string, CmdInfo*>(kCmdNameZRemrangebyscore, zremrangebyscoreptr));
////ZRemrangebylex
CmdInfo* zremrangebylexptr = new CmdInfo(kCmdNameZRemrangebylex, 4, kCmdFlagsWrite | kCmdFlagsList);
cmd_infos.insert(std::pair<std::string, CmdInfo*>(kCmdNameZRemrangebylex, zremrangebylexptr));
//////////////////////////Set///////////////////////////
////SAdd
CmdInfo* saddptr = new CmdInfo(kCmdNameSAdd, -3, kCmdFlagsWrite | kCmdFlagsList);
cmd_infos.insert(std::pair<std::string, CmdInfo*>(kCmdNameSAdd, saddptr));
////SPop
CmdInfo* spopptr = new CmdInfo(kCmdNameSPop, 2, kCmdFlagsWrite | kCmdFlagsList);
cmd_infos.insert(std::pair<std::string, CmdInfo*>(kCmdNameSPop, spopptr));
////SCard
CmdInfo* scardptr = new CmdInfo(kCmdNameSCard, 2, kCmdFlagsRead | kCmdFlagsList);
cmd_infos.insert(std::pair<std::string, CmdInfo*>(kCmdNameSCard, scardptr));
////SMembers
CmdInfo* smembersptr = new CmdInfo(kCmdNameSMembers, 2, kCmdFlagsRead | kCmdFlagsList);
cmd_infos.insert(std::pair<std::string, CmdInfo*>(kCmdNameSMembers, smembersptr));
////SMembers
CmdInfo* sscanptr = new CmdInfo(kCmdNameSScan, -3, kCmdFlagsRead | kCmdFlagsList);
cmd_infos.insert(std::pair<std::string, CmdInfo*>(kCmdNameSScan, sscanptr));
////SRem
CmdInfo* sremptr = new CmdInfo(kCmdNameSRem, -3, kCmdFlagsWrite | kCmdFlagsList);
cmd_infos.insert(std::pair<std::string, CmdInfo*>(kCmdNameSRem, sremptr));
////SUnion
CmdInfo* sunionptr = new CmdInfo(kCmdNameSUnion, -2, kCmdFlagsRead | kCmdFlagsList);
cmd_infos.insert(std::pair<std::string, CmdInfo*>(kCmdNameSUnion, sunionptr));
////SUnion
CmdInfo* sunionstoreptr = new CmdInfo(kCmdNameSUnionstore, -3, kCmdFlagsWrite | kCmdFlagsList);
cmd_infos.insert(std::pair<std::string, CmdInfo*>(kCmdNameSUnionstore, sunionstoreptr));
////SInter
CmdInfo* sinterptr = new CmdInfo(kCmdNameSInter, -2, kCmdFlagsRead | kCmdFlagsList);
cmd_infos.insert(std::pair<std::string, CmdInfo*>(kCmdNameSInter, sinterptr));
////SInterstore
CmdInfo* sinterstoreptr = new CmdInfo(kCmdNameSInterstore, -3, kCmdFlagsWrite | kCmdFlagsList);
cmd_infos.insert(std::pair<std::string, CmdInfo*>(kCmdNameSInterstore, sinterstoreptr));
////SIsmember
CmdInfo* sismemberptr = new CmdInfo(kCmdNameSIsmember, 3, kCmdFlagsRead | kCmdFlagsList);
cmd_infos.insert(std::pair<std::string, CmdInfo*>(kCmdNameSIsmember, sismemberptr));
////SDiff
CmdInfo* sdiffptr = new CmdInfo(kCmdNameSDiff, -2, kCmdFlagsRead | kCmdFlagsList);
cmd_infos.insert(std::pair<std::string, CmdInfo*>(kCmdNameSDiff, sdiffptr));
////SDiffstore
CmdInfo* sdiffstoreptr = new CmdInfo(kCmdNameSDiffstore, -3, kCmdFlagsWrite | kCmdFlagsList);
cmd_infos.insert(std::pair<std::string, CmdInfo*>(kCmdNameSDiffstore, sdiffstoreptr));
////SMove
CmdInfo* smoveptr = new CmdInfo(kCmdNameSMove, 4, kCmdFlagsWrite | kCmdFlagsList);
cmd_infos.insert(std::pair<std::string, CmdInfo*>(kCmdNameSMove, smoveptr));
////SRandmember
CmdInfo* srandmemberptr = new CmdInfo(kCmdNameSRandmember, -2, kCmdFlagsRead | kCmdFlagsList);
cmd_infos.insert(std::pair<std::string, CmdInfo*>(kCmdNameSRandmember, srandmemberptr));
/////////////////////////BitMap//////////////////////////
////BitSet
CmdInfo* bitsetptr = new CmdInfo(kCmdNameBitSet, 4, kCmdFlagsWrite | kCmdFlagsBit);
cmd_infos.insert(std::pair<std::string, CmdInfo*>(kCmdNameBitSet, bitsetptr)).second;
////BitGet
CmdInfo* bitgetptr = new CmdInfo(kCmdNameBitGet, 3, kCmdFlagsRead | kCmdFlagsBit);
cmd_infos.insert(std::pair<std::string, CmdInfo*>(kCmdNameBitGet, bitgetptr)).second;
////BitPos
CmdInfo* bitposptr = new CmdInfo(kCmdNameBitPos, -3, kCmdFlagsRead | kCmdFlagsBit);
cmd_infos.insert(std::pair<std::string, CmdInfo*>(kCmdNameBitPos, bitposptr)).second;
////BitOp
CmdInfo* bitopptr = new CmdInfo(kCmdNameBitOp, -3, kCmdFlagsWrite | kCmdFlagsBit);
cmd_infos.insert(std::pair<std::string, CmdInfo*>(kCmdNameBitOp, bitopptr)).second;
////BitCount
CmdInfo* bitcountptr = new CmdInfo(kCmdNameBitCount, -2, kCmdFlagsRead | kCmdFlagsBit);
cmd_infos.insert(std::pair<std::string, CmdInfo*>(kCmdNameBitCount, bitcountptr)).second;
}
Pika命令表
Cmd是所有命令的基类，不同命令执行的时候入口是一样的，通过重载DoInitial和Do函数来实现不同的功能.
class Cmd {
public:
Cmd() {}
virtual ~Cmd() {}
virtual void Do() = 0;
void Initial(PikaCmdArgsType &argvs, const CmdInfo* const ptr_info) {
res_.clear(); // Clear res content
Clear(); // Clear cmd, Derived class can has own implement
DoInitial(argvs, ptr_info);
};
CmdRes& res() {
return res_;
}
protected:
CmdRes res_;
private:
virtual void DoInitial(PikaCmdArgsType &argvs, const CmdInfo* const ptr_info) = 0;
virtual void Clear() {};
Cmd(const Cmd&);
Cmd& operator=(const Cmd&);
};
每个线程在构造函数中都会构造命令表，命令属性表只有一份，但是命令表是每个线程都有一份，初始化如下：
void InitCmdTable(std::unordered_map<std::string, Cmd*> *cmd_table) {
//////////////////////////////////////////////////Admin////////////////////////////////////
////Slaveof
Cmd* slaveofptr = new SlaveofCmd();
cmd_table->insert(std::pair<std::string, Cmd*>(kCmdNameSlaveof, slaveofptr));
////Trysync
Cmd* trysyncptr = new TrysyncCmd();
cmd_table->insert(std::pair<std::string, Cmd*>(kCmdNameTrysync, trysyncptr));
Cmd* authptr = new AuthCmd();
cmd_table->insert(std::pair<std::string, Cmd*>(kCmdNameAuth, authptr));
Cmd* bgsaveptr = new BgsaveCmd();
cmd_table->insert(std::pair<std::string, Cmd*>(kCmdNameBgsave, bgsaveptr));
Cmd* bgsaveoffptr = new BgsaveoffCmd();
cmd_table->insert(std::pair<std::string, Cmd*>(kCmdNameBgsaveoff, bgsaveoffptr));
Cmd* compactptr = new CompactCmd();
cmd_table->insert(std::pair<std::string, Cmd*>(kCmdNameCompact, compactptr));
Cmd* purgelogptr = new PurgelogstoCmd();
cmd_table->insert(std::pair<std::string, Cmd*>(kCmdNamePurgelogsto, purgelogptr));
Cmd* pingptr = new PingCmd();
cmd_table->insert(std::pair<std::string, Cmd*>(kCmdNamePing, pingptr));
Cmd* selectptr = new SelectCmd();
cmd_table->insert(std::pair<std::string, Cmd*>(kCmdNameSelect, selectptr));
Cmd* flushallptr = new FlushallCmd();
cmd_table->insert(std::pair<std::string, Cmd*>(kCmdNameFlushall, flushallptr));
Cmd* readonlyptr = new ReadonlyCmd();
cmd_table->insert(std::pair<std::string, Cmd*>(kCmdNameReadonly, readonlyptr));
Cmd* clientptr = new ClientCmd();
cmd_table->insert(std::pair<std::string, Cmd*>(kCmdNameClient, clientptr));
Cmd* shutdownptr = new ShutdownCmd();
cmd_table->insert(std::pair<std::string, Cmd*>(kCmdNameShutdown, shutdownptr));
Cmd* infoptr = new InfoCmd();
cmd_table->insert(std::pair<std::string, Cmd*>(kCmdNameInfo, infoptr));
Cmd* configptr = new ConfigCmd();
cmd_table->insert(std::pair<std::string, Cmd*>(kCmdNameConfig, configptr));
Cmd* monitorptr = new MonitorCmd();
cmd_table->insert(std::pair<std::string, Cmd*>(kCmdNameMonitor, monitorptr));
//////////////////////////////////////////////Kv/////////////////////////////////////////////
////SetCmd
Cmd* setptr = new SetCmd();
cmd_table->insert(std::pair<std::string, Cmd*>(kCmdNameSet, setptr));
////GetCmd
Cmd* getptr = new GetCmd();
cmd_table->insert(std::pair<std::string, Cmd*>(kCmdNameGet, getptr));
////DelCmd
Cmd* delptr = new DelCmd();
cmd_table->insert(std::pair<std::string, Cmd*>(kCmdNameDel, delptr));
////IncrCmd
Cmd* incrptr = new IncrCmd();
cmd_table->insert(std::pair<std::string, Cmd*>(kCmdNameIncr, incrptr));
////IncrbyCmd
Cmd* incrbyptr = new IncrbyCmd();
cmd_table->insert(std::pair<std::string, Cmd*>(kCmdNameIncrby, incrbyptr));
////IncrbyfloatCmd
Cmd* incrbyfloatptr = new IncrbyfloatCmd();
cmd_table->insert(std::pair<std::string, Cmd*>(kCmdNameIncrbyfloat, incrbyfloatptr));
////DecrCmd
Cmd* decrptr = new DecrCmd();
cmd_table->insert(std::pair<std::string, Cmd*>(kCmdNameDecr, decrptr));
////DecrbyCmd
Cmd* decrbyptr = new DecrbyCmd();
cmd_table->insert(std::pair<std::string, Cmd*>(kCmdNameDecrby, decrbyptr));
////GetsetCmd
Cmd* getsetptr = new GetsetCmd();
cmd_table->insert(std::pair<std::string, Cmd*>(kCmdNameGetset, getsetptr));
////AppendCmd
Cmd* appendptr = new AppendCmd();
cmd_table->insert(std::pair<std::string, Cmd*>(kCmdNameAppend, appendptr));
////MgetCmd
Cmd* mgetptr = new MgetCmd();
cmd_table->insert(std::pair<std::string, Cmd*>(kCmdNameMget, mgetptr));
////KeysCmd
Cmd* keysptr = new KeysCmd();
cmd_table->insert(std::pair<std::string, Cmd*>(kCmdNameKeys, keysptr));
////SetnxCmd
Cmd* setnxptr = new SetnxCmd();
cmd_table->insert(std::pair<std::string, Cmd*>(kCmdNameSetnx, setnxptr));
////SetexCmd
Cmd* setexptr = new SetexCmd();
cmd_table->insert(std::pair<std::string, Cmd*>(kCmdNameSetex, setexptr));
////MSetCmd
Cmd* msetptr = new MsetCmd();
cmd_table->insert(std::pair<std::string, Cmd*>(kCmdNameMset, msetptr));
////MSetCmd
Cmd* msetnxptr = new MsetnxCmd();
cmd_table->insert(std::pair<std::string, Cmd*>(kCmdNameMsetnx, msetnxptr));
////GetrangeCmd
Cmd* getrangeptr = new GetrangeCmd();
cmd_table->insert(std::pair<std::string, Cmd*>(kCmdNameGetrange, getrangeptr));
////SetrangeCmd
Cmd* setrangeptr = new SetrangeCmd();
cmd_table->insert(std::pair<std::string, Cmd*>(kCmdNameSetrange, setrangeptr));
////StrlenCmd
Cmd* strlenptr = new StrlenCmd();
cmd_table->insert(std::pair<std::string, Cmd*>(kCmdNameStrlen, strlenptr));
////ExistsCmd
Cmd* existsptr = new ExistsCmd();
cmd_table->insert(std::pair<std::string, Cmd*>(kCmdNameExists, existsptr));
////ExpireCmd
Cmd* expireptr = new ExpireCmd();
cmd_table->insert(std::pair<std::string, Cmd*>(kCmdNameExpire, expireptr));
////PexpireCmd
Cmd* pexpireptr = new PexpireCmd();
cmd_table->insert(std::pair<std::string, Cmd*>(kCmdNamePexpire, pexpireptr));
////ExpireatCmd
Cmd* expireatptr = new ExpireatCmd();
cmd_table->insert(std::pair<std::string, Cmd*>(kCmdNameExpireat, expireatptr));
////PexpireatCmd
Cmd* pexpireatptr = new PexpireatCmd();
cmd_table->insert(std::pair<std::string, Cmd*>(kCmdNamePexpireat, pexpireatptr));
////TtlCmd
Cmd* ttlptr = new TtlCmd();
cmd_table->insert(std::pair<std::string, Cmd*>(kCmdNameTtl, ttlptr));
////PttlCmd
Cmd* pttlptr = new PttlCmd();
cmd_table->insert(std::pair<std::string, Cmd*>(kCmdNamePttl, pttlptr));
////PersistCmd
Cmd* persistptr = new PersistCmd();
cmd_table->insert(std::pair<std::string, Cmd*>(kCmdNamePersist, persistptr));
////TypeCmd
Cmd* typeptr = new TypeCmd();
cmd_table->insert(std::pair<std::string, Cmd*>(kCmdNameType, typeptr));
////ScanCmd
Cmd* scanptr = new ScanCmd();
cmd_table->insert(std::pair<std::string, Cmd*>(kCmdNameScan, scanptr));
///////////////////////////////////////Hash///////////////////////////////////////////
////HDelCmd
Cmd* hdelptr = new HDelCmd();
cmd_table->insert(std::pair<std::string, Cmd*>(kCmdNameHDel, hdelptr));
////HSetCmd
Cmd* hsetptr = new HSetCmd();
cmd_table->insert(std::pair<std::string, Cmd*>(kCmdNameHSet, hsetptr));
////HGetCmd
Cmd* hgetptr = new HGetCmd();
cmd_table->insert(std::pair<std::string, Cmd*>(kCmdNameHGet, hgetptr));
////HGetallCmd
Cmd* hgetallptr = new HGetallCmd();
cmd_table->insert(std::pair<std::string, Cmd*>(kCmdNameHGetall, hgetallptr));
////HExistsCmd
Cmd* hexistsptr = new HExistsCmd();
cmd_table->insert(std::pair<std::string, Cmd*>(kCmdNameHExists, hexistsptr));
////HIncrbyCmd
Cmd* hincrbyptr = new HIncrbyCmd();
cmd_table->insert(std::pair<std::string, Cmd*>(kCmdNameHIncrby, hincrbyptr));
////HIncrbyfloatCmd
Cmd* hincrbyfloatptr = new HIncrbyfloatCmd();
cmd_table->insert(std::pair<std::string, Cmd*>(kCmdNameHIncrbyfloat, hincrbyfloatptr));
////HKeysCmd
Cmd* hkeysptr = new HKeysCmd();
cmd_table->insert(std::pair<std::string, Cmd*>(kCmdNameHKeys, hkeysptr));
////HLenCmd
Cmd* hlenptr = new HLenCmd();
cmd_table->insert(std::pair<std::string, Cmd*>(kCmdNameHLen, hlenptr));
////HMgetCmd
Cmd* hmgetptr = new HMgetCmd();
cmd_table->insert(std::pair<std::string, Cmd*>(kCmdNameHMget, hmgetptr));
////HMsetCmd
Cmd* hmsetptr = new HMsetCmd();
cmd_table->insert(std::pair<std::string, Cmd*>(kCmdNameHMset, hmsetptr));
////HSetnxCmd
Cmd* hsetnxptr = new HSetnxCmd();
cmd_table->insert(std::pair<std::string, Cmd*>(kCmdNameHSetnx, hsetnxptr));
////HStrlenCmd
Cmd* hstrlenptr = new HStrlenCmd();
cmd_table->insert(std::pair<std::string, Cmd*>(kCmdNameHStrlen, hstrlenptr));
////HValsCmd
Cmd* hvalsptr = new HValsCmd();
cmd_table->insert(std::pair<std::string, Cmd*>(kCmdNameHVals, hvalsptr));
////HScanCmd
Cmd* hscanptr = new HScanCmd();
cmd_table->insert(std::pair<std::string, Cmd*>(kCmdNameHScan, hscanptr));
//List
Cmd* lindexptr = new LIndexCmd();
cmd_table->insert(std::pair<std::string, Cmd*>(kCmdNameLIndex, lindexptr));
Cmd* linsertptr = new LInsertCmd();
cmd_table->insert(std::pair<std::string, Cmd*>(kCmdNameLInsert, linsertptr));
Cmd* llenptr = new LLenCmd();
cmd_table->insert(std::pair<std::string, Cmd*>(kCmdNameLLen, llenptr));
Cmd* lpopptr = new LPopCmd();
cmd_table->insert(std::pair<std::string, Cmd*>(kCmdNameLPop, lpopptr));
Cmd* lpushptr = new LPushCmd();
cmd_table->insert(std::pair<std::string, Cmd*>(kCmdNameLPush, lpushptr));
Cmd* lpushxptr = new LPushxCmd();
cmd_table->insert(std::pair<std::string, Cmd*>(kCmdNameLPushx, lpushxptr));
Cmd* lrangeptr = new LRangeCmd();
cmd_table->insert(std::pair<std::string, Cmd*>(kCmdNameLRange, lrangeptr));
Cmd* lremptr = new LRemCmd();
cmd_table->insert(std::pair<std::string, Cmd*>(kCmdNameLRem, lremptr));
Cmd* lsetptr = new LSetCmd();
cmd_table->insert(std::pair<std::string, Cmd*>(kCmdNameLSet, lsetptr));
Cmd* ltrimptr = new LTrimCmd();
cmd_table->insert(std::pair<std::string, Cmd*>(kCmdNameLTrim, ltrimptr));
Cmd* rpopptr = new RPopCmd();
cmd_table->insert(std::pair<std::string, Cmd*>(kCmdNameRPop, rpopptr));
Cmd* rpoplpushptr = new RPopLPushCmd();
cmd_table->insert(std::pair<std::string, Cmd*>(kCmdNameRPopLPush, rpoplpushptr));
Cmd* rpushptr = new RPushCmd();
cmd_table->insert(std::pair<std::string, Cmd*>(kCmdNameRPush, rpushptr));
Cmd* rpushxptr = new RPushxCmd();
cmd_table->insert(std::pair<std::string, Cmd*>(kCmdNameRPushx, rpushxptr));
////////////////////////////////////////Zset////////////////////////////////////////////
////ZAddCmd
Cmd* zaddptr = new ZAddCmd();
cmd_table->insert(std::pair<std::string, Cmd*>(kCmdNameZAdd, zaddptr));
////ZCardCmd
Cmd* zcardptr = new ZCardCmd();
cmd_table->insert(std::pair<std::string, Cmd*>(kCmdNameZCard, zcardptr));
////ZScanCmd
Cmd* zscanptr = new ZScanCmd();
cmd_table->insert(std::pair<std::string, Cmd*>(kCmdNameZScan, zscanptr));
////ZIncrbyCmd
Cmd* zincrbyptr = new ZIncrbyCmd();
cmd_table->insert(std::pair<std::string, Cmd*>(kCmdNameZIncrby, zincrbyptr));
////ZRangeCmd
Cmd* zrangeptr = new ZRangeCmd();
cmd_table->insert(std::pair<std::string, Cmd*>(kCmdNameZRange, zrangeptr));
////ZRevrangeCmd
Cmd* zrevrangeptr = new ZRevrangeCmd();
cmd_table->insert(std::pair<std::string, Cmd*>(kCmdNameZRevrange, zrevrangeptr));
////ZRangebyscoreCmd
Cmd* zrangebyscoreptr = new ZRangebyscoreCmd();
cmd_table->insert(std::pair<std::string, Cmd*>(kCmdNameZRangebyscore, zrangebyscoreptr));
////ZRevrangebyscoreCmd
Cmd* zrevrangebyscoreptr = new ZRevrangebyscoreCmd();
cmd_table->insert(std::pair<std::string, Cmd*>(kCmdNameZRevrangebyscore, zrevrangebyscoreptr));
////ZCountCmd
Cmd* zcountptr = new ZCountCmd();
cmd_table->insert(std::pair<std::string, Cmd*>(kCmdNameZCount, zcountptr));
////ZRemCmd
Cmd* zremptr = new ZRemCmd();
cmd_table->insert(std::pair<std::string, Cmd*>(kCmdNameZRem, zremptr));
////ZUnionstoreCmd
Cmd* zunionstoreptr = new ZUnionstoreCmd();
cmd_table->insert(std::pair<std::string, Cmd*>(kCmdNameZUnionstore, zunionstoreptr));
////ZInterstoreCmd
Cmd* zinterstoreptr = new ZInterstoreCmd();
cmd_table->insert(std::pair<std::string, Cmd*>(kCmdNameZInterstore, zinterstoreptr));
////ZRankCmd
Cmd* zrankptr = new ZRankCmd();
cmd_table->insert(std::pair<std::string, Cmd*>(kCmdNameZRank, zrankptr));
////ZRevrankCmd
Cmd* zrevrankptr = new ZRevrankCmd();
cmd_table->insert(std::pair<std::string, Cmd*>(kCmdNameZRevrank, zrevrankptr));
////ZScoreCmd
Cmd* zscoreptr = new ZScoreCmd();
cmd_table->insert(std::pair<std::string, Cmd*>(kCmdNameZScore, zscoreptr));
////ZRangebylexCmd
Cmd* zrangebylexptr = new ZRangebylexCmd();
cmd_table->insert(std::pair<std::string, Cmd*>(kCmdNameZRangebylex, zrangebylexptr));
////ZRevrangebylexCmd
Cmd* zrevrangebylexptr = new ZRevrangebylexCmd();
cmd_table->insert(std::pair<std::string, Cmd*>(kCmdNameZRevrangebylex, zrevrangebylexptr));
////ZLexcountCmd
Cmd* zlexcountptr = new ZLexcountCmd();
cmd_table->insert(std::pair<std::string, Cmd*>(kCmdNameZLexcount, zlexcountptr));
////ZRemrangebyrankCmd
Cmd* zremrangebyrankptr = new ZRemrangebyrankCmd();
cmd_table->insert(std::pair<std::string, Cmd*>(kCmdNameZRemrangebyrank, zremrangebyrankptr));
////ZRemrangebyscoreCmd
Cmd* zremrangebyscoreptr = new ZRemrangebyscoreCmd();
cmd_table->insert(std::pair<std::string, Cmd*>(kCmdNameZRemrangebyscore, zremrangebyscoreptr));
////ZRemrangebylexCmd
Cmd* zremrangebylexptr = new ZRemrangebylexCmd();
cmd_table->insert(std::pair<std::string, Cmd*>(kCmdNameZRemrangebylex, zremrangebylexptr));
///////////////////////////////////////////////Set///////////////////////////////////////////////
////SAddCmd
Cmd* saddptr = new SAddCmd();
cmd_table->insert(std::pair<std::string, Cmd*>(kCmdNameSAdd, saddptr));
////SPopCmd
Cmd* spopptr = new SPopCmd();
cmd_table->insert(std::pair<std::string, Cmd*>(kCmdNameSPop, spopptr));
////SCardCmd
Cmd* scardptr = new SCardCmd();
cmd_table->insert(std::pair<std::string, Cmd*>(kCmdNameSCard, scardptr));
////SMembersCmd
Cmd* smembersptr = new SMembersCmd();
cmd_table->insert(std::pair<std::string, Cmd*>(kCmdNameSMembers, smembersptr));
////SScanCmd
Cmd* sscanptr = new SScanCmd();
cmd_table->insert(std::pair<std::string, Cmd*>(kCmdNameSScan, sscanptr));
////SScanCmd
Cmd* sremptr = new SRemCmd();
cmd_table->insert(std::pair<std::string, Cmd*>(kCmdNameSRem, sremptr));
////SUnionCmd
Cmd* sunionptr = new SUnionCmd();
cmd_table->insert(std::pair<std::string, Cmd*>(kCmdNameSUnion, sunionptr));
////SUnionstoreCmd
Cmd* sunionstoreptr = new SUnionstoreCmd();
cmd_table->insert(std::pair<std::string, Cmd*>(kCmdNameSUnionstore, sunionstoreptr));
////SInterCmd
Cmd* sinterptr = new SInterCmd();
cmd_table->insert(std::pair<std::string, Cmd*>(kCmdNameSInter, sinterptr));
////SInterstoreCmd
Cmd* sinterstoreptr = new SInterstoreCmd();
cmd_table->insert(std::pair<std::string, Cmd*>(kCmdNameSInterstore, sinterstoreptr));
////SIsmemberCmd
Cmd* sismemberptr = new SIsmemberCmd();
cmd_table->insert(std::pair<std::string, Cmd*>(kCmdNameSIsmember, sismemberptr));
////SDiffCmd
Cmd* sdiffptr = new SDiffCmd();
cmd_table->insert(std::pair<std::string, Cmd*>(kCmdNameSDiff, sdiffptr));
////SDiffstoreCmd
Cmd* sdiffstoreptr = new SDiffstoreCmd();
cmd_table->insert(std::pair<std::string, Cmd*>(kCmdNameSDiffstore, sdiffstoreptr));
////SMoveCmd
Cmd* smoveptr = new SMoveCmd();
cmd_table->insert(std::pair<std::string, Cmd*>(kCmdNameSMove, smoveptr));
////SRandmemberCmd
Cmd* srandmemberptr = new SRandmemberCmd();
cmd_table->insert(std::pair<std::string, Cmd*>(kCmdNameSRandmember, srandmemberptr));
////////////////////////////////////////BitMap//////////////////////////////////////
////bitsetCmd
Cmd* bitsetptr = new BitSetCmd();
cmd_table->insert(std::pair<std::string, Cmd*>(kCmdNameBitSet, bitsetptr));
////bitgetCmd
Cmd* bitgetptr = new BitGetCmd();
cmd_table->insert(std::pair<std::string, Cmd*>(kCmdNameBitGet, bitgetptr));
////bitcountCmd
Cmd* bitcountptr = new BitCountCmd();
cmd_table->insert(std::pair<std::string, Cmd*>(kCmdNameBitCount, bitcountptr));
////bitposCmd
Cmd* bitposptr = new BitPosCmd();
cmd_table->insert(std::pair<std::string, Cmd*>(kCmdNameBitPos, bitposptr));
////bitopCmd
Cmd* bitopptr = new BitOpCmd();
cmd_table->insert(std::pair<std::string, Cmd*>(kCmdNameBitOp, bitopptr));
}
枚举变量：
enum CmdFlagsMask {
//0000 0000 0000 0001
kCmdFlagsMaskRW = 1,
//0000 0000 0000 1110
kCmdFlagsMaskType = 14,
//0000 0000 0001 0000
kCmdFlagsMaskLocal = 16,
//0000 0000 0010 0000
kCmdFlagsMaskSuspend = 32,
//0000 0000 0100 0000
kCmdFlagsMaskPrior = 64,
//0000 0000 1000 0000
kCmdFlagsMaskAdminRequire = 128
};
enum CmdFlags {
//0000 0000 0000 0000
kCmdFlagsRead = 0, //default rw
//0000 0000 0000 0001
kCmdFlagsWrite = 1,
//0000 0000 0000 0000
kCmdFlagsAdmin = 0, //default type
//0000 0000 0000 0010
kCmdFlagsKv = 2,
//0000 0000 0000 0100
kCmdFlagsHash = 4,
//0000 0000 0000 0110
kCmdFlagsList = 6,
//0000 0000 0000 1000
kCmdFlagsSet = 8,
//0000 0000 0000 1010
kCmdFlagsZset = 10,
//0000 0000 0000 1100
kCmdFlagsBit = 12,
//0000 0000 0000 0000
kCmdFlagsNoLocal = 0, //default nolocal
//0000 0000 0001 0000
kCmdFlagsLocal = 16,
//0000 0000 0000 0000
kCmdFlagsNoSuspend = 0, //default nosuspend
//0000 0000 0010 0000
kCmdFlagsSuspend = 32,
//0000 0000 0000 0000
kCmdFlagsNoPrior = 0, //default noprior
//0000 0000 0100 0000
kCmdFlagsPrior = 64,
//0000 0000 0000 0000
kCmdFlagsNoAdminRequire = 0, //default no need admin
//0000 0000 1000 0000
kCmdFlagsAdminRequire = 128
};