网站海外vps如何使用redis实现消息队列

已关闭留言

网站海外vps使用redis实现消息队列的示例:

redispubsub功能实现发布订阅模式,代码:

import redis

class Task(object):

def __init__(self):

self.rcon = redis.StrictRedis(host=’localhost’, db=5)

self.ps = self.rcon.pubsub()

self.ps.subscribe(‘task:pubsub:channel’)

def listen_task(self):

for i in self.ps.listen():

if i[‘type’] == ‘message’:

print “Task get”, i[‘data’]

if __name__ == ‘__main__’:

print ‘listen task channel’

Task().listen_task()

一诺网络提供的网站海外vps,是一款弹性计算服务类产品,其功能基本上与传统的x86物理服务器相当,具备分钟级交付效率,可快速部署和创建所需要的业务应用环境,服务器资源和配置支持弹性伸缩;拥有管理便捷、易于操作等诸多优点。可以极大降低用户的IT使用成本,用户无需亲自搭建基础设施、简化了运维和管理的日常工作量,使得用户能够更专注于自身的业务发展和创新。