phpredis中文手册
本文是参考《redis中文手册》,将示例代码用php来实现,注意php-redis与redis_cli的区别(主要是返回值类型和参数用法)。
目录(使用CTRL+F快速查找命令):
Key | String | Hash | List | Set |
---|---|---|---|---|
|
|
|
|
|
Sorted Set | Pub/Sub | Transaction | Connection | Server |
---|---|---|---|---|
|
|
|
|
|
phpredis是redis的php的一个扩展,效率是相当高有链表排序功能,对创建内存级的模块业务关系
很有用;以下是redis官方提供的命令使用技巧:
下载地址如下:
https://github.com/owlient/phpredis(支持redis 2.0.4)
Redis::__construct构造函数
$redis = new Redis();
connect, open 链接redis服务
参数
host: string,服务地址
port: int,端口号
timeout: float,链接时长 (可选, 默认为 0 ,不限链接时间)
注: 在redis.conf中也有时间,默认为300
pconnect, popen 不会主动关闭的链接
参考上面
setOption 设置redis模式
getOption 查看redis设置的模式
ping 查看连接状态
KEY相关操作
?
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
//DEL
# 情况1: 删除单个key
$redis->
set
(
'myname'
,
'ikodota'
);
echo $redis->
get
(
'myname'
).
'
'; # 返回:ikodota
$redis->del(
'myname'
);# 返回 TRUE(1)
var_dump($redis->
get
(
'myname'
)); # 返回
bool
(
false
)
# 情况2: 删除一个不存在的key
if
(!$redis->exists(
'fake_key'
)) # 不存在
var_dump($redis->del(
'fake_key'
)); # 返回
int
(0)
# 情况3: 同时删除多个key
$array_mset=array(
'first_key'
=>
'first_val'
,
'second_key'
=>
'second_val'
,
'third_key'
=>
'third_val'
);
$redis->mset($array_mset); #用MSET一次储存多个值
$array_mget=array(
'first_key'
,
'second_key'
,
'third_key'
);
var_dump($redis->mget($array_mget)); #一次返回多个值
//array(3) { [0]=> string(9) "first_val" [1]=> string(10) "second_val" [2]=> string(9) "third_val" }
$redis->del($array_mget); #同时删除多个key
var_dump($redis->mget($array_mget)); #返回 array(3) { [0]=>
bool
(
false
) [1]=>
bool
(
false
) [2]=>
bool
(
false
) }
1 2 3 4 5 6 7 8 9 10 11 |
//KEYS
#$redis->FLUSHALL();
$array_mset_keys=array( 'one' => '1' ,
'two' => '2' ,
'three ' => '3' ,
'four' => '4' );
$redis->mset($array_mset_keys); #用MSET一次储存多个值
var_dump($redis->keys( '*o*' )); //array(3) { [0]=> string(4) "four" [1]=> string(3) "two" [2]=> string(3) "one" }
var_dump($redis->keys( 't??' )); //array(1) { [0]=> string(3) "two" }
var_dump($redis->keys( 't[w]*' )); //array(1) { [0]=> string(3) "two" }
print_r($redis->keys( '*' )); //Array ( [0] => four [1] => three [2] => two [3] => one )
|
?
MOVE当作锁(locking)原语。 RENAME命令将覆盖旧值。
1
2
3
4
5
6
7
8
9
10
11
12
13
//RANDOMKEY
$redis->FLUSHALL();
# 情况1:数据库不为空
$array_mset_randomkey=array(
'fruit'
=>
'apple'
,
'drink'
=>
'beer'
,
'food'
=>
'cookis'
);
$redis->mset($array_mset_randomkey);
echo $redis->randomkey();
print_r($redis->keys(
'*'
)); # 查看数据库内所有key,证明RANDOMKEY并不删除key
//Array ( [0] => food [1] => drink [2] => fruit )
# 情况2:数据库为空
$redis->flushdb(); # 删除当前数据库所有key
var_dump($redis-> randomkey());
//bool(false)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
//TTL
# 情况1:带TTL的key
$redis->flushdb();
//$redis->set('name','ikodota'); # 设置一个key
$redis->expire(
'name'
,30); # 设置生存时间为30秒
//return (integer) 1
echo $redis->
get
(
'name'
);
//return ikodota
echo $redis->ttl(
'name'
);
//(integer) 25
//echo $redis->ttl('name'); # 30秒过去,name过期 //(integer) -1
var_dump($redis->
get
(
'name'
)); # 过期的key将被删除
//return bool(false);
# 情况2:不带TTL的key
$redis->
set
(
'site'
,
'wikipedia.org'
);
//OK
var_dump($redis->ttl(
'site'
));
//int(-1)
# 情况3:不存在的key
$redis->EXISTS(
'not_exists_key'
);
//int(0)
var_dump($redis->TTL(
'not_exists_key'
));
//int(-1)
1
2
3
4
5
6
//EXISTS
echo
'
EXISTS
';
$redis->
set
(
'db'
,
"redis"
);
//bool(true)
var_dump($redis->exists(
'db'
)); # key存在
//bool(true)
$redis->del(
'db'
); # 删除key
//int(1)
var_dump($redis->exists(
'db'
)) # key不存在
//bool(false)
?
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
//MOVE
echo
'
MOVE
';
# 情况1: key存在于当前数据库
$redis->SELECT(0); # redis默认使用数据库0,为了清晰起见,这里再显式指定一次。
//OK
$redis->SET(
'song'
,
"secret base - Zone"
);
//OK
var_dump ($redis->MOVE(
'song'
,1)); # 将song移动到数据库1
//bool(true)
# 情况2:当key不存在的时候
$redis->SELECT(1);
var_dump ($redis->EXISTS(
'fake_key'
));
//bool(false);
var_dump($redis->MOVE(
'fake_key'
, 0)); # 试图从数据库1移动一个不存在的key到数据库0,失败)
//bool(false)
$redis->SELECT(0); # 使用数据库0
var_dump($redis->EXISTS(
'fake_key'
)); # 证实fake_key不存在
//bool(false)
# 情况3:当源数据库和目标数据库有相同的key时
$redis->SELECT(0); # 使用数据库0
$redis->SET(
'favorite_fruit'
,
"banana"
);
$redis->SELECT(1); # 使用数据库1
$redis->SET(
'favorite_fruit'
,
"apple"
);
$redis->SELECT(0); # 使用数据库0,并试图将favorite_fruit移动到数据库1
var_dump($redis->MOVE(
'favorite_fruit'
,1)); # 因为两个数据库有相同的key,MOVE失败
//return bool(false)
echo $redis->GET(
'favorite_fruit'
); # 数据库0的favorite_fruit没变
//return banana
$redis->SELECT(1);
echo $redis->GET(
'favorite_fruit'
); # 数据库1的favorite_fruit也是
//return apple
?
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
//RENAME
echo
'
RENAME
';
# 情况1:key存在且newkey不存在
$redis->SET(
'message'
,
"hello world"
);
var_dump($redis->RENAME(
'message'
,
'greeting'
));
//bool(true)
var_dump($redis->EXISTS(
'message'
)); # message不复存在
//bool(false)
var_dump($redis->EXISTS(
'greeting'
)); # greeting取而代之
//bool(true)
# 情况2:当key不存在时,返回错误 ,php返回false;
var_dump($redis->RENAME(
'fake_key'
,
'never_exists'
));
//bool(false)
# 情况3:newkey已存在时,RENAME会覆盖旧newkey
$redis->SET(
'pc'
,
"lenovo"
);
$redis->SET(
'personal_computer'
,
"dell"
);
var_dump($redis->RENAME(
'pc'
,
'personal_computer'
));
//bool(true)
var_dump($redis->GET(
'pc'
));
//(nil) bool(false)
var_dump($redis->GET(
'personal_computer'
)); # dell“没有”了
//string(6) "lenovo"
- 时间复杂度:
- O(1)
- 返回值:
- 修改成功时,返回1。 如果newkey已经存在,返回0。
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 |
//RENAMENX
echo ' ;
# 情况1:newkey不存在,成功
$redis->SET( 'player' , "MPlyaer" );
$redis->EXISTS( 'best_player' ); //int(0)
var_dump($redis->RENAMENX( 'player' , 'best_player' )); // bool(true)
# 情况2:newkey存在时,失败
$redis->SET( 'animal' , "bear" );
$redis->SET( 'favorite_animal' , "butterfly" );
var_dump($redis->RENAMENX( 'animal' , 'favorite_animal' )); // bool(false)
var_dump($redis-> get ( 'animal' )); //string(4) "bear"
var_dump($redis-> get ( 'favorite_animal' )); //string(9) "butterfly"
|
- ?
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 //TYPE
$redis->flushALL();
echo
'
TYPE
';
var_dump($redis->TYPE(
'fake_key'
));
//none /int(0)
$redis->SET(
'weather'
,
"sunny"
); # 构建一个字符串
var_dump($redis->TYPE(
'weather'
));
//string / int(1)
$redis->SADD(
'pat'
,
"dog"
); # 构建一个集合
var_dump($redis->TYPE(
'pat'
));
//set /int(2)
$redis->LPUSH(
'book_list'
,
"programming in scala"
); # 构建一个列表
var_dump($redis->TYPE(
'book_list'
));
//list / int(3)
$redis->ZADD(
'pats'
,1,
'cat'
); # 构建一个zset (sorted
set
)
// int(1)
$redis->ZADD(
'pats'
,2,
'dog'
);
$redis->ZADD(
'pats'
,3,
'pig'
);
var_dump($redis->zRange(
'pats'
,0,-1));
// array(3) { [0]=> string(3) "cat" [1]=> string(3) "dog" [2]=> string(3) "pig" }
var_dump($redis->TYPE(
'pats'
));
//zset / int(4)
$redis->HSET(
'website'
,
'google'
,
'www.g.cn'
); # 一个新域
var_dump($redis->HGET(
'website'
,
'google'
));
//string(8) "www.g.cn"
var_dump($redis->TYPE(
'website'
));
//hash /int(5)
PERSIST命令移除。(详情参见 http://redis.io/topics/expire)。
- 时间复杂度:
- O(1)
- 返回值:
- 设置成功返回1。 当key不存在或者不能为key设置生存时间时(比如在低于2.1.3中你尝试更新key的生存时间),返回0。
1 2 3 4 5 6 7 8 9 10 11 12 13 //EXPIRE
$redis->
select
(7);
//$redis->flushdb();
echo
'
EXPIRE
';
$redis->SET(
'cache_page'
,
"www.cnblogs.com/ikodota"
);
$redis->EXPIRE(
'cache_page'
, 30); # 设置30秒后过期
sleep(6);
echo $redis->TTL(
'cache_page'
).
'
'; # 查看给定key的剩余生存时间
//(integer) 24
$redis->EXPIRE(
'cache_page'
, 3000); # 更新生存时间,3000秒
sleep(4);
echo $redis->TTL(
'cache_page'
).
'
';
//(integer) 2996
- EXPIREAT的作用和EXPIRE一样,都用于为key设置生存时间。
不同在于EXPIREAT命令接受的时间参数是UNIX时间戳(unix timestamp)。
- 时间复杂度:
- O(1)
- 返回值:
- 如果生存时间设置成功,返回1。 当key不存在或没办法设置生存时间,返回0。
1 2 3 4 5 6 //EXPIREAT
echo
'
EXPIREAT
';
$redis->SET(
'cache'
,
'www.google.com'
);
echo $redis->EXPIREAT(
'cache'
,
'1355292000'
); # 这个key将在2012.12.12过期
echo ($redis->TTL(
'cache'
));
//return 124345085
- OBJECT命令允许从内部察看给定key的Redis对象。
它通常用在除错(debugging)或者了解为了节省空间而对key使用特殊编码的情况。
当将Redis用作缓存程序时,你也可以通过OBJECT命令中的信息,决定key的驱逐策略(eviction policies)。
OBJECT命令有多个子命令:
- OBJECT REFCOUNT
返回给定key引用所储存的值的次数。此命令主要用于除错。 - OBJECT ENCODING
返回给定key锁储存的值所使用的内部表示(representation)。 - OBJECT IDLETIME
返回给定key自储存以来的空转时间(idle, 没有被读取也没有被写入),以秒为单位。
- 字符串可以被编码为raw(一般字符串)或int(用字符串表示64位数字是为了节约空间)。
- 列表可以被编码为ziplist或linkedlist。ziplist是为节约大小较小的列表空间而作的特殊表示。
- 集合可以被编码为intset或者hashtable。intset是只储存数字的小集合的特殊表示。
- 哈希表可以编码为zipmap或者hashtable。zipmap是小哈希表的特殊表示。
- 有序集合可以被编码为ziplist或者skiplist格式。ziplist用于表示小的有序集合,而skiplist则用于表示任何大小的有序集合。
- 时间复杂度:
- O(1)
- 返回值:
- REFCOUNT和IDLETIME返回数字。 ENCODING返回相应的编码类型。
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 //OBJECT
$redis->
select
(8);
echo
'
OBJECT
';
$redis->SET(
'game'
,
"WOW"
); # 设置一个字符串
$redis->OBJECT(
'REFCOUNT'
,
'game'
); # 只有一个引用
//sleep(5);
echo $redis->OBJECT(
'IDLETIME'
,
'game'
); # 等待一阵。。。然后查看空转时间
//(integer) 10
//echo $redis->GET('game'); # 提取game, 让它处于活跃(active)状态 //return WOW
//echo $redis->OBJECT('IDLETIME','game'); # 不再处于空转 //(integer) 0
var_dump($redis->OBJECT(
'ENCODING'
,
'game'
)); # 字符串的编码方式
//string(3) "raw"
$redis->SET(
'phone'
,15820123123); # 大的数字也被编码为字符串
var_dump($redis->OBJECT(
'ENCODING'
,
'phone'
));
//string(3) "raw"
$redis->SET(
'age'
,20); # 短数字被编码为
int
var_dump($redis->OBJECT(
'ENCODING'
,
'age'
));
//string(3) "int"
- ?
1 2 3 4 5 6 7 8 9 10 //PERSIST
echo
'
PERSIST
';
$redis->SET(
'time_to_say_goodbye'
,
"886..."
);
$redis->EXPIRE(
'time_to_say_goodbye'
, 300);
sleep(3);
echo $redis->TTL(
'time_to_say_goodbye'
); # (
int
) 297
echo
'
';
$redis->PERSIST(
'time_to_say_goodbye'
); # 移除生存时间
echo $redis->TTL(
'time_to_say_goodbye'
); # 移除成功
//int(-1)
?1 2 3 4 5 6 7 8 array(
‘
by
’ => ‘some_pattern_*’,
‘limit’ => array(0, 1),
‘
get
’ => ‘some_other_pattern_*’ or an array of patterns,
‘sort’ => ‘asc’ or ‘desc’,
‘alpha’ => TRUE,
‘store’ => ‘external-key’
)
返回或保存给定列表、集合、有序集合key中经过排序的元素。
排序默认以数字作为对象,值被解释为双精度浮点数,然后进行比较。
一般SORT用法
最简单的SORT使用方法是SORT key。
假设today_cost是一个保存数字的列表,SORT命令默认会返回该列表值的递增(从小到大)排序结果。
?1 2 3 4 5 6 7 # 将数据一一加入到列表中
$redis->LPUSH(
'today_cost'
, 30);
$redis->LPUSH(
'today_cost'
, 1.5);
$redis->LPUSH(
'today_cost'
, 10);
$redis->LPUSH(
'today_cost'
, 8);
# 排序
var_dump($redis->SORT(
'today_cost'
));
//array(4) { [0]=> string(3) "1.5" [1]=> string(1) "8" [2]=> string(2) "10" [3]=> string(2) "30" }
当数据集中保存的是字符串值时,你可以用ALPHA修饰符(modifier)进行排序。
?1 2 3 4 5 6 7 8 9 # 将数据一一加入到列表中
$redis->LPUSH(
'website'
,
"www.reddit.com"
);
$redis->LPUSH(
'website'
,
"www.slashdot.com"
);
$redis->LPUSH(
'website'
,
"www.infoq.com"
);
# 默认排序
var_dump($redis->SORT(
'website'
));
//array(3) { [0]=> string(13) "www.infoq.com" [1]=> string(16) "www.slashdot.com" [2]=> string(14) "www.reddit.com" }
# 按字符排序 ALPHA=true
var_dump($redis->SORT(
'website'
, array(
'ALPHA'
=>TRUE)));
//array(3) { [0]=> string(13) "www.infoq.com" [1]=> string(14) "www.reddit.com" [2]=> string(16) "www.slashdot.com" }
如果你正确设置了!LC_COLLATE环境变量的话,Redis能识别UTF-8编码。
排序之后返回的元素数量可以通过LIMIT修饰符进行限制。 LIMIT修饰符接受两个参数:offset和count。 offset指定要跳过的元素数量,count指定跳过offset个指定的元素之后,要返回多少个对象。以下例子返回排序结果的前5个对象(offset为0表示没有元素被跳过)。
?1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 # 将数据一一加入到列表中
$redis->LPUSH(
'rank'
, 30);
//(integer) 1
$redis->LPUSH(
'rank'
, 56);
//(integer) 2
$redis->LPUSH(
'rank'
, 42);
//(integer) 3
$redis->LPUSH(
'rank'
, 22);
//(integer) 4
$redis->LPUSH(
'rank'
, 0);
//(integer) 5
$redis->LPUSH(
'rank'
, 11);
//(integer) 6
$redis->LPUSH(
'rank'
, 32);
//(integer) 7
$redis->LPUSH(
'rank'
, 67);
//(integer) 8
$redis->LPUSH(
'rank'
, 50);
//(integer) 9
$redis->LPUSH(
'rank'
, 44);
//(integer) 10
$redis->LPUSH(
'rank'
, 55);
//(integer) 11
# 排序
$redis_sort_option=array(
'LIMIT'
=>array(0,5));
var_dump($redis->SORT(
'rank'
,$redis_sort_option)); # 返回排名前五的元素
// array(5) { [0]=> string(1) "0" [1]=> string(2) "11" [2]=> string(2) "22" [3]=> string(2) "30" [4]=> string(2) "32" }
修饰符可以组合使用。以下例子返回降序(从大到小)的前5个对象。
?1 2 3 4 5 $redis_sort_option=array(
'LIMIT'
=>array(0,5),
'SORT'
=>
'DESC'
);
var_dump($redis->SORT(
'rank'
,$redis_sort_option));
//array(5) { [0]=> string(2) "67" [1]=> string(2) "56" [2]=> string(2) "55" [3]=> string(2) "50" [4]=> string(2) "44" }
使用外部key进行排序
有时候你会希望使用外部的key作为权重来比较元素,代替默认的对比方法。
假设现在有用户(user)数据如下:
id name level
-------------------------------
1 admin 9999
2 huangz 10
59230 jack 3
222 hacker 9999id数据保存在key名为user_id的列表中。
?
name数据保存在key名为user_name_{id}的列表中
level数据保存在user_level_{id}的key中。1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 # 先将要使用的数据加入到数据库中
# admin
$redis->LPUSH(
'user_id'
, 1);
//(integer) 1
$redis->SET(
'user_name_1'
,
'admin'
);
$redis->SET(
'user_level_1'
,9999);
# huangz
$redis->LPUSH(
'user_id'
, 2);
//(integer) 2
$redis->SET(
'user_name_2'
,
'huangz'
);
$redis->SET(
'user_level_2'
, 10);
# jack
$redis->LPUSH(
'user_id'
, 59230);
//(integer) 3
$redis->SET(
'user_name_59230'
,
'jack'
);
$redis->SET(
'user_level_59230'
, 3);
# hacker
$redis->LPUSH(
'user_id'
, 222);
//(integer) 4
$redis->SET(
'user_name_222'
,
'hacker'
);
$redis->SET(
'user_level_222'
, 9999);
如果希望按level从大到小排序user_id,可以使用以下命令:
?1 2 3 4 5 6 7 8 9 10 $redis_sort_option=array(
'BY'
=>
'user_level_*'
,
'SORT'
=>
'DESC'
);
var_dump($redis->SORT(
'user_id'
,$redis_sort_option));
//array(4) { [0]=> string(3) "222" [1]=> string(1) "1" [2]=> string(1) "2" [3]=> string(5) "59230" }
#---------------------------
#1) "222" # hacker
#2) "1" # admin
#3) "2" # huangz
#4) "59230" # jack
但是有时候只是返回相应的id没有什么用,你可能更希望排序后返回id对应的用户名,这样更友好一点,使用GET选项可以做到这一点:
?1 2 3 4 5 6 7 8 9 $redis_sort_option=array(
'BY'
=>
'user_level_*'
,
'SORT'
=>
'DESC'
,
'GET'
=>
'user_name_*'
);
var_dump($redis->SORT(
'user_id'
, $redis_sort_option));
//array(4) { [0]=> string(6) "hacker" [1]=> string(5) "admin" [2]=> string(6) "huangz" [3]=> string(4) "jack" }
#1) "hacker"
#2) "admin"
#3) "huangz"
#4) "jack"
可以多次地、有序地使用GET操作来获取更多外部key。
比如你不但希望获取用户名,还希望连用户的密码也一并列出,可以使用以下命令:
?1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 # 先添加一些测试数据
$redis->SET(
'user_password_222'
,
"hey,im in"
);
$redis->SET(
'user_password_1'
,
"a_long_long_password"
);
$redis->SET(
'user_password_2'
,
"nobodyknows"
);
$redis->SET(
'user_password_59230'
,
"jack201022"
);
# 获取name和password
$redis_sort_option=array(
'BY'
=>
'user_level_*'
,
'SORT'
=>
'DESC'
,
'GET'
=>array(
'user_name_*'
,
'user_password_*'
)
);
var_dump($redis->SORT(
'user_id'
,$redis_sort_option));
//array(8) { [0]=> string(6) "hacker" [1]=> string(9) "hey,im in" [2]=> string(5) "admin" [3]=> string(20) "a_long_long_password" [4]=> string(6) "huangz" [5]=> string(11) "nobodyknows" [6]=> string(4) "jack" [7]=> string(10) "jack201022" }
#------------------------------------
#1) "hacker" # 用户名
#2) "hey,im in" # 密码
#3) "jack"
#4) "jack201022"
#5) "huangz"
#6) "nobodyknows"
#7) "admin"
#8) "a_long_long_password"
# 注意GET操作是有序的,GET user_name_* GET user_password_* 和 GET user_password_* GET user_name_*返回的结果位置不同
?1 2 3 4 5 6 # 获取name和password 注意GET操作是有序的
$redis_sort_option=array(
'BY'
=>
'user_level_*'
,
'SORT'
=>
'DESC'
,
'GET'
=>array(
'user_password_*'
,
'user_name_*'
)
);
var_dump($redis->SORT(
'user_id'
,$redis_sort_option));
// array(8) { [0]=> string(9) "hey,im in" [1]=> string(6) "hacker" [2]=> string(20) "a_long_long_password" [3]=> string(5) "admin" [4]=> string(11) "nobodyknows" [5]=> string(6) "huangz" [6]=> string(10) "jack201022" [7]=> string(4) "jack" }
GET还有一个特殊的规则——"GET #",用于获取被排序对象(我们这里的例子是user_id)的当前元素。
比如你希望user_id按level排序,还要列出id、name和password,可以使用以下命令:
?1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 $redis_sort_option=array(
'BY'
=>
'user_level_*'
,
'SORT'
=>
'DESC'
,
'GET'
=>array(
'#'
,
'user_password_*'
,
'user_name_*'
)
);
var_dump($redis->SORT(
'user_id'
,$redis_sort_option));
//array(12) { [0]=> string(3) "222" [1]=> string(9) "hey,im in" [2]=> string(6) "hacker" [3]=> string(1) "1" [4]=> string(20) "a_long_long_password" [5]=> string(5) "admin" [6]=> string(1) "2" [7]=> string(11) "nobodyknows" [8]=> string(6) "huangz" [9]=> string(5) "59230" [10]=> string(10) "jack201022" [11]=> string(4) "jack" }
#--------------------------------------------------------------
#1) "222" # id
#2) "hacker" # name
#3) "hey,im in" # password
#4) "1"
#5) "admin"
#6) "a_long_long_password"
#7) "2"
#8) "huangz"
#9) "nobodyknows"
#10) "59230"
#11) "jack"
#12) "jack201022"
只获取对象而不排序
BY修饰符可以将一个不存在的key当作权重,让SORT跳过排序操作。
该方法用于你希望获取外部对象而又不希望引起排序开销时使用。
?1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 # 确保fake_key不存在
$redis->EXISTS(
'fake_key'
);
//(integer) 0
# 以fake_key作BY参数,不排序,只GET name 和 GET password
$redis_sort_option=array(
'BY'
=>
'fake_key'
,
'SORT'
=>
'DESC'
,
'GET'
=>array(
'#'
,
'user_name_*'
,
'user_password_*'
)
);
var_dump($redis->SORT(
'user_id'
,$redis_sort_option));
//array(12) { [0]=> string(3) "222" [1]=> string(6) "hacker" [2]=> string(9) "hey,im in" [3]=> string(5) "59230" [4]=> string(4) "jack" [5]=> string(10) "jack201022" [6]=> string(1) "2" [7]=> string(6) "huangz" [8]=> string(11) "nobodyknows" [9]=> string(1) "1" [10]=> string(5) "admin" [11]=> string(20) "a_long_long_password" }
#----------------------------------------------
#1) "222" # id
#2) "hacker" # user_name
#3) "hey,im in" # password
#4) "59230"
#5) "jack"
#6) "jack201022"
#7) "2"
#8) "huangz"
#9) "nobodyknows"
#10) "1"
#11) "admin"
#12) "a_long_long_password"
保存排序结果
默认情况下,SORT操作只是简单地返回排序结果,如果你希望保存排序结果,可以给STORE选项指定一个key作为参数,排序结果将以列表的形式被保存到这个key上。(若指定key已存在,则覆盖。)
?1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 $redis->EXISTS(
'user_info_sorted_by_level'
); # 确保指定key不存在
//(integer) 0
$redis_sort_option=array(
'BY'
=>
'user_level_*'
,
'GET'
=>array(
'#'
,
'user_name_*'
,
'user_password_*'
),
'STORE'
=>
'user_info_sorted_by_level'
);
var_dump($redis->SORT(
'user_id'
,$redis_sort_option));
//int(12)
var_dump($redis->LRANGE(
'user_info_sorted_by_level'
, 0 ,11)); # 查看排序结果
//array(12) { [0]=> string(5) "59230" [1]=> string(4) "jack" [2]=> string(10) "jack201022" [3]=> string(1) "2" [4]=> string(6) "huangz" [5]=> string(11) "nobodyknows" [6]=> string(3) "222" [7]=> string(6) "hacker" [8]=> string(9) "hey,im in" [9]=> string(1) "1" [10]=> string(5) "admin" [11]=> string(20) "a_long_long_password" }
#-----------------------------------------------------------------
#1) "59230"
#2) "jack"
#3) "jack201022"
#4) "2"
#5) "huangz"
#6) "nobodyknows"
#7) "222"
#8) "hacker"
#9) "hey,im in"
#10) "1"
#11) "admin"
#12) "a_long_long_password"
一个有趣的用法是将SORT结果保存,用EXPIRE为结果集设置生存时间,这样结果集就成了SORT操作的一个缓存。
这样就不必频繁地调用SORT操作了,只有当结果集过期时,才需要再调用一次SORT操作。
有时候为了正确实现这一用法,你可能需要加锁以避免多个客户端同时进行缓存重建(也就是多个客户端,同一时间进行SORT操作,并保存为结果集),具体参见SETNX命令。
在GET和BY中使用哈希表
可以使用哈希表特有的语法,在SORT命令中进行GET和BY操作。
?1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 # 假设现在我们的用户表新增了一个serial项来为作为每个用户的序列号
# 序列号以哈希表的形式保存在serial哈希域内。
$redis_hash_testdata_array=array(1=>
'23131283'
,
2=>
'23810573'
,
222=>
'502342349'
,
59230=>
'2435829758'
);
$redis->HMSET(
'serial'
,$redis_hash_testdata_array);
# 我们希望以比较serial中的大小来作为排序user_id的方式
$redis_sort_option=array(
'BY'
=>
'*->serial'
);
var_dump($redis->SORT(
'user_id'
, $redis_sort_option));
//array(4) { [0]=> string(3) "222" [1]=> string(5) "59230" [2]=> string(1) "2" [3]=> string(1) "1" }
#----------------------------------------
#1) "222"
#2) "59230"
#3) "2"
#4) "1"
符号"->"用于分割哈希表的关键字(key name)和索引域(hash field),格式为"key->field"。
除此之外,哈希表的BY和GET操作和上面介绍的其他数据结构(列表、集合、有序集合)没有什么不同。
- 时间复杂度:
- O(N+M*log(M)),N为要排序的列表或集合内的元素数量,M为要返回的元素数量。 如果只是使用SORT命令的GET选项获取数据而没有进行排序,时间复杂度O(N)。
- 返回值:
- 没有使用STORE参数,返回列表形式的排序结果。 使用STORE参数,返回排序结果的元素数量。
SET就覆写旧值,无视类型。
时间复杂度:O(1)返回值:总是返回OK(TRUE),因为SET不可能失败。# 情况1:对字符串类型的key进行SET
SETNX不做任何动作。
$redis->SET('apple', 'www.apple.com');#OK //bool(true)
$redis->GET('apple');//"www.apple.com"
# 情况2:对非字符串类型的key进行SET
$redis->LPUSH('greet_list', "hello"); # 建立一个列表 #(integer) 1 //int(1)
$redis->TYPE('greet_list');#list //int(3)
$redis->SET('greet_list', "yooooooooooooooooo"); # 覆盖列表类型 #OK //bool(true)
$redis->TYPE('greet_list');#string //int(1)SETNX是”SET if Not eXists”(如果不存在,则SET)的简写。
- 时间复杂度:
- O(1)
- 返回值:
- 设置成功,返回1。 设置失败,返回0。
//SETNX
echo '
SETNX
';
$redis->EXISTS('job'); # job不存在 //bool(false);
$redis->SETNX('job', "programmer"); # job设置成功 //bool(true)
$redis->SETNX('job', "code-farmer"); # job设置失败 //bool(false)
echo $redis->GET('job'); # 没有被覆盖 //"programmer"设计模式(Design pattern): 将SETNX用于加锁(locking)
SETNX可以用作加锁原语(locking primitive)。比如说,要对关键字(key)foo加锁,客户端可以尝试以下方式:
SETNX lock.foo
Unix time + lock timeout + 1> 如果SETNX返回1,说明客户端已经获得了锁,key设置的unix时间则指定了锁失效的时间。之后客户端可以通过DEL lock.foo来释放锁。
如果SETNX返回0,说明key已经被其他客户端上锁了。如果锁是非阻塞(non blocking lock)的,我们可以选择返回调用,或者进入一个重试循环,直到成功获得锁或重试超时(timeout)。
处理死锁(deadlock)
上面的锁算法有一个问题:如果因为客户端失败、崩溃或其他原因导致没有办法释放锁的话,怎么办?
这种状况可以通过检测发现——因为上锁的key保存的是unix时间戳,假如key值的时间戳小于当前的时间戳,表示锁已经不再有效。
但是,当有多个客户端同时检测一个锁是否过期并尝试释放它的时候,我们不能简单粗暴地删除死锁的key,再用SETNX上锁,因为这时竞争条件(race condition)已经形成了:
- C1和C2读取lock.foo并检查时间戳,SETNX都返回0,因为它已经被C3锁上了,但C3在上锁之后就崩溃(crashed)了。
- C1向lock.foo发送DEL命令。
- C1向lock.foo发送SETNX并成功。
- C2向lock.foo发送DEL命令。
- C2向lock.foo发送SETNX并成功。
- 出错:因为竞争条件的关系,C1和C2两个都获得了锁。
幸好,以下算法可以避免以上问题。来看看我们聪明的C4客户端怎么办:
- C4向lock.foo发送SETNX命令。
- 因为崩溃掉的C3还锁着lock.foo,所以Redis向C4返回0。
- C4向lock.foo发送GET命令,查看lock.foo的锁是否过期。如果不,则休眠(sleep)一段时间,并在之后重试。
- 另一方面,如果lock.foo内的unix时间戳比当前时间戳老,C4执行以下命令:
GETSET lock.foo
Unix timestamp + lock timeout + 1> - 因为GETSET的作用,C4可以检查看GETSET的返回值,确定lock.foo之前储存的旧值仍是那个过期时间戳,如果是的话,那么C4获得锁。
- 如果其他客户端,比如C5,比C4更快地执行了GETSET操作并获得锁,那么C4的GETSET操作返回的就是一个未过期的时间戳(C5设置的时间戳)。C4只好从第一步开始重试。
警告
为了让这个加锁算法更健壮,获得锁的客户端应该常常检查过期时间以免锁因诸如DEL等命令的执行而被意外解开,因为客户端失败的情况非常复杂,不仅仅是崩溃这么简单,还可能是客户端因为某些操作被阻塞了相当长时间,紧接着DEL命令被尝试执行(但这时锁却在另外的客户端手上)。
这个命令类似于以下两个命令:
$redis->SET('key', 'value');
$redis->EXPIRE('key','seconds'); # 设置生存时间不同之处是,SETEX是一个原子性(atomic)操作,关联值和设置生存时间两个动作会在同一时间内完成,该命令在Redis用作缓存时,非常实用。
- 时间复杂度:
- O(1)
- 返回值:
- 设置成功时返回OK。 当seconds参数不合法时,返回一个错误。
# 情况1:key不存在
$redis->SETEX('cache_user_id', 60,10086);//bool(true)
echo $redis->GET('cache_user_id'); # 值 //"10086"
sleep(4);
echo $redis->TTL('cache_user_id'); # 剩余生存时间 //int(56)
# 情况2:key已经存在,key被覆写
$redis->SET('cd', "timeless"); //bool(true);
$redis->SETEX('cd', 3000,"goodbye my love"); //bool(true);
echo $redis->GET('cd');//"goodbye my love"SETRANGE命令会确保字符串足够长以便将value设置在指定的偏移量上,如果给定key原来储存的字符串长度比偏移量小(比如字符串只有5个字符长,但你设置的offset是10),那么原字符和偏移量之间的空白将用零比特(zerobytes,"\x00")来填充。
注意你能使用的最大偏移量是2^29-1(536870911),因为Redis的字符串被限制在512兆(megabytes)内。如果你需要使用比这更大的空间,你得使用多个key。
- 时间复杂度:
- 对小(small)的字符串,平摊复杂度O(1)。(关于什么字符串是”小”的,请参考APPEND命令) 否则为O(M),M为value参数的长度。
- 返回值:
- 被SETRANGE修改之后,字符串的长度。
警告
当生成一个很长的字符串时,Redis需要分配内存空间,该操作有时候可能会造成服务器阻塞(block)。在2010年的Macbook Pro上,设置偏移量为536870911(512MB内存分配),耗费约300毫秒, 设置偏移量为134217728(128MB内存分配),耗费约80毫秒,设置偏移量33554432(32MB内存分配),耗费约30毫秒,设置偏移量为8388608(8MB内存分配),耗费约8毫秒。 注意若首次内存分配成功之后,再对同一个key调用SETRANGE操作,无须再重新内存。
模式
因为有了SETRANGE和GETRANGE命令,你可以将Redis字符串用作具有O(1)随机访问时间的线性数组。这在很多真实用例中都是非常快速且高效的储存方式。
# 情况1:对非空字符串进行SETRANGE
$redis->SET('greeting', "hello world");
$redis->SETRANGE('greeting', 6, "Redis"); //int(11)
$redis->GET('greeting');//"hello Redis"
# 情况2:对空字符串/不存在的key进行SETRANGE
$redis->EXISTS('empty_string');//bool(false)
$redis->SETRANGE('empty_string', 5 ,"Redis!"); # 对不存在的key使用SETRANGE //int(11)
var_dump($redis->GET('empty_string')); # 空白处被"\x00"填充 #"\x00\x00\x00\x00\x00Redis!" //return string(11) "Redis!"MSET会用新值覆盖旧值,如果你不希望覆盖同名key,请使用MSETNX命令。
MSET是一个原子性(atomic)操作,所有给定key都在同一时间内被设置,某些给定key被更新而另一些给定key没有改变的情况,不可能发生。
- 时间复杂度:
- O(N),N为要设置的key数量。
- 返回值:
- 总是返回OK(因为MSET不可能失败)
#MSET
echo '
MSET
';
$redis->select(0);
$redis->flushdb();
$array_mset=array('date'=>'2012.3.5',
'time'=>'9.09a.m.',
'weather'=>'sunny'
);
$redis->MSET($array_mset); //bool(true)
var_dump($redis->KEYS('*')); # 确保指定的三个key-value对被插入 //array(3) { [0]=> string(4) "time" [1]=> string(7) "weather" [2]=> string(4) "date" }
# MSET覆盖旧值的例子 但是经过测试覆盖不了
var_dump($redis->SET('google', "google.cn")); //bool(true)
var_dump($redis->MSET('google',"google.hk")); //bool(false)
echo $redis->GET('google'); //google.cn 与redis手册的示例结果不符MSETNX也会拒绝所有传入key的设置操作
MSETNX是原子性的,因此它可以用作设置多个不同key表示不同字段(field)的唯一性逻辑对象(unique logic object),所有字段要么全被设置,要么全不被设置。
- 时间复杂度:
- O(N),N为要设置的key的数量。
- 返回值:
- 当所有key都成功设置,返回1。 如果所有key都设置失败(最少有一个key已经存在),那么返回0。
# 情况1:对不存在的key进行MSETNX
$array_mset=array('rmdbs'=>'MySQL',
'nosql'=>'MongoDB',
'key-value-store'=>'redis'
);
$redis->MSETNX($array_mset);//bool(true)
# 情况2:对已存在的key进行MSETNX
$array_mset=array('rmdbs'=>'Sqlite',
'language'=>'python'
);
var_dump($redis->MSETNX($array_mset)); # rmdbs键已经存在,操作失败 //bool(false)
var_dump($redis->EXISTS('language')); # 因为操作是原子性的,language没有被设置 bool(false)
echo $redis->GET('rmdbs'); # rmdbs没有被修改 //"MySQL"
$array_mset_keys=array( 'rmdbs', 'nosql', 'key-value-store');
print_r($redis->MGET($array_mset_keys)); //Array ( [0] => MySQL [1] => MongoDB [2] => redis )APPEND命令将value追加到key原来的值之后。
如果key不存在,APPEND就简单地将给定key设为value,就像执行SET key value一样。
- 时间复杂度:
- 平摊复杂度O(1)
- 返回值:
- 追加value之后,key中字符串的长度。
# 情况1:对不存在的key执行APPEND
$redis->EXISTS('myphone'); # 确保myphone不存在 //bool(false)
$redis->APPEND('myphone',"nokia"); # 对不存在的key进行APPEND,等同于SET myphone "nokia" //int(5) # 字符长度
# 情况2:对字符串进行APPEND
$redis->APPEND('myphone', " - 1110");# 长度从5个字符增加到12个字符 //int(12)
echo $redis->GET('myphone'); # 查看整个字符串 //"nokia - 1110"GET只能用于处理字符串值。
- 时间复杂度:
- O(1)
- 返回值:
- key的值。 如果key不存在,返回nil。
//GET
var_dump($redis->GET('fake_key')); #(nil) //return bool(false)
$redis->SET('animate', "anohana"); //return bool(true)
var_dump($redis->GET('animate')); //return string(7) "anohana"GETRANGE通过保证子字符串的值域(range)不超过实际字符串的值域来处理超出范围的值域请求。
- 时间复杂度:
- O(N),N为要返回的字符串的长度。 复杂度最终由返回值长度决定,但因为从已有字符串中建立子字符串的操作非常廉价(cheap),所以对于长度不大的字符串,该操作的复杂度也可看作O(1)。
- 返回值:
- 截取得出的子字符串。
注解:在<=2.0的版本里,GETRANGE被叫作SUBSTR。
//GETRANGE
echo '
GETRANGE
';
$redis->SET('greeting', "hello, my friend");
echo $redis->GETRANGE('greeting', 0, 4).'
'; # 返回索引0-4的字符,包括4。 //"hello"
echo $redis->GETRANGE('greeting', -1 ,-5).'
'; # 不支持回绕操作 //""
echo $redis->GETRANGE('greeting', -3 ,-1).'
'; # 负数索引 //"end"
echo $redis->GETRANGE('greeting', 0, -1).'
'; # 从第一个到最后一个 //"hello, my friend"
echo $redis->GETRANGE('greeting', 0, 1008611).'
'; # 值域范围不超过实际字符串,超过部分自动被符略 //"hello, my friend"GETSET可以和INCR组合使用,实现一个有原子性(atomic)复位操作的计数器(counter)。
举例来说,每次当某个事件发生时,进程可能对一个名为mycount的key调用INCR操作,通常我们还要在一个原子时间内同时完成获得计数器的值和将计数器值复位为0两个操作。
可以用命令GETSET mycounter 0来实现这一目标。
$redis->SELECT(2);
echo $redis->INCR('mycount').'
'; #(integer) 11
if($redis->GET('mycount')>19){
echo $redis->GETSET('mycount', 0).'
'; # 一个原子内完成GET mycount和SET mycount 0操作 #"11"
}
echo $redis->GET('mycount'); #"0"INCR操作。
如果值包含错误的类型,或字符串类型的值不能表示为数字,那么返回一个错误。
本操作的值限制在64位(bit)有符号数字表示之内。
- 时间复杂度:
- O(1)
- 返回值:
- 执行INCR命令之后key的值。
注解:这是一个针对字符串的操作,因为Redis没有专用的整数类型,所以key内储存的字符串被解释为十进制64位有符号整数来执行INCR操作。
$redis->SET('page_view', 20);
var_dump($redis->INCR('page_view')); //int(21)
var_dump($redis->GET('page_view')); # 数字值在Redis中以字符串的形式保存 //string(2) "21INCRBY命令。
如果值包含错误的类型,或字符串类型的值不能表示为数字,那么返回一个错误。
本操作的值限制在64位(bit)有符号数字表示之内。
关于更多递增(increment)/递减(decrement)操作信息,参见INCR命令。
- 时间复杂度:
- O(1)
- 返回值:
- 加上increment之后,key的值。
//INCRBY
echo '
INCRBY
';
# 情况1:key存在且是数字值
$redis->SET('rank', 50); # 设置rank为50
$redis->INCRBY('rank', 20); # 给rank加上20
var_dump($redis->GET('rank')); #"70" //string(2) "70"
# 情况2:key不存在
$redis->EXISTS('counter'); //bool(false)
$redis->INCRBY('counter'); #int 30 //bool(false)
var_dump($redis->GET('counter')); #30 //经测试 与手册上结果不一样,不能直接从bool型转为int型。 return bool(false)
# 情况3:key不是数字值
$redis->SET('book', "long long ago...");
var_dump($redis->INCRBY('book', 200)); #(error) ERR value is not an integer or out of range // bool(false)DECR操作。
如果值包含错误的类型,或字符串类型的值不能表示为数字,那么返回一个错误。
本操作的值限制在64位(bit)有符号数字表示之内。
关于更多递增(increment)/递减(decrement)操作信息,参见INCR命令。
- 时间复杂度:
- O(1)
- 返回值:
- 执行DECR命令之后key的值。
//DECR
$redis->SELECT(3);
$redis->flushdb();
echo '
DECR
';
# 情况1:对存在的数字值key进行DECR
$redis->SET('failure_times', 10);
$redis->DECR('failure_times'); //int(9)
echo $redis->GET('failure_times').'
'; //string(1) "9"
# 情况2:对不存在的key值进行DECR
$redis->EXISTS('count'); #(integer) 0 //bool(false)
$redis->DECR('count'); //int(-1)
echo $redis->GET('count').'
'; //string(2) "-1"
# 情况3:对存在但不是数值的key进行DECR
$redis->SET('company', 'YOUR_CODE_SUCKS.LLC');
var_dump($redis->DECR('company')); #(error) ERR value is not an integer or out of range //bool(false)
echo $redis->GET('company').'
'; //YOUR_CODE_SUCKS.LLCDECRBY操作。
如果值包含错误的类型,或字符串类型的值不能表示为数字,那么返回一个错误。
本操作的值限制在64位(bit)有符号数字表示之内。
关于更多递增(increment)/递减(decrement)操作信息,参见INCR命令。
- 时间复杂度:
- O(1)
- 返回值:
- 减去decrement之后,key的值。
# 情况1:对存在的数值key进行DECRBY
$redis->SET('count', 100);
var_dump($redis->DECRBY('count', 20)); //int(80)
var_dump($redis->GET('count')); //string(2) "80"
# 情况2:对不存在的key进行DECRBY
$redis->EXISTS('pages');#(integer) 0 //bool(false)
var_dump($redis->DECRBY('pages', 10)); //int(-10)
var_dump($redis->GET('pages')); //string(3) "-10"SETBIT操作来说,内存分配可能造成Redis服务器被阻塞。具体参考SETRANGE命令,warning(警告)部分。
//SETBIT
echo '
SETBIT
';
$bit_val=67;
echo decbin($bit_val).'
'; //1000011
var_dump($redis->SETBIT('bit',1,1));//int(0) 空位上都是0
var_dump($redis->SETBIT('bit',2,0));//int(0)
var_dump($redis->SETBIT('bit',3,0));//int(0)
var_dump($redis->SETBIT('bit',4,0));//int(0)
var_dump($redis->SETBIT('bit',5,0));//int(0)
var_dump($redis->SETBIT('bit',6,1));//int(0)
var_dump($redis->SETBIT('bit',7,1));//int(0)
var_dump($redis->GET('bit')); //string(1) "C" ,二进制为:1000011 ,ASCII:67
var_dump($redis->GETBIT('bit', 6 )); //int(1) 取出第6位(从左到右)为“1”
var_dump($redis->SETBIT('bit',5,1));//int(0) 把第5位的0改为1
var_dump($redis->SETBIT('bit',6,0));//int(1) 把第6位的1改为0
var_dump($redis->GET('bit')); //string(1) "E ,二进制为:1000101,ASCII:69lHSET操作。
如果域field已经存在于哈希表中,旧值将被覆盖。
- 时间复杂度:
- O(1)
- 返回值:
- 如果field是哈希表中的一个新建域,并且值设置成功,返回1。 如果哈希表中域field已经存在且旧值已被新值覆盖,返回0。
HSETNX命令。
- 时间复杂度:
- O(1)
- 返回值:
- 设置成功,返回1。 如果给定域已经存在且没有操作被执行,返回0。
HMSET操作。
- 时间复杂度:
- O(N),N为field - value对的数量。
- 返回值:
- 如果命令执行成功,返回OK。 当key不是哈希表(hash)类型时,返回一个错误。
HMGET操作将返回一个只带有nil值的表。
- 时间复杂度:
- O(N),N为给定域的数量。
- 返回值:
- 一个包含多个给定域的关联值的表,表值的排列顺序和给定域参数的请求顺序一样。
HDEL每次只能删除单个域,如果你需要在一个原子时间内删除多个域,请将命令包含在MULTI/ EXEC块内。
HINCRBY命令。
如果域field不存在,那么在执行命令前,域的值被初始化为0。
对一个储存字符串值的域field执行HINCRBY命令将造成一个错误。
本操作的值限制在64位(bit)有符号数字表示之内。
- 时间复杂度:
- O(1)
- 返回值:
- 执行HINCRBY命令之后,哈希表key中域field的值。
LPUSH操作。
当key存在但不是列表类型时,返回一个错误。
- 时间复杂度:
- O(1)
- 返回值:
- 执行LPUSH命令后,列表的长度。
注解:在Redis 2.4版本以前的LPUSH命令,都只接受单个value值。
LPUSH命令相反,当key不存在时,LPUSHX命令什么也不做。
- 时间复杂度:
- O(1)
- 返回值:
- LPUSHX命令执行之后,表的长度。
RPUSH操作。
当key存在但不是列表类型时,返回一个错误。
- 时间复杂度:
- O(1)
- 返回值:
- 执行RPUSH操作后,表的长度。
注解:在Redis 2.4版本以前的RPUSH命令,都只接受单个value值。
RPUSH命令相反,当key不存在时,RPUSHX命令什么也不做。
- 时间复杂度:
- O(1)
- 返回值:
- RPUSHX命令执行之后,表的长度。
BLPOP是列表的阻塞式(blocking)弹出原语。
它是LPOP命令的阻塞版本,当给定列表内没有任何元素可供弹出的时候,连接将被BLPOP命令阻塞,直到等待超时或发现可弹出元素为止。
当给定多个key参数时,按参数key的先后顺序依次检查各个列表,弹出第一个非空列表的头元素。
非阻塞行为
当BLPOP被调用时,如果给定key内至少有一个非空列表,那么弹出遇到的第一个非空列表的头元素,并和被弹出元素所属的列表的名字一起,组成结果返回给调用者。
当存在多个给定key时,BLPOP按给定key参数排列的先后顺序,依次检查各个列表。
假设现在有job、 command和request三个列表,其中job不存在,command和request都持有非空列表。考虑以下命令:
BLPOP job command request 0
BLPOP保证返回的元素来自command,因为它是按”查找job -> 查找command -> 查找request“这样的顺序,第一个找到的非空列表。
阻塞行为
如果所有给定key都不存在或包含空列表,那么BLPOP命令将阻塞连接,直到等待超时,或有另一个客户端对给定key的任意一个执行LPUSH或RPUSH命令为止。
超时参数timeout接受一个以秒为单位的数字作为值。超时参数设为0表示阻塞时间可以无限期延长(block indefinitely) 。
相同的key被多个客户端同时阻塞
相同的key可以被多个客户端同时阻塞。 不同的客户端被放进一个队列中,按”先阻塞先服务”(first-BLPOP,first-served)的顺序为key执行BLPOP命令。在MULTI/EXEC事务中的BLPOP
BLPOP可以用于流水线(pipline,批量地发送多个命令并读入多个回复),但把它用在MULTI/EXEC块当中没有意义。因为这要求整个服务器被阻塞以保证块执行时的原子性,该行为阻止了其他客户端执行LPUSH或RPUSH命令。
因此,一个被包裹在MULTI/EXEC块内的BLPOP命令,行为表现得就像LPOP一样,对空列表返回nil,对非空列表弹出列表元素,不进行任何阻塞操作。
时间复杂度:O(1)返回值:
如果列表为空,返回一个nil。 反之,返回一个含有两个元素的列表,第一个元素是被弹出元素所属的key,第二个元素是被弹出元素的值。BRPOP是列表的阻塞式(blocking)弹出原语。
它是RPOP命令的阻塞版本,当给定列表内没有任何元素可供弹出的时候,连接将被BRPOP命令阻塞,直到等待超时或发现可弹出元素为止。
当给定多个key参数时,按参数key的先后顺序依次检查各个列表,弹出第一个非空列表的尾部元素。
关于阻塞操作的更多信息,请查看BLPOP命令,BRPOP除了弹出元素的位置和BLPOP不同之外,其他表现一致。
- 时间复杂度:
- O(1)
- 返回值:
- 假如在指定时间内没有任何元素被弹出,则返回一个nil和等待时长。 反之,返回一个含有两个元素的列表,第一个元素是被弹出元素所属的key,第二个元素是被弹出元素的值。
LRANGE命令的取值范围之内(闭区间),这和某些语言的区间函数可能不一致,比如Ruby的Range.new、Array#slice和Python的range()函数。
超出范围的下标
超出范围的下标值不会引起错误。
如果start下标比列表的最大下标end(LLEN list减去1)还要大,或者start > stop,LRANGE返回一个空列表。
如果stop下标比end下标还要大,Redis将stop的值设置为end。
- 时间复杂度:
- O(S+N),S为偏移量start,N为指定区间内元素的数量。
- 返回值:
- 一个列表,包含指定区间内的元素。
LREM命令总是返回0。
LINDEX操作。
当index参数超出范围,或对一个空列表(key不存在)进行LSET时,返回一个错误。
- 时间复杂度:
- 对头元素或尾元素进行LSET操作,复杂度为O(1)。 其他情况下,为O(N),N为列表的长度。
- 返回值:
- 操作成功返回ok,否则返回错误信息
LTRIM命令通常和LPUSH命令或RPUSH命令配合使用,举个例子:
这个例子模拟了一个日志程序,每次将最新日志newest_log放到log列表中,并且只保留最新的100项。注意当这样使用LTRIM命令时,时间复杂度是O(1),因为平均情况下,每次只有一个元素被移除。
注意LTRIM命令和编程语言区间函数的区别
假如你有一个包含一百个元素的列表list,对该列表执行LTRIM list 0 10,结果是一个包含11个元素的列表,这表明stop下标也在LTRIM命令的取值范围之内(闭区间),这和某些语言的区间函数可能不一致,比如Ruby的Range.new、Array#slice和Python的range()函数。
超出范围的下标
超出范围的下标值不会引起错误。
如果start下标比列表的最大下标end(LLEN list减去1)还要大,或者start > stop,LTRIM返回一个空列表(因为LTRIM已经将整个列表清空)。
如果stop下标比end下标还要大,Redis将stop的值设置为end。
- 时间复杂度:
- O(N),N为被移除的元素的数量。
- 返回值:
- 命令执行成功时,返回ok。
LINDEX命令,复杂度为O(1)。
- 返回值:
- 列表中下标为index的元素。 如果index参数的值不在列表的区间范围内(out of range),返回nil。
- OBJECT REFCOUNT
RPOPLPUSH在一个原子时间内,执行以下两个动作:
- 将列表source中的最后一个元素(尾元素)弹出,并返回给客户端。
- 将source弹出的元素插入到列表destination,作为destination列表的的头元素。
举个例子,你有两个列表source和destination,source列表有元素a, b, c,destination列表有元素x, y, z,执行RPOPLPUSH source destination之后,source列表包含元素a, b,destination列表包含元素c, x, y, z ,并且元素c被返回。
如果source不存在,值nil被返回,并且不执行其他动作。
如果source和destination相同,则列表中的表尾元素被移动到表头,并返回该元素,可以把这种特殊情况视作列表的旋转(rotation)操作。
- 时间复杂度:
- O(1)
- 返回值:
- 被弹出的元素。
设计模式: 一个安全的队列
Redis的列表经常被用作队列(queue),用于在不同程序之间有序地交换消息(message)。一个程序(称之为生产者,producer)通过LPUSH命令将消息放入队列中,而另一个程序(称之为消费者,consumer)通过RPOP命令取出队列中等待时间最长的消息。
不幸的是,在这个过程中,一个消费者可能在获得一个消息之后崩溃,而未执行完成的消息也因此丢失。
使用RPOPLPUSH命令可以解决这个问题,因为它在返回一个消息之余,还将该消息添加到另一个列表当中,另外的这个列表可以用作消息的备份表:假如一切正常,当消费者完成该消息的处理之后,可以用LREM命令将该消息从备份表删除。
另一方面,助手(helper)程序可以通过监视备份表,将超过一定处理时限的消息重新放入队列中去(负责处理该消息的消费者可能已经崩溃),这样就不会丢失任何消息了。
BRPOPLPUSH是RPOPLPUSH的阻塞版本,当给定列表source不为空时,BRPOPLPUSH的表现和RPOPLPUSH一样。
当列表source为空时,BRPOPLPUSH命令将阻塞连接,直到等待超时,或有另一个客户端对source执行LPUSH或RPUSH命令为止。
超时参数timeout接受一个以秒为单位的数字作为值。超时参数设为0表示阻塞时间可以无限期延长(block indefinitely) 。
更多相关信息,请参考RPOPLPUSH命令。
- 时间复杂度:
- O(1)
- 返回值:
- 假如在指定时间内没有任何元素被弹出,则返回一个nil和等待时长。 反之,返回一个含有两个元素的列表,第一个元素是被弹出元素的值,第二个元素是等待时长。
SADD只接受单个member值。
SREM只接受单个member值。
SMOVE是原子性操作。
如果source集合不存在或不包含指定的member元素,则SMOVE命令不执行任何操作,仅返回0。否则,member元素从source集合中被移除,并添加到destination集合中去。
当destination集合已经包含member元素时,SMOVE命令只是简单地将source集合中的member元素删除。
当source或destination不是集合类型时,返回一个错误。
- 时间复杂度:
- O(1)
- 返回值:
- 如果member元素被成功移除,返回1。 如果member元素不是source集合的成员,并且没有任何操作对destination集合执行,那么返回0。
SRANDMEMBER命令。
SPOP相似,但SPOP将随机元素从集合中移除并返回,而SRANDMEMBER则仅仅返回随机元素,而不对集合进行任何改动。
- 时间复杂度:
- O(1)
- 返回值:
- 被选中的随机元素。 当key不存在或key是空集时,返回nil。
SINTER,但它将结果保存到destination集合,而不是简单地返回结果集。
如果destination集合已经存在,则将其覆盖。
destination可以是key本身。
- 时间复杂度:
- O(N * M),N为给定集合当中基数最小的集合,M为给定集合的个数。
- 返回值:
- 结果集中的成员数量。
SUNION,但它将结果保存到destination集合,而不是简单地返回结果集。
如果destination已经存在,则将其覆盖。
destination可以是key本身。
- 时间复杂度:
- O(N),N是所有给定集合的成员数量之和。
- 返回值:
- 结果集中的元素数量。
SDIFF,但它将结果保存到destination集合,而不是简单地返回结果集。
如果destination集合已经存在,则将其覆盖。
destination可以是key本身。
- 时间复杂度:
- O(N),N是所有给定集合的成员数量之和。
- 返回值:
- 结果集中的元素数量。
ZADD操作。
当key存在但不是有序集类型时,返回一个错误。
对有序集的更多介绍请参见sorted set。
- 时间复杂度:
- O(M*log(N)),N是有序集的基数,M为成功添加的新成员的数量。
- 返回值:
- 被成功添加的新成员的数量,不包括那些被更新的、已经存在的成员。
注解:在Redis2.4版本以前,ZADD每次只能添加一个元素。
ZREM每次只能删除一个元素。
ZRANGEBYSCORE命令。
- 时间复杂度:
- O(log(N)+M),N为有序集的基数,M为值在min和max之间的元素的数量。
- 返回值:
- score值在min和max之间的成员的数量。
lexicographical order)来排列。
如果你需要成员按score值递减(从大到小)来排列,请使用ZREVRANGE命令。
下标参数start和stop都以0为底,也就是说,以0表示有序集第一个成员,以1表示有序集第二个成员,以此类推。 你也可以使用负数下标,以-1表示最后一个成员,-2表示倒数第二个成员,以此类推。 超出范围的下标并不会引起错误。 比如说,当start的值比有序集的最大下标还要大,或是start > stop时,ZRANGE命令只是简单地返回一个空列表。 另一方面,假如stop参数的值比有序集的最大下标还要大,那么Redis将stop当作最大下标来处理。 可以通过使用WITHSCORES选项,来让成员和它的score值一并返回,返回列表以value1,score1, ..., valueN,scoreN的格式表示。 客户端库可能会返回一些更复杂的数据类型,比如数组、元组等。- 时间复杂度:
- O(log(N)+M),N为有序集的基数,而M为结果集的基数。
- 返回值:
- 指定区间内,带有score值(可选)的有序集成员的列表。
reverse lexicographical order)排列。
除了成员按score值递减的次序排列这一点外,ZREVRANGE命令的其他方面和ZRANGE命令一样。
- 时间复杂度:
- O(log(N)+M),N为有序集的基数,而M为结果集的基数。
- 返回值:
- 指定区间内,带有score值(可选)的有序集成员的列表。
lexicographical order)来排列(该属性是有序集提供的,不需要额外的计算)。
可选的LIMIT参数指定返回结果的数量及区间(就像SQL中的SELECT LIMIT offset, count),注意当offset很大时,定位offset的操作可能需要遍历整个有序集,此过程最坏复杂度为O(N)时间。
可选的WITHSCORES参数决定结果集是单单返回有序集的成员,还是将有序集成员及其score值一起返回。 该选项自Redis 2.0版本起可用。区间及无限
min和max可以是-inf和+inf,这样一来,你就可以在不知道有序集的最低和最高score值的情况下,使用ZRANGEBYSCORE这类命令。
默认情况下,区间的取值使用闭区间(小于等于或大于等于),你也可以通过给参数前增加(符号来使用可选的开区间(小于或大于)。
举个例子:
返回所有符合条件1 < score <= 5的成员;
返回所有符合条件5 < score < 10的成员。
- 时间复杂度:
- O(log(N)+M),N为有序集的基数,M为被结果集的基数。
- 返回值:
- 指定区间内,带有score值(可选)的有序集成员的列表。
reverse lexicographical order)排列。
除了成员按score值递减的次序排列这一点外,ZREVRANGEBYSCORE命令的其他方面和ZRANGEBYSCORE命令一样。
- 时间复杂度:
- O(log(N)+M),N为有序集的基数,M为结果集的基数。
- 返回值:
- 指定区间内,带有score值(可选)的有序集成员的列表。
ZREVRANK命令可以获得成员按score值递减(从大到小)排列的排名。
- 时间复杂度:
- O(log(N))
- 返回值:
- 如果member是有序集key的成员,返回member的排名。 如果member不是有序集key的成员,返回nil。
ZRANK命令可以获得成员按score值递增(从小到大)排列的排名。
- 时间复杂度:
- O(log(N))
- 返回值:
- 如果member是有序集key的成员,返回member的排名。 如果member不是有序集key的成员,返回nil。
ZRANGEBYSCORE命令。
- 时间复杂度:
- O(log(N)+M),N为有序集的基数,而M为被移除成员的数量。
- 返回值:
- 被移除成员的数量。
ZUNIONSTORE命令。
- 时间复杂度:
- O(N*K)+O(M*log(M)),N为给定key中基数最小的有序集,K为给定有序集的数量,M为结果集的基数。
- 返回值:
- 保存到destination的结果集的基数。
WATCH 命令对所有 key 的监视。
如果在执行 WATCH 命令之后, EXEC 命令或 DISCARD 命令先被执行了的话,那么就不需要再执行 UNWATCH 了。
因为 EXEC 命令会执行事务,因此 WATCH 命令的效果已经产生了;而 DISCARD 命令在取消事务的同时也会取消所有对 key 的监视,因此这两个命令执行之后,就没有必要执行 UNWATCH 了。
- 时间复杂度:
- O(1)
- 返回值:
- 总是 OK 。
EXEC 命令在一个原子时间内执行。
- 时间复杂度:
- O(1)。
- 返回值:
- 总是返回 OK 。
WATCH 命令的监视之下,且事务块中有和这个(或这些) key 相关的命令,那么 EXEC 命令只在这个(或这些) key 没有被其他命令所改动的情况下执行并生效,否则该事务被打断(abort)。
- 时间复杂度:
- 事务块内所有命令的时间复杂度的总和。
- 返回值:
- 事务块内所有命令的返回值,按命令执行的先后顺序排列。 当操作被打断时,返回空值 nil 。
WATCH 命令监视某个(或某些) key ,那么取消所有监视,等同于执行命令 UNWATCH 。
- 时间复杂度:
- O(1)。
- 返回值:
- 总是返回 OK 。
BGREWRITEAOF 命令执行失败,旧 AOF 文件中的数据也不会因此丢失或改变。
- 时间复杂度:
- O(N), N 为要追加到 AOF 文件中的数据数量。
- 返回值:
- 反馈信息。
BGSAVE 命令执行之后立即返回 OK ,然后 Redis fork出一个新子进程,原来的 Redis 进程(父进程)继续处理客户端请求,而子进程则负责将数据保存到磁盘,然后退出。
客户端可以通过 LASTSAVE 命令查看相关信息,判断 BGSAVE 命令是否执行成功。
- 时间复杂度:
- O(N), N 为要保存到数据库中的 key 的数量。
- 返回值:
- 反馈信息。
SAVE 、 BGSAVE 等),以 UNIX 时间戳格式表示。
- 时间复杂度:
- O(1)
- 返回值:
- 一个 UNIX 时间戳。
SLAVEOF 命令用于在 Redis 运行时动态地修改复制(replication)功能的行为。
通过执行 SLAVEOF host port 命令,可以将当前服务器转变为指定服务器的从属服务器(slave server)。
如果当前服务器已经是某个主服务器(master server)的从属服务器,那么执行 SLAVEOF host port 将使当前服务器停止对旧主服务器的同步,丢弃旧数据集,转而开始对新主服务器进行同步。
另外,对一个从属服务器执行命令 SLAVEOF NO ONE 将使得这个从属服务器关闭复制功能,并从从属服务器转变回主服务器,原来同步所得的数据集不会被丢弃。
利用“ SLAVEOF NO ONE 不会丢弃同步所得数据集”这个特性,可以在主服务器失败的时候,将从属服务器用作新的主服务器,从而实现无间断运行。
- 时间复杂度:
- SLAVEOF host port ,O(N), N 为要同步的数据数量。 SLAVEOF NO ONE , O(1) 。
- 返回值:
- 总是返回 OK 。
SHUTDOWN 命令执行以下操作:
- 停止所有客户端
- 如果有最少一个保存点在等待,执行 SAVE 命令
- 如果 AOF 选项被打开,更新 AOF 文件
- 服务器关闭
如果持久化被打开的话, SHUTDOWN 命令会保证服务器正常关闭而不丢失任何数据。
假如只是单纯地执行 SAVE 命令,然后再执行 QUIT 命令,则没有这一保证 —— 因为在执行 SAVE 之后、执行 QUIT 之前的这段时间中间,其他客户端可能正在和服务器进行通讯,这时如果执行 QUIT 就会造成数据丢失。
- 时间复杂度:
- 不明确
- 返回值:
- 执行失败时返回错误。 执行成功时不返回任何信息,服务器和客户端的连接断开,客户端自动退出。
CONFIG GET 命令用于取得运行中的 Redis 服务器的配置参数(configuration parameters),不过并非所有配置参数都被 CONFIG GET 命令所支持。
CONFIG GET 接受单个参数 parameter 作为搜索关键字,查找所有匹配的配置参数,其中参数和值以“键-值对”(key-value pairs)的方式排列。
比如执行 CONFIG GET s* 命令,服务器就会返回所有以 s 开头的配置参数及参数的值:
如果你只是寻找特定的某个参数的话,你当然也可以直接指定参数的名字:
使用命令 CONFIG GET * ,可以列出 CONFIG GET 命令支持的所有参数:
所有被 CONFIG SET 所支持的配置参数都可以在配置文件 redis.conf 中找到,不过 CONFIG GET 和 CONFIG SET 使用的格式和 redis.conf 文件所使用的格式有以下两点不同:
- 10kb 、 2gb 这些在配置文件中所使用的储存单位缩写,不可以用在 CONFIG 命令中, CONFIG SET 的值只能通过数字值显式地设定。 像 CONFIG SET xxx 1k 这样的命令是错误的,正确的格式是 CONFIG SET xxx 1000 。
- save 选项在 redis.conf 中是用多行文字储存的,但在 CONFIG GET 命令中,它只打印一行文字。 以下是 save 选项在 redis.conf 文件中的表示: save 900 1 save 300 10 save 60 10000 但是 CONFIG GET 命令的输出只有一行: redis> CONFIG GET save 1) "save" 2) "900 1 300 10 60 10000" 上面 save 参数的三个值表示:在 900 秒内最少有 1 个 key 被改动,或者 300 秒内最少有 10 个 key 被改动,又或者 60 秒内最少有 1000 个 key 被改动,以上三个条件随便满足一个,就触发一次保存操作。
- 时间复杂度:
- 不明确
- 返回值:
- 给定配置参数的值。
CONFIG SET 命令可以动态地调整 Redis 服务器的配置(configuration)而无须重启。
你可以使用它修改配置参数,或者改变 Redis 的持久化(Persistence)方式。
CONFIG SET 可以修改的配置参数可以使用命令 CONFIG GET * 来列出,所有被 CONFIG SET 修改的配置参数都会立即生效。
关于 CONFIG SET 命令的更多消息,请参见命令 CONFIG GET 的说明。
关于如何使用 CONFIG SET 命令修改 Redis 持久化方式,请参见 Redis Persistence 。
- 时间复杂度:
- 不明确
- 返回值:
- 当设置成功时返回 OK ,否则返回一个错误。
INFO 命令中的某些统计数据,包括:
- Keyspace hits (键空间命中次数)
- Keyspace misses (键空间不命中次数)
- Number of commands processed (执行命令的次数)
- Number of connections received (连接服务器的次数)
- Number of expired keys (过期key的数量)
- 时间复杂度:
- O(1)
- 返回值:
- 总是返回 OK 。
DEBUG OBJECT
- DEBUG OBJECT key
返回给定 key 的调试信息。
- 时间复杂度:
- O(1)
- 返回值:
- 当 key 存在时,返回有关信息。 当 key 不存在时,返回一个错误。
DEBUG SEGFAULT
- DEBUG SEGFAULT
令 Redis 服务器崩溃,调试用。
- 时间复杂度:
- 不明确
- 返回值:
- 无
MONITOR
MONITOR
实时打印出 Redis 服务器接收到的命令,调试用。
- 时间复杂度:
- 不明确
- 返回值:
- 总是返回 OK 。
SYNC
YNC
用于复制功能(replication)的内部命令。
- 时间复杂度:
- 不明确
- 返回值:
- 不明确