执行代码后提示too many connections 和watched variable changed

执行代码后提示too many connections 和watched variable changed

#coding:utf-8

from concurrent.futures import ThreadPoolExecutor
from redis_db import pool
import redis
import random

s=set()
while True:
if len(s)>=1000:
break
num=random.randint(10000,100000)
s.add(num)

con=redis.Redis(
connection_pool=pool
)

try:
con.delete("kill_total","kill_num","kill_flag","kill_user")
con.set("kill_total",50)
con.set("kill_num",0)
con.set("kill_flag",1)
con.expire("kill_flag",600)
except Exception as e:
print(e)
finally:
del con

executor = ThreadPoolExecutor(200)

def buy():
connection = redis.Redis(connection_pool=pool)
pipline = connection.pipeline()
try:
if connection.exists("kill_flag") == 1:
pipline.watch("kill_num", "kill_user")
total = int(pipline.get("kill_total").decode("utf-8"))
num = int(pipline.get("kill_num").decode("utf-8"))
if num<total:
pipline.multi()
pipline.incr("kill_num")
user_id=s.pop()
print(user_id)
pipline.rpush("kill_user",user_id)
pipline.execute()
except Exception as e:
print(e)
finally:
if "pipline" in dir():
pipline.reset()
del connection

for i in range(1000):
executor.submit(buy)

print("秒杀已经结束")

https://img1.sycdn.imooc.com//climg/61381af309b36cda13700987.jpg

正在回答

登陆购买课程后可参与讨论,去登陆

1回答

同学,你好!

1、出现too many connections是因为redis_db中的pool在建立时有一个参数max_connections,这个参数是最大连接数。若参数的值设置的过小,就会提示too many connections,需要改大一些,例如200,如下图

http://img1.sycdn.imooc.com//climg/5eb1289a09c2d5c102790142.jpg

2、Watched variable changed:watch 执行之后, execute执行之前,有其他客户端修改了watch中指定的key的值, 程序的事务就会抛出异常 redis.WatchError

祝学习愉快!

  • 为什么老师电脑演示里没有出现这些,用的是一样的代码

    2021-12-21 16:36:07
  • 同学,你好!

    出现以上信息是因为最大连接数设置太少的原因,导致连接不够用,同学可以将最大连接数改大,如下图:

    https://img1.sycdn.imooc.com//climg/61c198c409b9c4dd05630570.jpg

    祝学习愉快~

    2021-12-21 17:06:50
问题已解决,确定采纳
还有疑问,暂不采纳

恭喜解决一个难题,获得1积分~

来为老师/同学的回答评分吧

0 星
请稍等 ...
意见反馈 帮助中心 APP下载
官方微信

在线咨询

领取优惠

免费试听

领取大纲

扫描二维码,添加
你的专属老师