11

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

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

4

1 回答 1

15 
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 秒才能完成。

于 2012-09-29T08:47:53.007 回答