使用 Python BaseHTTPServer 处理同时/异步请求

我通过创建一个继承自 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 秒）。

有没有一种简单的方法可以让我实现一个服务器不等待处理程序返回的系统？具体来说，我正在尝试编写一个系统，该系统在返回任何请求之前等待接收多个请求（一种长轮询的形式），并遇到第一个请求等待阻止任何未来请求连接到服务器的问题。

class ThreadedHTTPServer(ThreadingMixIn, HTTPServer):
    pass

足够。您的客户端可能不会发出并发请求。如果您并行发出请求，线程服务器将按预期工作。这是客户：

#!/usr/bin/env python
import sys
import urllib2

from threading import Thread

def make_request(url):
    print urllib2.urlopen(url).read()

def main():
    port = int(sys.argv[1]) if len(sys.argv) > 1 else 8000
    for _ in range(10):
        Thread(target=make_request, args=("http://localhost:%d" % port,)).start()

main()

以及对应的服务器：

import time
from BaseHTTPServer   import BaseHTTPRequestHandler, HTTPServer, test as _test
from SocketServer     import ThreadingMixIn


class ThreadedHTTPServer(ThreadingMixIn, HTTPServer):
    pass

class SlowHandler(BaseHTTPRequestHandler):
    def do_GET(self):
        self.send_response(200)
        self.send_header("Content-type", "text/plain")
        self.end_headers()

        self.wfile.write("Entered GET request handler")
        time.sleep(1)
        self.wfile.write("Sending response!")

def test(HandlerClass = SlowHandler,
         ServerClass = ThreadedHTTPServer):
    _test(HandlerClass, ServerClass)


if __name__ == '__main__':
    test()

所有 10 个请求都会在 1 秒内完成。如果您删除ThreadingMixIn根据服务器定义，所有 10 个请求都需要 10 秒才能完成。