fwq

如何用Redis实现延迟队列？ 0浏览 收藏 目前golang学习网上已经有很多关于数据库的文章了，自己在初次阅读这些文章中，也见识到了很多学习思路；那么本文《如何用Redis实现延迟队列？》，也希望能帮助到大家，如果阅读完后真的对你学习数据库有帮助，欢迎动动手指，评论留言并分享~ Redis实现延迟队列 Redis延迟队列 Redis 是通过有序集合（ZSet）的方式来实现延迟消息队列的，ZSet 有一个 Score 属性可以用来存储延迟执行的时间。 但需要无限循环检查任务，会消耗系统资源 class RedisDelayQueue(object):     """Simple Queue with Redis Backend     dq = RedisDelayQueue('delay:commtrans')     dq.put( 5 ,{'info':'测试 5555','time': timestamp_to_datetime_str(t + 5)})     print(dq.get())     """     def __init__(self, name, namespace='queue'):         """The default connection parameters are: host='localhost', port=6379, db=0"""         self.__db = get_redis_engine(database_name='spdb')         self.key = '%s:%s' % (namespace, name)     def qsize(self):         """Return the approximate size of the queue."""         return self.__db.zcard(self.key)     def empty(self):         """Return True if the queue is empty, False otherwise."""         return self.qsize() == 0…