怎么用redis+python做消息队列

怎么用redis+python做消息队列

这篇文章主要讲解了“怎么用redis+python做消息队列”，文中的讲解内容简单清晰，易于学习与理解，下面请大家跟着小编的思路慢慢深入，一起来研究和学习“怎么用redis+python做消息队列”吧！

一、使用redis的List类型结合lpush 和 brpop 来实现

简介

• 首先redis的List 相当于一个队列，可以实现先进先出的规则

• 采用brpop 是因为当队列中没有的时候会进行阻塞，直到队列中有可弹出元素或者等待超时

模拟问题：

• 访问太多，服务器处理速度太慢，如果每隔用户等待，服务器反馈的话，时间太长，http连接超时，出现服务器错误。

模拟实现过程：

• 有一个客户端不断的往队列里放东西(数据)，采用多线程，模拟大量用户访问的情况

• 有一个服务器不断的从队列中取出打印，并设置每次打印时间睡2秒

redis的List结构介绍

key[value,value]key代表List的名字，[value,...]是值

客户client.py

importrandomimportthreadingimportredisimportconfiglock=threading.Lock()lock.acquire()lock.release()pool=redis.ConnectionPool(host=config.HOST,port=config.PORT,decode_responses=True,password=config.PASSWORD)r=redis.Redis(connection_pool=pool)#客户往redis中放数据deffun1(redisObj):value=random.randint(0,100)#往ccc列表中存放print("开始发送数据:",value)redisObj.lpush("print",str(value))foriinrange(100):threading.Thread(target=fun1,args=(r,)).start()

服务器server.py

importredisimporttimeimportconfigpool=redis.ConnectionPool(host=config.HOST,port=config.PORT,decode_responses=True,password=config.PASSWORD)r=redis.Redis(connection_pool=pool)#服务端不断的取whileTrue:value=r.brpop("print")time.sleep(2)print(value)

问题回顾

我们之前说存在阻塞太久断开连接的问题，解决下

方式： 将连接作为一个函数，进行错误捕捉，发生问题的时候重新连接。

importredisimporttimeimportconfigdefget_redis():pool=redis.ConnectionPool(host=config.HOST,port=config.PORT,decode_responses=True,password=config.PASSWORD)r=redis.Redis(connection_pool=pool)returnr#服务端不断的取r=get_redis()whileTrue:try:value=r.brpop("print")time.sleep(2)print(value)exceptExceptionase:print("等待超时重连")r=get_redis()

感谢各位的阅读，以上就是“怎么用redis+python做消息队列”的内容了，经过本文的学习后，相信大家对怎么用redis+python做消息队列这一问题有了更深刻的体会，具体使用情况还需要大家实践验证。这里是恰卡编程网，小编将为大家推送更多相关知识点的文章，欢迎关注！