【发布时间】:2012-02-13 08:21:04
【问题描述】:
我在这段代码中看到的问题是,虽然它正在工作,但一些客户端(玩家)发送到该服务器的信息最终会以方法“permission”结束,而原本打算以“clientRequests”结束,因为两者其中有recvfrom()。所以,如果我可以将我想要的信息指定为 recvfrom() 的参数,它会解决它。我相信使用 C++ 是可能的,但是使用 python 是可能的,以及如何? 使用 TCP 不存在这个问题,但我更喜欢 UDP。
类似:recvfrom(512, address=(ip, port)) ?
'permission' 用于处理新客户端的连接。
问题是位置、从客户端发送的事件等信息不会在“许可”下得到处理。
class Server:
def __init__(self):
#host = '192.168.0.2'
host = '127.0.0.1'
port = 50007
addr = (host, port)
self.UDPSock = socket(AF_INET, SOCK_DGRAM)
self.UDPSock.bind(addr)
self.UDPSock.settimeout(5.0)
self.searchForClients = True
self.playersOnline = []
threading.Thread(target=self.permission).start()
Gui.add_event("Server online on port %s" % port)
def permission(self):
global _status
while self.searchForClients:
time.sleep(0.5)
_status.set("Status: Running; Connected: %s" % len(self.playersOnline))
try:
clientMessage, addr = self.UDPSock.recvfrom(1024) # , MSG_PEEK
except:
clientMessage = ""
if clientMessage == "CONNECT" and addr not in self.playersOnline:
if self.searchForClients:
self.addNewClient(addr)
elif clientMessage == "DISCONNECT" and addr in self.playersOnline:
self.removeClient(addr)
Gui.add_event("No longer accepting logins")
return False
def clientRequests(self, addr):
latestRequest = time.time()
while addr in self.playersOnline:
time.sleep(0.01)
try:
data, requestAddr = self.UDPSock.recvfrom(1024)
except:
requestAddr, data = "", ""
if requestAddr == addr:
latestRequest = time.time()
dataCommand = data.split(':')
if time.time() - latestRequest > 2:
if addr in self.playersOnline:
self.removeClient(addr)
if not self.searchForClients:
Gui.add_event("Player %s(%s) forcibly removed" % addr)
return False
【问题讨论】:
标签: python networking udp recv