我正在用 Python 编写一个小型 Web 服务器，使用 BaseHTTPServer 和 BaseHTTPServer.BaseHTTPRequestHandler 的自定义子类。是否可以在多个端口上进行监听？
我现在在做什么：
class MyRequestHandler(BaseHTTPServer.BaseHTTPRequestHandler):
def doGET
[...]
class ThreadingHTTPServer(ThreadingMixIn, HTTPServer):
pass
server = ThreadingHTTPServer(('localhost', 80), MyRequestHandler)
server.serve_forever()
【问题讨论】：
当然；只需在两个不同线程中的两个不同端口上启动两个不同的服务器，每个线程都使用相同的处理程序。这是我刚刚编写和测试的一个完整的工作示例。如果您运行此代码，那么您将能够在 http://localhost:1111/ 和 http://localhost:2222/ 获得一个 Hello World 网页
from threading import Thread
from SocketServer import ThreadingMixIn
from BaseHTTPServer import HTTPServer, BaseHTTPRequestHandler
class Handler(BaseHTTPRequestHandler):
def do_GET(self):
self.send_response(200)
self.send_header("Content-type", "text/plain")
self.end_headers()
self.wfile.write("Hello World!")
class ThreadingHTTPServer(ThreadingMixIn, HTTPServer):
daemon_threads = True
def serve_on_port(port):
server = ThreadingHTTPServer(("localhost",port), Handler)
server.serve_forever()
Thread(target=serve_on_port, args=[1111]).start()
serve_on_port(2222)
更新：
这也适用于 Python 3，但需要稍微更改三行：
from socketserver import ThreadingMixIn
from http.server import HTTPServer, BaseHTTPRequestHandler
和
self.wfile.write(bytes("Hello World!", "utf-8"))
【讨论】：
daemon_threads = True 添加为class ThreadingHTTPServer(ThreadingMixIn, HTTPServer) 的成员，否则生成的线程将不会停止并且您的Python 进程将不会退出，直到您发送更多请求以帮助这些线程意识到它们需要停止.我相应地编辑了您的答案，如果有问题请告诉我。
不容易。你可以有两个 ThreadingHTTPServer 实例，编写你自己的 serve_forever() 函数（别担心它不是一个复杂的函数）。
现有功能：
def serve_forever(self, poll_interval=0.5):
"""Handle one request at a time until shutdown.
Polls for shutdown every poll_interval seconds. Ignores
self.timeout. If you need to do periodic tasks, do them in
another thread.
"""
self.__serving = True
self.__is_shut_down.clear()
while self.__serving:
# XXX: Consider using another file descriptor or
# connecting to the socket to wake this up instead of
# polling. Polling reduces our responsiveness to a
# shutdown request and wastes cpu at all other times.
r, w, e = select.select([self], [], [], poll_interval)
if r:
self._handle_request_noblock()
self.__is_shut_down.set()
所以我们的替换是这样的：
def serve_forever(server1,server2):
while True:
r,w,e = select.select([server1,server2],[],[],0)
if server1 in r:
server1.handle_request()
if server2 in r:
server2.handle_request()
【讨论】：
我会说这种简单的事情的线程是矫枉过正的。你最好使用某种形式的异步编程。
这里是一个使用Twisted的例子：
from twisted.internet import reactor
from twisted.web import resource, server
class MyResource(resource.Resource):
isLeaf = True
def render_GET(self, request):
return 'gotten'
site = server.Site(MyResource())
reactor.listenTCP(8000, site)
reactor.listenTCP(8001, site)
reactor.run()
我还认为让每个端口都以相同的方式处理看起来更简洁，而不是让主线程处理一个端口而另一个线程处理另一个。可以说这可以在线程示例中修复，但是您使用的是三个线程。
【讨论】：