通过半天的不断折腾,在python代码中实现了redis的集群调用。
我在这里出的最大问题就是对redis和redis集群概念的混淆,从而导致在后面python代码里库的使用错误就出现了一系列问题。
Redis是一个单独的接口,通过这个接口实行key,value。在使用的时候通常是用redis这个库。
Redis集群是一个节点集合,在调用一个节点时其它节点都会响应。如果使用redis这个库的话肯定是不行的,如果可以的话我也就不用写这篇文章了。Redis集群在python代码中使用的是redis-py-cluster模块。
redis-py-cluster的使用:
我这里是使用了6个节点做例子
__author__ ="LUODI"
fromrediscluster importStrictRedisCluster
importsys
'''连接redis集群节点'''
defRedisCluster():
Redis_nodes
=[ {'host': '192.168.2.76', 'port': 6380},{'host': '192.168.2.76', 'port': 6381},{'host':
'192.168.2.76', 'port': 6382},{'host': '192.168.2.105', 'port': 7380},{'host': '192.168.2.105',
'port': 7381},{'host': '192.168.2.105', 'port': 7382},]
try:
redisconn
=StrictRedisCluster(startup_nodes=Redis_nodes)
exceptException,e:
print"Connect Redis node error:",e
sys.exit(1)
redisconn.set("name",'luodi')
#设置值
print(redisconn.get("name"))
#获取值
RedisCluster()```
网友评论