redis上手

如何在windows电脑上部署一个redis

有以下几种方案:
(1)最佳方案是安装redis on Ubuntu on windows
教程见: https://github.com/ServiceStack/redis-windows

image.png

(2) 最方便的方案是直接下载exe安装程序.
下载链接
下载之后直接点击安装就可以了.

如何配置redis, 更改配置之后何时生效?

• 启动redis的时候指定配置文件. 如下,可以设置配置文件.这个配置文件更改之后,再下次重启的时候生效.

cd D:\Program Files\Redis
redis-server.exe redis.windows.conf

• 也可以在redis-cli终端中进行配置. 其中config get *是用来查看所有的配置项.此时修改的配置项立刻生效.

cd D:\Program Files\Redis
redis-cli.exe
config set notify-keyspace-events xK
config get * 

如何插入数值

import redis
r = redis.StrictRedis(host='localhost', port=6379, db=0)
r.set('foo', 'bar')
r.get('foo')

如何订阅-发布消息

import redis
r = redis.StrictRedis(host='localhost', port=6379, db=0)
p = r.pubsub() 
p.subscribe('my-first-channel', 'my-second-channel')  #增加一个指定channel名的订阅
p.psubscribe('my-*')#增加一个指定名称模式的订阅
p.subscribe('my-first-channel') #重复订阅的命令会增加一条change_log,但不会对订阅列表有实质影响.
p.unsubscribe() # 取消所有订阅
message_list = []
for _ in range(10):
    message_list.append(p.get_message())  # 一次输出订阅列表的change_log.如果已经输出完了,则返回none.
print(message_list) 
# [{'type': 'subscribe', 'pattern': None, 'channel': b'my-first-channel', 'data': 1}, {'type': 'subscribe', 'pattern': None, 'channel': b'my-second-channel', 'data': 2}, {'type': 'psubscribe', 'pattern': None, 'channel': b'my-*', 'data': 3}, {'type': 'unsubscribe', 'pattern': None, 'channel': b'my-second-channel', 'data': 2}, {'type': 'unsubscribe', 'pattern': None, 'channel': b'my-first-channel', 'data': 1}, None, None, None, None, None]

如何利用callback函数来处理消息

使用p.subscribe方法可以把一个callback函数关联到一个channel上去.这里的坑: 订阅请求是异步执行的.

import redis
import time
r = redis.StrictRedis(host='localhost', port=6379, db=0)
p = r.pubsub()
def my_handler(message):
    print('my-handler:{}'.format(message))
p.subscribe(**{'my-channel':my_handler}) #使用这个方式来把callback函数关联到某个channel上去, 这个可能仅是发一个request过去,没有等到确认就返回了.
time.sleep(0.1) #这里不进行等待的话每次出来的结果是不一样的．
msg_list = []
msg_list.append(p.get_message())
r.publish('my-channel','good data')
msg_list2 = []
for _ in range(10):
    msg_list2.append(p.get_message())
    print(msg_list2)
print(msg_list)

如何开启与关闭订阅线程?

开启线程: 使用p.run_in_thread方法来开启线程.
关闭线程:thread.stop方法来关闭线程.

p.subscribe(**{'my-channel': my_handler})
thread = p.run_in_thread(sleep_time=0.001)
r.publish('my-channel', 'good_news') # 可以调用my_handle
thread.stop()

如果p订阅了一个没有绑定callback函数的channel,会报错.因为这么做会导致订阅的消息无法被消费掉.

image.png

如何使用redis来传递python对象

使用redis的pubsub功能可以传递二进制编码. 如果想传递一个python:py_obj. 发送的时候使用json.dumps(py_obj), 接收者使用json.loads(py_obj).
推测通过pickle做序列化也可以,但是安全性存疑.

如何管理redis的订阅列表

功能: PUBSUB类实例的两种订阅列表. 一种是普通的频道订阅, 另一种是pattern频道订阅.这两个列表分别使用subscribe,psubscribe来增加订阅列表, 使用unsubscribe, 与punsubscribe(必须输入参数)来取消订阅, 使用channels,与patterns来插件订阅列表.\

如何利用redis做微服务?

redis-dealer: 一个基于redis的微型处理单元. 功能类似于flask这样的微服务.只是数据传递不再通过web端口,而是通过redis中的指定通道. 一个redis可以对应多个dealer, 一个dealer也可以对应多个redis.
相对于flask的优势: 1.这个微服务对应一个redis的一个订阅渠道而已. 而一个flask则需要占用一个端口.
2.向这个微服务发其请求比较简单,直接使用redis.publish就可以.
3.利用redis的expire功能,可以方便时间定时启动程序. 而flask则没有这么简洁的方法.
4.在一个脚本里面可以启动N个redis-dealer,而一个脚本通常只能启动一个flask.