所以我从我之前的问题开始继续我的 python 游戏
Socket issue when using threads
我遇到了另一个问题，这次是关于 MySQL，它与我在 Pythonanywhere.com 上的托管服务器并存。错误如下:
Traceback (most recent call last):
File "/usr/local/lib/python3.4/dist-packages/mysql/connector/network.py", line 191, in recv_plain
chunk = self.sock.recv(1)
InterruptedError: [Errno 4] Interrupted system call
During handling of the above exception, another exception occurred:
Traceback (most recent call last):
File "/usr/local/lib/python3.4/dist-packages/flask/app.py", line 1817, in wsgi_app
response = self.full_dispatch_request()
File "/usr/local/lib/python3.4/dist-packages/flask/app.py", line 1477, in full_dispatch_request
rv = self.handle_user_exception(e)
File "/usr/local/lib/python3.4/dist-packages/flask/app.py", line 1381, in handle_user_exception
reraise(exc_type, exc_value, tb)
File "/usr/local/lib/python3.4/dist-packages/flask/_compat.py", line 33, in reraise
raise value
File "/usr/local/lib/python3.4/dist-packages/flask/app.py", line 1475, in full_dispatch_request
rv = self.dispatch_request()
File "/usr/local/lib/python3.4/dist-packages/flask/app.py", line 1461, in dispatch_request
return self.view_functions[rule.endpoint](**req.view_args)
File "/home/elvishknight1/mysite/flask_app.py", line 81, in intro
c.execute("SELECT * FROM players WHERE name=%s", (ID,))
File "/usr/local/lib/python3.4/dist-packages/mysql/connector/cursor.py", line 515, in execute
self._handle_result(self._connection.cmd_query(stmt))
File "/usr/local/lib/python3.4/dist-packages/mysql/connector/connection.py", line 684, in cmd_query
result = self._handle_result(self._send_cmd(ServerCmd.QUERY, query))
File "/usr/local/lib/python3.4/dist-packages/mysql/connector/connection.py", line 476, in _send_cmd
return self._socket.recv()
File "/usr/local/lib/python3.4/dist-packages/mysql/connector/network.py", line 212, in recv_plain
errno=2055, values=(self.get_address(), _strioerror(err)))
mysql.connector.errors.OperationalError: 2055: Lost connection to MySQL server at 'mysql.server:3306', system error: 4 Interrupted system call
2014-12-18 16:27:13,712 :Exception on /chat/ [GET]
Traceback (most recent call last):
File "/usr/local/lib/python3.4/dist-packages/mysql/connector/network.py", line 189, in recv_plain
packet = self.sock.recv(1)
InterruptedError: [Errno 4] Interrupted system call
随着服务器发出更多的 get 请求，上面的重复内容覆盖了错误日志
这是主要的应用程序代码(如果不是最pythonic的，请见谅)
from flask import Flask, render_template, request, jsonify
import mysql.connector
from grid import Grid
from game import Game
import random
from monster import Monster
from descriptions import Descriptions
from calculator import Calculator
app = Flask(__name__)
sql = mysql.connector.connect(user="elvishknight1", password="351797asd", host="mysql.server", database="elvishknight1$Overseer", buffered=True)
c = sql.cursor()
game=Game()
grid=Grid()
monsters = []
x=0
y=0
descriptions=Descriptions()
calculator = Calculator()
@app.route('/')
def index():
return render_template("intro.html",)
@app.route('/mod/351797Aa')
def moderator():
return render_template("moderate.html",)
@app.route('/mod/')
def worldMaker():
grid.makeGrid()
for x in range(4000):
dice = random.choice(list(descriptions.monsters.keys()))
mons = descriptions.monsters[dice]
monsters.append(Monster(dice, mons[0], mons[1], mons[2], mons[3], mons[4],
mons[5], mons[6], mons[7],mons[8], random.choice(list(range(200))),
random.choice(list(range(200)))))
c.execute("UPDATE players SET status='alive'")
game.gameStatus="started"
sql.commit()
return jsonify(result="ok")
@app.route('/player/')
def playerCount():
return jsonify(result=game.players)
@app.route('/finish/')
def clear():
game.gameStatus="working on it"
c.execute("delete from players")
grid.clearGrid()
sql.commit()
return jsonify(result="cleared")
@app.route('/chat/', methods=["GET"])
def chat():
chatter=[]
message = request.args.get('value')
user = request.args.get('user')
if(message[0:2]=="::"):
c.execute("INSERT INTO chatPending(user,message) VALUES(%s,%s)",
(user,message[2:]))
else:
del chatter[:]
c.execute("SELECT * from chatPending")
row = c.fetchall()
for r in row:
if row is not None:
chatter.append("<p>" + r[0] + ":: " + r[1] + "</p>")
sql.commit()
return jsonify(result=chatter)
@app.route('/load/', methods=["GET"])
def intro():
status=None
answer = request.args.get('value')
ID = request.args.get('ID')
c.execute("SELECT * FROM players WHERE name=%s", (ID,))
row = c.fetchone()
if row is not None:
status = row[3]
if(game.gameStatus=="started" or game.players>=200):
status="access denied"
if(status == None):
c.execute("INSERT INTO players (name, status) VALUES('" + answer + "', 'entering name')")
c.execute("SELECT * FROM players WHERE name=%s",(ID,))
row = c.fetchone()
if row is not None:
status = row[3]
if(status == 'entering name'):
data = "<p>What is in your past: choose one: <ul> <li> Chosen </li> <li> Magician </li> <li> Poet </li></ul></p>"
c.execute("UPDATE players SET status='entering past' WHERE name=%s",(ID,))
c.execute("SELECT * FROM players WHERE name=%s",(ID,))
row = c.fetchone()
if row is not None:
status = row[3]
elif(status == 'entering past'):
data = "<p>What is your class. Choose one: <ul> <li> Warrior </li> <li> Mage </li> <li> Rougue </li> <li> Bard </li></ul></p>"
c.execute("UPDATE players SET status='entering class' WHERE name=%s", (ID,))
c.execute("UPDATE players SET past=%s WHERE name=%s",(answer.capitalize(), ID))
c.execute("SELECT * FROM players WHERE name=%s",(ID,))
row = c.fetchone()
if row is not None:
status = row[3]
elif(status == 'entering class'):
data = "<p>What is your secret code?</p>"
c.execute("UPDATE players SET status='entering code' WHERE name=%s", (ID,))
c.execute("UPDATE players SET class=%s WHERE name=%s",(answer.capitalize(), ID))
c.execute("SELECT * FROM players WHERE name=%s",(ID,))
row = c.fetchone()
if row is not None:
status = row[3]
elif(status == 'entering code'):
data = "<p>OK all set. Waiting on the moderator!</p>"
c.execute("UPDATE players SET status='waiting' WHERE name=%s", (ID,))
c.execute("UPDATE players SET code=%s WHERE name=%s",(answer.capitalize(), ID))
c.execute("SELECT * FROM players WHERE name=%s",(ID,))
game.players+=1
row = c.fetchone()
if row is not None:
status = row[3]
past = row[1]
Class = row[2]
stats = calculator.calculateStats(past)
attacks = []
attackString=""
equipmentString=""
equipment = descriptions.classes[Class.capitalize()]
for a in list(equipment["lHand"][1]["moves"].keys()):
attacks.append(a)
for b in list(equipment["rHand"][1]["moves"].keys()):
attacks.append(b)
for att in attacks:
attackString=attackString + att + ","
for d in equipment:
equipmentString = equipmentString + d[0] + ","
c.execute("UPDATE players SET hp=%s,attack=%s,defense=%s,speed=%s, attacks=%s,"
+ "level=1, experience=0, nextLevel=50, energy=%s,inventory=%s, lHand=%s,rHand=%s,head=%s,hands=%s,chest=%s,legs=%s where name=%s",(stats[0],
stats[1],stats[2],stats[3],attackString,stats[4],equipmentString,
equipment["lHand"][0],equipment["rHand"][0],equipment["Head"][0],
equipment["Hands"][0],equipment["Chest"][0],equipment["Legs"][0],ID))
elif(status == 'waiting'):
data = "<p>Still waiting, please be patient.</p>"
elif(status=="access denied"):
data = "<p>Sorry. The player queue is full.</p>"
else:
data="error"
sql.commit()
return jsonify(result=data)
@app.route('/check/')
def checker():
status=None
ID = request.args.get('user')
c.execute("SELECT * FROM players WHERE name=%s", (ID,))
row = c.fetchone()
if row is not None:
status = row[3]
if(status=="alive"):
data="<p>Ready! Press >> to begin.</p>"
head="ok"
else:
data=""
head="not"
return jsonify(result=data, header=head)
@app.route('/move/')
def move():
y=0
x=0
data=""
answer = request.args.get('value')
ID = request.args.get('ID')
c.execute("SELECT * FROM players WHERE name=%s", (ID,))
row = c.fetchone()
if row is not None:
status = row[3]
x = row[5]
y = row[6]
HP = row[7]
attack = row[8]
defense = row[9]
speed = row[10]
level = row[13]
energy = row[17]
Class = row[2]
past = row[1]
attacks = row[11]
exp = row[14]
nextLevel = row[15]
if(answer=="start"):
c.execute("UPDATE players SET X=%s, y=%s WHERE name=%s",(random.choice(list(range(200))),random.choice(list(range(200))), ID))
data = "You are on a {} tile <br> {} <br>".format(grid.getLandType(x,y), grid.getDesc(x,y))
if(status!="dead"):
if(answer=='profile'):
data = "You're name is {} <br> You are a {} <br> {} <br> your class is: {} <br> your stats are: <br> Level:{} HP:{} <br> Attack:{} <br> Defense:{} <br> Speed:{} <br> Energy:{}".format(ID,past,descriptions.player_backstory[past.lower()],Class,level,HP,attack,defense,speed,energy)
elif(answer=="North" or answer=="N" and status!="fighting"):
if(y>0):
c.execute("UPDATE players SET y=%s WHERE name=%s", (y-1,ID))
data = "You are on a {} tile <br> {} <br>".format(grid.getLandType(x,y), grid.getDesc(x,y))
elif(answer=="East" or answer=="E" and status!="fighting"):
if(x<199):
c.execute("UPDATE players SET X=%s WHERE name=%s", (x+1,ID))
c.execute("SELECT * FROM players WHERE name=%s", (ID,))
row = c.fetchone()
if row is not None:
x = row[5]
data = "You are on a {} tile <br> {} <br>".format(grid.getLandType(x,y), grid.getDesc(x,y))
elif(answer=="South" or answer=="S" and status!="fighting"):
if(y<199):
c.execute("UPDATE players SET y=%s WHERE name=%s", (y+1,ID))
c.execute("SELECT * FROM players WHERE name=%s", (ID,))
row = c.fetchone()
if row is not None:
y = row[6]
data = "You are on a {} tile <br> {} <br>".format(grid.getLandType(x,y), grid.getDesc(x,y))
elif(answer=="West" or answer=="W" and status!="fighting"):
if(x>0):
c.execute("UPDATE players SET X=%s WHERE name=%s", (x-1,ID))
c.execute("SELECT * FROM players WHERE name=%s", (ID,))
row = c.fetchone()
if row is not None:
x = row[5]
data = "You are on a {} tile <br> {} <br>".format(grid.getLandType(x,y), grid.getDesc(x,y))
elif(answer=="Attack"):
for monster in monsters:
if(x==monster.X and y==monster.Y):
data = data + "The {} wakes up, the battle begins".format(monster.name)
c.execute("UPDATE players SET status='fighting' WHERE name=%s",(ID,))
monsterImFighting = monster
elif(answer == "Moves" and status=="fighting"):
c.execute("SELECT * FROM players WHERE name=%s", (ID,))
row = c.fetchone()
if row is not None:
attacks=row[11]
listOfAttacks=attacks.split(",")
for y in listOfAttacks:
data = data + y.capitalize() + "<br>"
elif(status=="fighting"):
for m in monsterImFighting.attacks.keys():
monsterName = m
for a in attacks.split(","):
if(a == answer):
damage = calculator.calculateDamage(attack,monsterImFighting.defense,
descriptions.classes[Class.capitalize()][1]["moves"][answer],
"normal","thunder")
data = data + "you deal {} damage to {}".format(damage,m)
monsterImFighting.hitpoints-=damage
if(monsterImFighting.hitpoints <=0):
data = data + "<br> You killed the {}. You gain {} exp.".format(monsterName,monsterImFighting.drops[0])
c.execute("UPDATE players SET experience=%s WHERE name=%s",(exp + monsterImFighting.drops[0],ID))
c.excecute("SELECT * FROM players WHERE name=%s",(ID,))
row = c.fetchone()
if row is not None:
exp = row[14]
c.excecute("UPDATE players SET status='alive' WHERE name=%s",(ID,))
if(exp >= nextLevel):
data = data + "You've leveled up!!"
c.execute("UPDATE players SET level=%s, attack=%s, defense=%s, speed=%s hp=%s WHERE name=%s",(level + 1,
attack + random.choice(list(range(3))),defense + random.choice(list(range(3))),
speed + random.choice(list(range(3))), HP +random.choice(list(range(20))),ID))
else:
shuf = random.choice(list(monsterImFighting.attacks.keys()))
damageReturn = calculator.calculateReturnDamage(monsterImFighting.attack, defense, monsterImFighting.attacks[shuf])
c.execute("UPDATE players SET hp=%s WHERE name=%s",(HP - damageReturn,ID))
data=data + "{} deals {} damage to you".format(monsterName,damageReturn)
if(HP<=0):
data= data + "You have perished at the hands of a {}".format(monsterName)
c.execute("UPDATE players SET status='dead' WHERE name=%s",(HP - damageReturn,ID))
else:
data = "You are on a {} tile <br> {} <br>".format(grid.getLandType(x,y), grid.getDesc(x,y))
else:
data = "Sorry, but you are dead. Dead people don't move"
sql.commit()
return jsonify(result=data, header=status)
@app.route('/event/')
def eventManager():
data = ""
ID=request.args.get("ID")
c.execute("SELECT * FROM players WHERE name=%s", (ID,))
row = c.fetchone()
if row is not None:
x = row[5]
c.execute("SELECT * FROM players WHERE name=%s", (ID,))
row = c.fetchone()
if row is not None:
y = row[6]
for monster in monsters:
if(monster.X == x and monster.Y == y):
data = "A {} is sleeping nearby!".format(monster.name)
return jsonify(result=data, header=len(monsters))
我在网上寻找解决方案，他们都提到这与您一次与服务器建立的连接数量有关(至少我是这样认为的)，但解决方案似乎...没有定论，尤其是关于在 pythonanywhere 上托管您的应用程序时如何处理这个问题。
如有任何帮助，我们将不胜感激!
最佳答案
PythonAnywhere 开发者在这里。我真的建议你通过 SQLalchemy 而不是直接使用 MySQL——它是一个位于你的代码和 mysql.connector 东西之间的库，它应该使你与所有连接管理东西隔离开来。这适用于 PythonAnywhere 或任何其他托管平台。
Flask 教程对使用 SQLAlchemy 有一些很好的提示。
关于python - 将mysql与pythonanywhere一起使用时出现错误4，我们在Stack Overflow上找到一个类似的问题： https://stackoverflow.com/questions/27552094/