broker缓存: - mongodb 存硬盘 - redis 默认存内存,配置可存硬盘 - memcache 只能存内存
redis介绍REmote DIctionary Server(Redis)
redis官网:https://redis.io/
redis数据类型: - String 操作 set get - Hash 操作 hset hget - List 操作 lpush lrange - Set 操作 sadd smembers - Sort Set 操作
安装windows安装下载: https://github.com/MicrosoftArchive/redis/releases
启动服务: 切换目录到 C:\redis 运行 redis-server.exe redis.windows.conf
连接服务: 切换到redis目录下运行 redis-cli.exe -h 127.0.0.1 -p 6379
设置键值对 set myKey abc 取出键值对 get myKey
安装第三方库
pip install redis
简单连接
import redis
r = redis.Redis(host="127.0.0.1", port=6379)
r.set("foo", "xxx")
print(r.get("foo")) # b'xxx'
url链接
redis://username[:password]@host:port/db # TCP连接
连接池
import redis
pool = redis.ConnectionPool(host="127.0.0.1", port=6379)
r = redis.Redis(connection_pool=pool)
r.set("cat", "Tom")
print(r.get("cat"))
管道
import redis
pool = redis.ConnectionPool(host="127.0.0.1", port=6379)
r = redis.Redis(connection_pool=pool)
pipe=r.pipeline(transaction=True)
pipe.set("key1", "value1")
pipe.set("key2", "value2")
pipe.execute() # 一起执行
print(r.get("key1"))
发布者和订阅者
# 封装的公共类
import redis
class RedisHelper:
def __init__(self):
self.__conn = redis.Redis(host='127.0.0.1')
self.chan_sub = 'fm104.5'
self.chan_pub = 'fm104.5'
def public(self, msg):
self.__conn.publish(self.chan_pub, msg)
return True
def subscribe(self):
pub = self.__conn.pubsub()
pub.subscribe(self.chan_sub)
pub.parse_response()
return pub
# 发布者
import redis_helper
obj = redis_helper.RedisHelper()
obj.public('hello')
print("发布成功")
# 订阅者
import redis_helper
obj = redis_helper.RedisHelper()
redis_sub = obj.subscribe()
print("开始订阅")
while True:
msg = redis_sub.parse_response()
print(msg)
参考文章: redis-py https://github.com/andymccurdy/redis-py/
Redis 命令参考 http://doc.redisfans.com/
《Redis 教程-菜鸟教程》 http://www.runoob.com/redis/redis-tutorial.html
《Python之路【第九篇】:Python操作Redis》 http://www.cnblogs.com/wupeiqi/articles/5132791.html
《python 之路,Day12 - redis缓存数据库》 http://www.cnblogs.com/alex3714/articles/6217453.html