Python Redis管道模式

762次阅读
没有评论
Python

Python Redis管道模式

我们知道所有对 Redis 的操作都需要发送消息给服务器,然后等待服务器处理,在服务器完成后才能执行下一个操作。

而使用管道(pipelining)模式就可以不用等待服务器处理完之后再进行下一个操作。这样可以将自己要执行的操作像脚本文件一样打包发送给服务器,服务器会依次执行。由于服务器其实是单线程模式运行的,所以不会出现第 3 个请求在第 1 个请求结束之前就开始的情况,这样就不会出现错误结果。这种做法主要是节省了中间的等待时间。

管道模式要求申请一个管道(pipeline)对象,然后在该对象中输入要执行的命令,最后启动管道,就是向服务器发送请求。

>>> r = redis.Redis(host='127.0.0.1',port=6379)    # 连接服务器
>>> pipe = r.pipeline()                                # 创建管道
>>> pipe.set('key1', 'val1')                        # 设定值
Pipeline<ConnectionPool<Connection<host=127.0.0.1,port=6379,db=0>>>
>>> pipe.set('key2', 'val2')
Pipeline<ConnectionPool<Connection<host=127.0.0.1,port=6379,db=0>>>
>>> pipe.set('key3', 'val3')
Pipeline<ConnectionPool<Connection<host=127.0.0.1,port=6379,db=0>>>
>>> pipe.execute()
[True, True, True]

从前面的输出可以看到管道执行操作之后返回值还是自己,所以可以用链式写法如下:

>>> r = redis.Redis(host='127.0.0.1',port=6379)    # 连接服务器
>>> pipe = r.pipeline()
>>> pipe.set('key1', 'val1').set('key2', 'val2').set('key3', 'val3')
Pipeline<ConnectionPool<Connection<host=127.0.0.1,port=6379,db=0>>>
>>> pipe.execute()
[True, True, True]

管道默认是原子性的,就是在执行 execute() 的过程中,其他的请求是不会被执行的,就算是其他的客户端在这时发送了请求,这个新的请求也只能等待 execute() 执行完毕后才可以开始执行。

神龙|纯净稳定代理IP免费测试>>>>>>>>天启|企业级代理IP免费测试>>>>>>>>IPIPGO|全球住宅代理IP免费测试

相关文章:

版权声明:[db:作者]2022-09-19发表,共计1180字。
新手QQ群:570568346,欢迎进群讨论 Python51学习