2

尝试在 python 中为我的游戏创建 UDP 服务器/客户端时，我完全迷失了。我是这门语言的新手，在网络方面的经验有限。现在，服务器正在运行，但似乎没有收到来自客户端的任何消息。

服务器：

class GameServer:
    class GameServerUDPHandler(socketserver.BaseRequestHandler):
        def handle(self):
            data = self.request[0].strip()
            socket = self.request[1]
            print("{} wrote:".format(self.client_address[0]))
            print(data)
            socket.sendto(data.upper(), self.client_address)

    def __init__(self, port):
        self.server = socketserver.UDPServer(("localhost", port), self.GameServerUDPHandler)

    def start_server(self):
        self.server.serve_forever(

客户：

import socket
import sys

class GameClient:
    def __init__(self, port, host):
        self.port = port
        self.host = host
        self.socket = socket.socket(socket.AF_INET, socket.SOCK_DGRAM)

    def register(self):
        self.socket.sendto(bytes("register\n", "utf-8"), (self.host, self.port))
        self.numberID = int(self.socket.recv(1024))
        print("Received:   {}".format(self.numberID))

-主/程序开始

import gameserver
import gameclient

if __name__ == "__main__":
    server = gameserver.GameServer(1300)
    server.start_server()
    client = gameclient.GameClient(1300, "localhost")
    client.register()

注意：我最有可能犯多处错误，并且可能违反了该语言的几个最佳实践。我真的一点头绪都没有。

4

2 回答 2

3

问题是其中一些调用被阻塞了。特别是，该serve_forever()方法将永远运行，因此如果您希望程序的其余部分继续运行，则需要将其放在单独的线程上：

import threading
if __name__ == "__main__":
    server = GameServer(1300)
    server_thread = threading.Thread(target=lambda: server.start_server())
    server_thread.start()

    time.sleep(1) # Give it time to start up; not production quality code of course

    client = GameClient(1300, "localhost")
    client.register()

socket.recv()也是一个阻塞调用，但在这种情况下可能没问题。

于 2013-06-09T19:37:42.167 回答
1

似乎这个库不是异步的，因此您的第一次调用serve_forever将不会返回，并且您的客户端永远不会启动。您可以创建一个新线程来启动服务器或将您的客户端和服务器拆分为单独的进程。

于 2013-06-09T19:38:18.403 回答