BaseHTTPRequestHandler 하위 클래스에서 BaseHTTPServer.serve_forever()를 중지하는 방법은 무엇입니까?
-
06-07-2019 - |
문제
나는 내 일을 하고 있다 HTTPServer
별도의 스레드에서(스레드를 중지할 방법이 없는 스레딩 모듈을 사용하여...) 메인 스레드도 종료될 때 요청 제공을 중지하려고 합니다.
Python 문서에는 다음과 같이 명시되어 있습니다. BaseHTTPServer.HTTPServer
의 하위 클래스입니다 SocketServer.TCPServer
, 이는 shutdown
방법이 있지만 누락되었습니다. HTTPServer
.
전체 BaseHTTPServer
모듈에는 문서가 거의 없습니다 :(
해결책
나는 "아마도 직접하지 않겠지 만 과거에는있다"고 말하면서 시작해야한다. sect_forever (SocketServer.py의) 메소드는 다음과 같습니다.
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()
다른 팁
내 Python 2.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>>
>>>
나는 당신이 사용할 수 있다고 생각합니다 [serverName].socket.close()
그것을 기반으로하는 또 다른 방법 http://docs.python.org/2/library/basehttpserver.html#more-examples, IS : Serv_forever () 대신 조건이 충족되는 한 서버가 각 요청 전후 조건을 확인하면서 계속 서빙하십시오. 예를 들어:
import CGIHTTPServer
import BaseHTTPServer
KEEP_RUNNING = True
def keep_running():
return KEEP_RUNNING
class Handler(CGIHTTPServer.CGIHTTPRequestHandler):
cgi_directories = ["/cgi-bin"]
httpd = BaseHTTPServer.HTTPServer(("", 8000), Handler)
while keep_running():
httpd.handle_request()
이벤트 루프는 SIGTERT에서 끝나고 Ctrl 키+씨 또는 언제 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, sigterm, Ctrl 키+씨, ...):
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()
Python 2.7에서는 Sop_forever를 통해 서비스를 제공하는 경우에만 Shutdown () 호출이 작동합니다. Async Select 및 폴링 루프를 사용하기 때문입니다. handle_request ()로 자신의 루프를 실행하면이 기능이 멍청한 차단 호출을 의미하기 때문에이 기능을 아이러니하게 제외합니다.
SocketServer.py 's 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")
이 방법은 성공적으로 사용하여 (Python 3) 웹 응용 프로그램 자체 (웹 페이지)에서 서버를 중지합니다.
import http.server
import os
import re
class PatientHTTPRequestHandler(http.server.SimpleHTTPRequestHandler):
stop_server = False
base_directory = "/static/"
# A file to use as an "server stopped user information" page.
stop_command = "/control/stop.html"
def send_head(self):
self.path = os.path.normpath(self.path)
if self.path == PatientHTTPRequestHandler.stop_command and self.address_string() == "127.0.0.1":
# I wanted that only the local machine could stop the server.
PatientHTTPRequestHandler.stop_server = True
# Allow the stop page to be displayed.
return http.server.SimpleHTTPRequestHandler.send_head(self)
if self.path.startswith(PatientHTTPRequestHandler.base_directory):
return http.server.SimpleHTTPRequestHandler.send_head(self)
else:
return self.send_error(404, "Not allowed", "The path you requested is forbidden.")
if __name__ == "__main__":
httpd = http.server.HTTPServer(("127.0.0.1", 8080), PatientHTTPRequestHandler)
# A timeout is needed for server to check periodically for KeyboardInterrupt
httpd.timeout = 1
while not PatientHTTPRequestHandler.stop_server:
httpd.handle_request()
이런 식으로 페이지는 기본 주소를 통해 제공됩니다 http://localhost:8080/static/
(예시 http://localhost:8080/static/styles/common.css
) 기본 핸들러가 제공합니다. http://localhost:8080/control/stop.html
서버의 컴퓨터에서 표시됩니다 stop.html
그런 다음 서버를 중지하면 다른 옵션이 금지됩니다.
나는 가능한 해결책을 모두 시도했고 결국 "언젠가"문제가 생겼습니다. 어떻게 든 실제로는 그렇게하지 않았습니다. 그래서 나는 항상 나를 위해 일하는 더러운 솔루션을 만들었습니다.
위의 모든 것이 실패하면 Brute Force는 다음과 같은 것을 사용하여 실을 죽입니다.
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)