PythonのマルチスレッドWebサーバー

Question

私は、PythonでマルチスレッドWebサーバーを作成しようとしていますが、一度に1つの要求にしか応答せず、理由を特定できません。私を助けてくれますか？

#!/usr/bin/env python2 
# -*- coding: utf-8 -*- 

from SocketServer import ThreadingMixIn 
from BaseHTTPServer import HTTPServer 
from SimpleHTTPServer import SimpleHTTPRequestHandler 
from time import sleep 

class ThreadingServer(ThreadingMixIn, HTTPServer): 
    pass 

class RequestHandler(SimpleHTTPRequestHandler): 
    def do_GET(self): 
     self.send_response(200) 
     self.send_header('Content-type', 'text/plain') 
     sleep(5) 
     response = 'Slept for 5 seconds..' 
     self.send_header('Content-length', len(response)) 
     self.end_headers() 
     self.wfile.write(response) 

ThreadingServer(('', 8000), RequestHandler).serve_forever() 

Answer 1

Doug Hellmannのブログからthisの投稿を確認してください。

from BaseHTTPServer import HTTPServer, BaseHTTPRequestHandler 
from SocketServer import ThreadingMixIn 
import threading 

class Handler(BaseHTTPRequestHandler): 

    def do_GET(self): 
     self.send_response(200) 
     self.end_headers() 
     message = threading.currentThread().getName() 
     self.wfile.write(message) 
     self.wfile.write('\n') 
     return 

class ThreadedHTTPServer(ThreadingMixIn, HTTPServer): 
    """Handle requests in a separate thread.""" 

if __name__ == '__main__': 
    server = ThreadedHTTPServer(('localhost', 8080), Handler) 
    print 'Starting server, use <Ctrl-C> to stop' 
    server.serve_forever() 

Answer 2

これは、マルチスレッドのSimpleHTTPServerのようなHTTPサーバーの別の良い例です：MultithreadedSimpleHTTPServer on GitHub。

Answer 3

私はComplexHTTPServerというPIPユーティリティを開発しました。このユーティリティは、SimpleHTTPServerのマルチスレッドバージョンです。それをインストールするには

、すべてを行う必要がある：

pip install ComplexHTTPServer 

それは同じくらい簡単です使用：

python -m ComplexHTTPServer [PORT] 

（デフォルトでは、ポートは8000です）

Answer 4

ストリーミングを破るこれらのソリューションがどれだけ多くの票を得ているのは驚くべきことです。ストリーミングが必要な場合は、ThreadingMixInとgunicornは応答を収集して最後に単位として書き込みます（ストリームが無限であれば実際には何もしません）。

BaseHTTPServerとスレッドを組み合わせる基本的な方法は問題ありません。しかし、デフォルトのBaseHTTPServerの設定では、すべてのリスナーに新しいソケットが再バインドされます。リスナーがすべて同じポートにある場合、Linuxでは機能しません。 serve_forever()コールの前にこれらの設定を変更してください。

次の例では、同じハンドラスレッドを同じポート上で起動し、各ハンドラはBaseHTTPServerで開始します。

import time, threading, socket, SocketServer, BaseHTTPServer 

class Handler(BaseHTTPServer.BaseHTTPRequestHandler): 

    def do_GET(self): 
     if self.path != '/': 
      self.send_error(404, "Object not found") 
      return 
     self.send_response(200) 
     self.send_header('Content-type', 'text/html; charset=utf-8') 
     self.end_headers() 

     # serve up an infinite stream 
     i = 0 
     while True: 
      self.wfile.write("%i " % i) 
      time.sleep(0.1) 
      i += 1 

# Create ONE socket. 
addr = ('', 8000) 
sock = socket.socket (socket.AF_INET, socket.SOCK_STREAM) 
sock.setsockopt(socket.SOL_SOCKET, socket.SO_REUSEADDR, 1) 
sock.bind(addr) 
sock.listen(5) 

# Launch 100 listener threads. 
class Thread(threading.Thread): 
    def __init__(self, i): 
     threading.Thread.__init__(self) 
     self.i = i 
     self.daemon = True 
     self.start() 
    def run(self): 
     httpd = BaseHTTPServer.HTTPServer(addr, Handler, False) 

     # Prevent the HTTP server from re-binding every handler. 
     # https://stackoverflow.com/questions/46210672/ 
     httpd.socket = sock 
     httpd.server_bind = self.server_close = lambda self: None 

     httpd.serve_forever() 
[Thread(i) for i in range(100)] 
time.sleep(9e9)