Redis： 是一个高性能的key-value数据库。

简单来说就是：当你使用关系型数据库、文件或者其他介质存东西，性能不好反应慢，这个时候就要拿个东西做缓存。同类产品有好几种，目前比较流行，在我司进行商用的就是这个。目前，这玩意在集群状态下，为我们的百万级并发提供良好的支持。

今天，我们就来简单聊聊，如何用python操作redis。

牛小妹，把这个放进你的毕业设计，又能锦上添花哦。

redis的安装，参考文章

1.python 连接redis

普通连接

import redis

#后面是地址 端口

r = redis.Redis(host='127.0.0.1', port=6379)

2.连接池

redis-py使用connection pool来管理对一个redis server的所有连接，避免每次建立、释放连接的开销

import redis

pool = redis.ConnectionPool(host='192.168.0.110', port=6379)

r = redis.Redis(connection_pool=pool)

3.管道

redis-py,默认情况下，每次都会进行连接池的连接和断开。若是想一次执行多条命令，进行事务性操作，就要用管道。

import redis

pool = redis.ConnectionPool(host='192.168.0.110', port=6379)

r = redis.Redis(connection_pool=pool)

pipe = r.pipeline(transaction=True)

r.set('zcx', '5555')

r.set('zcx', '6666')

pipe.execute()

说明：虽然提供了这么一个功能。但实际情况还是不建议使用。因为这个执行起来慢。另一方面，也没必要

4.发布订阅

在我们学习操作系统这本书的时候，里面有个生产者和消费者。在这里，我试着用redis来模拟

定义公共的类，包装方法和初始化连接

import redis

class redis_util(object):

def __init__(self):

self.__conn = redis.Redis(host='127.0.0.1', port=6379)

self.channel = 'mybaby' # 定义通道名称

def publish(self, msg): # 定义发布的方法

self.__conn.publish(self.channel, msg)

return True

def subscribe(self): # 定义订阅的方法

pub = self.__conn.pubsub()

pub.subscribe(self.channel)

pub.parse_response()

return pub

publisher发布者：

from polls.redis_utils import redis_util

obj = redis_util()

obj.publish('test')

subscriber订阅者：

from polls.redis_utils import redis_util

obj = redis_util()

redis_sub = obj.subscribe()

while True:

msg = redis_sub.parse_response()

print(msg)

至于发布订阅。只是表达有这么一个功能。但是，不建议用。后面，我将和大家一起,更深入的讨论这方面的问题。

好啦，今晚就玩到这，要去陪我家小baby啦