redis pubsub非阻塞接口(带线程)。

redis-pubsub-helper的Python项目详细描述


在某些情况下,阻止pyredis的订阅实现是很烦人的。 它是可以用某种技术控制的,但是这里有一个快速的方法 一条Python线。

注意:此实现只适用于少数情况。

示例

>>> import redis
>>> redisc = redis.Redis()
>>> import redispubsub
>>> pubsub = redispubsub.RedisPubsub(redisc.pubsub())
>>> pubsub.subscribe('1') # You SHOULD subscribe before starting thread.
>>> pubsub.start() # Start the router
>>> pubsub.dequeue('1')
{'pattern': None, 'type': 'subscribe', 'channel': '1', 'data': 1L}
>>> redisc.publish('1', 'test')
>>> pubsub.dequeue('1') # None returned
>>> pubsub.dequeue('1')
{'pattern': None, 'type': 'message', 'channel': '1', 'data': 'test'}
>>> pubsub.dequeue('1') # None returned

欢迎加入QQ群-->: 979659372 Python中文网_新手群

推荐PyPI第三方库


热门话题
orm如何在Java中实现规范化映射?   java以编程方式修改Xtext生成的Mwe2工作流   java正在覆盖外部文件中的现有数据,如何停止?   java在ANTLR BNF语法符号中epsilon的等价物是什么?   java如何使用Hibernate@Anyrelated注释?   代码生成生成java类并在运行时加载它   java Maven无法在本地jar文件中收集依赖项   java NetBeans IDE 8.2不显示错误消息   java Selenium web驱动程序找不到元素   java如何修复“拒绝访问属性”invoke“”的权限?   JavaApacheJClouds,从比日期更早的blob中删除blob的最佳方法   java如何比较和排序树集中的项目?   使用JavaSpring和无头/解耦CMS   java使用swagercodegen在不同的类中生成端点   Java外部Keylistener没有响应