57

別のスレッドで実行HTTPServerしており (スレッドを停止する方法がないスレッド モジュールを使用しています...)、メイン スレッドもシャットダウンしたときにリクエストの処理を停止したいと考えています。

Python のドキュメントには、BaseHTTPServer.HTTPServerは のサブクラスであり、メソッドSocketServer.TCPServerをサポートしていると記載されていますが、 にはありません。shutdownHTTPServer

モジュール全体のBaseHTTPServerドキュメントはほとんどありません:(

4

11 に答える 11

29

私は「私はおそらくこれを自分でやらないだろうが、私は過去にそうしている」と言うことから始めるべきです。（SocketServer.pyからの）serve_foreverメソッドは次のようになります。

def serve_forever(self):
    """Handle one request at a time until doomsday."""
    while 1:
        self.handle_request()

（サブクラス内で）while 1をwhile self.should_be_runningに置き換えて、別のスレッドからその値を変更することができます。何かのようなもの：

def stop_serving_forever(self):
    """Stop handling requests"""
    self.should_be_running = 0
    # Make a fake request to the server, to really force it to stop.
    # Otherwise it will just stop on the next request.
    # (Exercise for the reader.)
    self.make_a_fake_request_to_myself()

編集：私はその時に使用した実際のコードを掘り起こしました：

class StoppableRPCServer(SimpleXMLRPCServer.SimpleXMLRPCServer):

    stopped = False
    allow_reuse_address = True

    def __init__(self, *args, **kw):
        SimpleXMLRPCServer.SimpleXMLRPCServer.__init__(self, *args, **kw)
        self.register_function(lambda: 'OK', 'ping')

    def serve_forever(self):
        while not self.stopped:
            self.handle_request()

    def force_stop(self):
        self.server_close()
        self.stopped = True
        self.create_dummy_request()

    def create_dummy_request(self):
        server = xmlrpclib.Server('http://%s:%s' % self.server_address)
        server.ping()
于 2008-11-06T13:21:35.237 に答える
25

イベントループは、SIGTERM、Ctrl+ C、またはshutdown()が呼び出されたときに終了します。

server_close()server_forever()リッスンしているソケットを閉じた後に呼び出す必要があります。

import http.server

class StoppableHTTPServer(http.server.HTTPServer):
    def run(self):
        try:
            self.serve_forever()
        except KeyboardInterrupt:
            pass
        finally:
            # Clean-up server (close socket, etc.)
            self.server_close()

ユーザーアクション（SIGTERM、Ctrl+ C、...）で停止可能なシンプルなサーバー：

server = StoppableHTTPServer(("127.0.0.1", 8080),
                             http.server.BaseHTTPRequestHandler)
server.run()

スレッドで実行中のサーバー:

import threading

server = StoppableHTTPServer(("127.0.0.1", 8080),
                             http.server.BaseHTTPRequestHandler)

# Start processing requests
thread = threading.Thread(None, server.run)
thread.start()

# ... do things ...

# Shutdown server
server.shutdown()
thread.join()
于 2016-02-23T11:18:35.847 に答える
24

私のpython2.6インストールでは、基盤となるTCPServerで呼び出すことができます-それはまだあなたのHTTPServer：の中にあります

TCPServer.shutdown


>>> import BaseHTTPServer
>>> h=BaseHTTPServer.HTTPServer(('',5555), BaseHTTPServer.BaseHTTPRequestHandler)
>>> h.shutdown
<bound method HTTPServer.shutdown of <BaseHTTPServer.HTTPServer instance at 0x0100D800>>
>>>
于 2008-11-06T13:30:25.033 に答える
15

使えると思います[serverName].socket.close()

于 2010-10-26T01:38:35.223 に答える
9

Python 2.7 では、shutdown() の呼び出しは機能しますが、非同期選択とポーリング ループを使用するため、serve_forever を介してサービスを提供している場合にのみ機能します。handle_request() を使用して独自のループを実行すると、皮肉なことにこの機能が除外されます。

SocketServer.py の BaseServer から:

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.__is_shut_down.clear()
    try:
        while not self.__shutdown_request:
            # 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 self in r:
                self._handle_request_noblock()
    finally:
        self.__shutdown_request = False
        self.__is_shut_down.set()

イベントを使用して完了を待機し、別のスレッドからブロッキングシャットダウンを実行するためのコードの一部を次に示します。

class MockWebServerFixture(object):
    def start_webserver(self):
        """
        start the web server on a new thread
        """
        self._webserver_died = threading.Event()
        self._webserver_thread = threading.Thread(
                target=self._run_webserver_thread)
        self._webserver_thread.start()

    def _run_webserver_thread(self):
        self.webserver.serve_forever()
        self._webserver_died.set()

    def _kill_webserver(self):
        if not self._webserver_thread:
            return

        self.webserver.shutdown()

        # wait for thread to die for a bit, then give up raising an exception.
        if not self._webserver_died.wait(5):
            raise ValueError("couldn't kill webserver")
于 2014-03-18T23:38:21.927 に答える
2

これは、 Python 3.7に対する Helgi の回答の簡易版です。

import threading
import time
from http.server import ThreadingHTTPServer, SimpleHTTPRequestHandler


class MyServer(threading.Thread):
    def run(self):
        self.server = ThreadingHTTPServer(('localhost', 8000), SimpleHTTPRequestHandler)
        self.server.serve_forever()
    def stop(self):
        self.server.shutdown()


if __name__ == '__main__':
    s = MyServer()
    s.start()
    print('thread alive:', s.is_alive())  # True
    time.sleep(2)
    s.stop()
    print('thread alive:', s.is_alive())  # False
于 2020-10-20T03:42:11.087 に答える
1

上記の可能な解決策をすべて試してみたところ、「いつか」問題が発生しました-どういうわけか実際にはうまくいきませんでした-そのため、私にとって常に機能する汚い解決策を作成することになりました:

上記のすべてが失敗した場合は、次のようなものを使用してブルート フォースでスレッドを強制終了します。

import subprocess
cmdkill = "kill $(ps aux|grep '<name of your thread> true'|grep -v 'grep'|awk '{print $2}') 2> /dev/null"
subprocess.Popen(cmdkill, stdout=subprocess.PIPE, shell=True)
于 2016-02-12T08:41:21.557 に答える