1

创建在一段时间空闲后自行关闭的 Python 服务器（XML-RPC 服务器）的最简单方法是什么？

我想这样做，但我不知道在待办事项中该怎么做：

from SimpleXMLRPCServer import SimpleXMLRPCServer

# my_paths variable
my_paths = []

# Create server
server = SimpleXMLRPCServer(("localhost", 7789))
server.register_introspection_functions()

# TODO: set the timeout
# TODO: set a function to be run on timeout

class MyFunctions:
    def add_path(paths):
        for path in paths:
            my_paths.append(path)
        return "done"

    def _dispatch(self, method, params):
        if method == 'add_path':
            # TODO: reset timeout
            return add_path(*params)
        else:
            raise 'bad method'

server.register_instance(MyFunctions())

# Run the server's main loop
server.serve_forever()

我也尝试按照此处signal.alarm()的示例进行探索，但它不会在 Windows 下运行，这会向我抛出。AttributeError: 'module' object has no attribute 'SIGALRM'

谢谢。

4

1 回答 1

1

您可以创建自己的扩展服务器类，SimpleXMLRPCServer以便在空闲一段时间时关闭。

class MyXMLRPCServer(SimpleXMLRPCServer):
    def __init__(self, addr):
        self.idle_timeout = 5.0 # In seconds
        self.idle_timer = Timer(self.idle_timeout, self.shutdown)
        self.idle_timer.start()
        SimpleXMLRPCServer.__init__(self, addr)

    def process_request(self, request, client_address):
        # Cancel the previous timer and create a new timer
        self.idle_timer.cancel()
        self.idle_timer = Timer(self.idle_timeout, self.shutdown)
        self.idle_timer.start()
        SimpleXMLRPCServer.process_request(self, request, client_address)

现在，您可以使用这个类来创建您的服务器对象。

# Create server
server = MyXMLRPCServer(("localhost", 7789))
server.register_introspection_functions()
于 2012-10-08T14:22:52.743 回答