12

我正在开发一个需要嵌入 HTTP 服务器的守护程序。我正在尝试使用 BaseHTTPServer 来执行此操作，当我在前台运行它时，它工作正常，但是当我尝试将守护进程分叉到后台时，它停止工作。我的主应用程序继续工作，但 BaseHTTPServer 没有。

我相信这与 BaseHTTPServer 将日志数据发送到 STDOUT 和 STDERR 的事实有关。我将这些重定向到文件。这是代码片段：

# Start the HTTP Server
server = HTTPServer((config['HTTPServer']['listen'],config['HTTPServer']['port']),HTTPHandler)

# Fork our process to detach if not told to stay in foreground
if options.foreground is False:
    try:
        pid = os.fork()
        if pid > 0:
            logging.info('Parent process ending.')
            sys.exit(0)            
    except OSError, e:
        sys.stderr.write("Could not fork: %d (%s)\n" % (e.errno, e.strerror))
        sys.exit(1)

    # Second fork to put into daemon mode
    try: 
        pid = os.fork() 
        if pid > 0:
            # exit from second parent, print eventual PID before
            print 'Daemon has started - PID # %d.' % pid
            logging.info('Child forked as PID # %d' % pid)
            sys.exit(0) 
    except OSError, e: 
        sys.stderr.write("Could not fork: %d (%s)\n" % (e.errno, e.strerror))
        sys.exit(1)


    logging.debug('After child fork')

    # Detach from parent environment
    os.chdir('/') 
    os.setsid()
    os.umask(0) 

    # Close stdin       
    sys.stdin.close()

    # Redirect stdout, stderr
    sys.stdout = open('http_access.log', 'w')
    sys.stderr = open('http_errors.log', 'w')    

# Main Thread Object for Stats
threads = []

logging.debug('Kicking off threads')

while ...
  lots of code here
...

server.serve_forever()

我在这里做错了什么还是 BaseHTTPServer 以某种方式阻止了守护进程？

编辑：更新代码以演示额外的、以前缺少的代码流，并且 log.debug 显示在我的分叉后台守护程序中，我在分叉后点击代码。

4

6 回答 6

8

经过一番谷歌搜索后，我终于偶然发现了这个 BaseHTTPServer 文档，之后我得到了：

from BaseHTTPServer import BaseHTTPRequestHandler, HTTPServer
from SocketServer import ThreadingMixIn

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

server = ThreadedHTTPServer((config['HTTPServer']['listen'],config['HTTPServer']['port']), HTTPHandler)
server.serve_forever()

这在很大程度上是在我分叉并最终解决了我的问题之后发生的。

于 2009-05-20T21:17:13.127 回答
4

以下是使用python-daemon库执行此操作的方法：

from BaseHTTPServer import (HTTPServer, BaseHTTPRequestHandler)
import contextlib

import daemon

from my_app_config import config

# Make the HTTP Server instance.
server = HTTPServer(
    (config['HTTPServer']['listen'], config['HTTPServer']['port']),
    BaseHTTPRequestHandler)

# Make the context manager for becoming a daemon process.
daemon_context = daemon.DaemonContext()
daemon_context.files_preserve = [server.fileno()]

# Become a daemon process.
with daemon_context:
    server.serve_forever()

与守护程序一样，您需要决定在程序成为守护程序后如何与程序交互。例如，您可能会注册一个 systemd 服务，或编写一个 PID 文件等。不过，这些都超出了问题的范围。

特别是，它超出了问题的范围：一旦它成为一个守护进程（必须与任何控制终端分离），我该如何停止守护进程？作为定义程序行为的一部分，这由您决定。

于 2010-02-11T23:13:09.603 回答
2

首先实例化一个 HTTPServer。但是您实际上并没有告诉它在任何提供的代码中开始服务。在您的子进程中尝试调用server.serve_forever().

请参阅此以供参考

于 2009-05-20T17:06:00.043 回答
1

一个对我有用的简单解决方案是覆盖BaseHTTPRequestHandler方法log_message()，因此我们防止在标准输出中进行任何类型的写入，并避免在妖魔化时出现问题。

class CustomRequestHandler(BaseHTTPServer.BaseHTTPRequestHandler):

    def log_message(self, format, *args):
            pass

...
rest of custom class code
...
于 2011-12-20T15:58:56.323 回答
0

只需使用daemontools或其他类似的脚本，而不是滚动您自己的守护进程。最好不要在脚本中使用它。

此外，您最好的选择：不要使用 BaseHTTPServer。这真的很糟糕。python 有很多不错的HTTP 服务器，例如cherrypy或paste。两者都包括现成的守护脚本。

于 2009-05-20T16:15:36.230 回答
0

自从我最初发布以来，这已经征求了答案，我想我会分享一些信息。

输出的问题与日志记录模块的默认处理程序使用 StreamHandler 的事实有关。处理此问题的最佳方法是创建您自己的处理程序。如果您想使用默认的日志记录模块，您可以执行以下操作：

# Get the default logger
default_logger = logging.getLogger('')

# Add the handler
default_logger.addHandler(myotherhandler)

# Remove the default stream handler
for handler in default_logger.handlers:
    if isinstance(handler, logging.StreamHandler):
        default_logger.removeHandler(handler)

同样在这一点上，我已经开始为我的嵌入式 http 服务器使用非常好的Tornado项目。

于 2010-02-13T05:07:24.410 回答