Python连接Redis
2017-09-26 22:54
531 查看
Redis: 是一个高性能的key-value数据库。
简单来说就是:当你使用关系型数据库、文件或者其他介质存东西,性能不好反应慢,这个时候就要拿个东西做缓存。同类产品有好几种,目前比较流行,在我司进行商用的就是这个。目前,这玩意在集群状态下,为我们的百万级并发提供良好的支持。
今天,我们就来简单聊聊,如何用python操作redis。
牛小妹,把这个放进你的毕业设计,又能锦上添花哦。
redis的安装,参考文章
import redis
#后面是地址 端口
r = redis.Redis(host='127.0.0.1', port=6379)
import redis
pool = redis.ConnectionPool(host='192.168.0.110', port=6379)
r = redis.Redis(connection_pool=pool)
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()
说明:虽然提供了这么一个功能。但实际情况还是不建议使用。因为这个执行起来慢。另一方面,也没必要
定义公共的类,包装方法和初始化连接
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啦
简单来说就是:当你使用关系型数据库、文件或者其他介质存东西,性能不好反应慢,这个时候就要拿个东西做缓存。同类产品有好几种,目前比较流行,在我司进行商用的就是这个。目前,这玩意在集群状态下,为我们的百万级并发提供良好的支持。
今天,我们就来简单聊聊,如何用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啦
相关文章推荐
- python 交互式命令行数据库连接助手 -- mysql、sql server (mssql)、redis
- redis学习(1)python连接redis
- python连接自建redis服务器
- redis安装,语法和Python连接
- 使用python连接redis
- (linux)python之setuptools、easyinstall、pip安装及连接redis
- python3之flask框架连接redis数据库
- python下的redis连接
- Python与Redis的连接教程
- redis -- python操作连接redis简单示例
- [Redis]python连接redis
- python操作redis之连接reids
- linux下使用python连接redis
- python 连接 redis
- python连接redis单例模式
- [Python]python连接redis
- python连接MySQL、MongoDB、Redis、memcache等数据库的方法
- python连接redis3.x集群并做操作
- python 连接redis工具类
- (linux)python之setuptools、easyinstall、pip安装及连接redis