3

我第一次在 Python 中使用套接字，我遇到了问题。

我的 UDP 服务器有一个线程化的请求处理程序，但由于它的工作方式（如这里所建议的那样），我无法弄清楚如何将参数传递给它。我需要它来访问应用程序中的其他对象，因为它必须通知它们网络中不同客户端执行的操作。然而，代表处理程序的类不能被实例化，所以它不能通过构造函数接受参数。

这是我的代码的简化版本。

class ThreadedUDPRequestHandler(socketserver.BaseRequestHandler):          

    def handle(self):
        data = self.request[0].strip()        
        socket = self.request[1]
        print ("{} wrote:".format(self.client_address[0]))
        print (data)
       #Ideally, I'd call a method of an object here


class ThreadedUDPServer(socketserver.ThreadingMixIn, socketserver.UDPServer):
    pass


class ServerManager():

    def __init__(self, player_box):
        self.player_box = player_box
        HOST, PORT = "xxx.xxx.xxx.xxx", 9999
        self.server = ThreadedUDPServer((HOST, PORT), ThreadedUDPRequestHandler)
        ip, port = self.server.server_address

    def start(self):             
        server_thread = threading.Thread(target=self.server.serve_forever)
        server_thread.start()

    def stop(self):
        self.server.shutdown()

在这种情况下，我希望请求处理程序访问的对象是 player_box。目标是在每次发出请求时调用该对象的方法。有没有办法做到这一点，或者我应该使用不同的方法？

我注意到这里有一个类似的问题，但建议的解决方案对我根本不起作用。事实上，这对我来说没有多大意义......

4

1 回答 1

1

这可能有点难看，但这是我最好的主意：

class ThreadedUDPRequestHandler(socketserver.BaseRequestHandler):
    PLAYER_BOX = None
    def handle(self):
       data = self.request[0].strip()        
       # (...)
       self.PLAYER_BOX.foo()

class ServerManager():

    def __init__(self, player_box):
        class ThreadedUDPRequestHandlerWithPlayerBox(ThreadedUDPRequestHandler):
            PLAYER_BOX = player_box
        HOST, PORT = "xxx.xxx.xxx.xxx", 9999
        self.server = ThreadedUDPServer((HOST, PORT), ThreadedUDPRequestHandlerWithPlayerBox)

如您所见，这个想法有两个部分：

  1. 让你的处理程序类有一个类属性，可以从它的方法访问。
  2. 创建此类的子类，其中上述属性将设置为所需的值（在您的情况下为 player_box 对象）。

我希望这有帮助。

于 2012-10-14T12:24:54.997 回答