我通过创建一个继承自 HTTPServer 和 ThreadingMixIn 的类来设置一个线程化(使用 Python 线程)HTTP 服务器:
class ThreadedHTTPServer(ThreadingMixIn, HTTPServer):
pass
我有一个从 BaseHTTPRequestHandler 继承的处理程序类,我用这样的东西启动服务器:
class MyHandler(BaseHTTPRequestHandler):
...
server = ThreadedHTTPServer(('localhost', 8080), MyHandler)
# Prevent issues with socket reuse
server.allow_reuse_address = True
# Start the server
server.serve_forever()
这一切都很简单。我遇到的问题是,ThreadingMixIn、ForkingMixIn 或其他方式,请求最终阻塞了请求处理程序以返回。通过实现此示例代码可以很容易地看到这一点:
class MyHandler(BaseHTTPRequestHandler):
def respond(self, status_code):
self.send_response(status_code)
self.end_headers()
def do_GET(self):
print "Entered GET request handler"
time.sleep(10)
print "Sending response!"
respond(200)
如果服务器同时处理这些,那么我们将能够发送两个请求并看到服务器在发送任何一个响应之前都进入了两个 GET 请求处理程序。相反,服务器将为第一个请求输入 GET 请求处理程序,等待它返回,然后输入第二个请求(因此第二个请求需要大约 20 秒而不是 10 秒才能返回)。
我有没有一种简单的方法来实现一个服务器不等待处理程序返回的系统?具体来说,我正在尝试编写一个系统,该系统在返回任何请求(一种长轮询形式)之前等待接收多个请求,并遇到第一个请求等待阻止任何未来请求连接到服务器的问题。