活用redis经验及数据类型
2014-07-16 13:28:21   来源：   评论：0 点击：

学东西一定要活学活用！ 我用redis也有几年的历史了，今个才想到把集合可以当python list用，结合最近做了几个掺杂了redis的项目， 将遇到了一些个问题和开发中提高性能的方法分享出来，共同学习。

下面先简单讲讲Redis集合的数据类型。

Sets 就是一个集合，集合的概念就是一堆不重复值的组合。利用Redis提供的Sets数据结构，可以存储一些集合性的数据，比如在微博应用中，可以将一个用户 所有的关注人存在一个集合中，将其所有粉丝存在一个集合。Redis还为集合提供了求交集、并集、差集等操作，可以非常方便的实现如共同关注、共同喜好、 二度好友等功能，对上面的所有集合操作，你还可以使用不同的命令选择将结果返回给客户端还是存集到一个新的集合中。上面说的是新浪微博的应用。

sadd，创建一个集合，并添加数据。

1. [root@66 ~]# redis-cli
2. redis 127.0.0.1:6379>
3. redis 127.0.0.1:6379>
4. redis 127.0.0.1:6379> sadd xiaorui aaa
5. (integer) 1
6. redis 127.0.0.1:6379> sadd xiaorui bbb
7. (integer) 1
8. redis 127.0.0.1:6379> sadd xiaorui ccc
9. (integer) 1
10. redis 127.0.0.1:6379>
11. redis 127.0.0.1:6379> SMEMBERS xiaorui
12. 1) ”aaa”
13. 2) ”ccc”
14. 3) ”bbb”
15. redis 127.0.0.1:6379>
16. redis 127.0.0.1:6379>

set集合是不能写重复的内容的

1. redis 127.0.0.1:6379> sadd xiaorui fuck_shencan
2. (integer) 1
3. redis 127.0.0.1:6379> sadd xiaorui fuck_shencan
4. (integer) 0
5. redis 127.0.0.1:6379>

查看集合的大小

1. redis 127.0.0.1:6379> SCARD xiaorui
2. (integer) 3
3. redis 127.0.0.1:6379>

删除

1. redis 127.0.0.1:6379> SREM xiaorui aaa
2. (integer) 1
3. redis 127.0.0.1:6379> SMEMBERS xiaorui
4. 1) ”ccc”
5. 2) ”bbb”
6. redis 127.0.0.1:6379>

两个集合的交集之处

1. redis 127.0.0.1:6379> SADD key1 a
2. (integer) 1
3. redis 127.0.0.1:6379> SADD key1 b
4. (integer) 1
5. redis 127.0.0.1:6379> SADD key1 c
6. (integer) 1
7. redis 127.0.0.1:6379> SADD key2 c
8. (integer) 1
9. redis 127.0.0.1:6379> SADD key2 d
10. (integer) 1
11. redis 127.0.0.1:6379> SADD key2 e
12. (integer) 1
13. redis 127.0.0.1:6379> SINTER key1 key2
14. 1) ”c”
15. redis 127.0.0.1:6379>

可以把集合当成redis list队列用，需要注意的是set集合的成员模式是不能有重复的值的。如果你的值不重复，你又蛋疼，还真的可以把set集合当成队列使用。

1. redis 127.0.0.1:6379> sadd myset one
2. (integer) 1
3. redis 127.0.0.1:6379> sadd myset two
4. (integer) 1
5. redis 127.0.0.1:6379> sadd myset three
6. (integer) 1
7. redis 127.0.0.1:6379> SPOP myset
8. “one”
9. redis 127.0.0.1:6379> SMEMBERS myset
10. 1) ”three”
11. 2) ”two”
12. redis 127.0.0.1:6379>

前两天和朋友说，我那监控平台的内存吃的厉害，他一下子蹦出一句，redis吃内存肯定很大了。。。 nima，哥只是用他的大队列。这里说下，redis做队列的强度。一般来说100w条的队列数据，占用73M 内存左 右。200w条数据内存在154M内存左右。
redis的堵塞取任务，最好少用，超过5个线程去brpop的话，会把redis的cpu使用率顶到80%左右，而且严重会影响别的进程的访问，如果确定任务不是每时每刻都有的情况下，最好在你的程序控制下他的访问频次和时间的间隔。
python处理redis的时候，最好要用pool，速度和资源明显的节省。

1. >>> pool = redis.ConnectionPool(host=’localhost’, port=6379, db=0)
2. >>> r = redis.Redis(connection_pool=pool)

新版的redis是支持管道的，pipline ！有朋友不太理解，这里的管道有什么好处。 pyhton 虽然连接redis的时候用了连接池，但是这也只是连接方面做了keepalive而已，但是每次的命令推送，他还是一次命令一个交互的。 用了pipline管道堵塞后，他会把所有的命令合成一个管道符推送到redis服务端。这样的话就省事了很多。  这个特别适用于并发大的时候。

对于redis的pub sub通信性能的问题，可以用gevent来搞定。直接导入gevent猴子就可以了。

1. import gevent.monkey
2. gevent.monkey.patch_all()
3. #http://rfyiamcool.blog.51cto.com/1030776/1435539
4. import os
5. import sys
6. import fcntl
7. import gevent
8. from gevent.socket import wait_read
9.  
10. from redis import Redis
11.  
12. PID = os.getpid()
13.  
14. red = Redis(‘localhost’)
15.  
16. def echo_stdin():
17.     # make stdin non-blocking
18.     fcntl.fcntl(sys.stdin, fcntl.F_SETFL, os.O_NONBLOCK)
19.     red.publish(‘echo’, ”[%i] joined” % (PID,))
20.     while True:
21.         wait_read(sys.stdin.fileno())
22.         l = sys.stdin.readline().strip()
23.         s = ”[%i] %s” % (PID, l)
24.         # save to log
25.         red.rpush(‘echo_log’, s)
26.         # publish message
27.         red.publish(‘echo’, s)
28.         if l == ’quit’:
29.             break
30.  
31. def handler():
32.     pubsub = red.pubsub()
33.     # first subscribe, then print log (no race condition this way)
34.     pubsub.subscribe(‘echo’)
35.     # print log
36.     for line in red.lrange(‘echo_log’, 0, -1):
37.         print ’.', line
38.     # print channel
39.     for msg in pubsub.listen():
40.         print ’>’, msg['data']
41.  
42. gevent.spawn(handler)
43. gevent.spawn(echo_stdin).join()

当然对于普通的set get sadd hset 也是可以配合redis来使用的。但是，没啥优势，因为redis只启用了一个进程针对数据的读写，咱们从程序中复用的那几个连接，最后取数据，还是需要 调用那进程，你还不如让他老老实实的干活，别搞个多线程，让他白白折腾。 我这边做了压力测试，python2.7用个gevent后，批量的读写没什么突出的增长。

1. >>> import geventredis
2. >>> redis_client = geventredis.connect(’127.0.0.1′, 6379)
3. >>> redis_client.set(‘foo’, ’bar’)
4. ‘OK’
5. >>> for msg in redis_client.monitor():
6.        print msg