我有一个 flask/gevent SocketIOServer,需要让它作为服务工作:
class TeleportService(win32serviceutil.ServiceFramework):
_svc_name_ = "TeleportServer"
_svc_display_name_ = "Teleport Database Backup Service"
_svc_description_ = "More info at www.elmalabarista.com/teleport"
def __init__(self, args):
win32serviceutil.ServiceFramework.__init__(self, args)
self.hWaitStop = win32event.CreateEvent(None, 0, 0, None)
def SvcStop(self):
self.ReportServiceStatus(win32service.SERVICE_STOP_PENDING)
win32event.SetEvent(self.hWaitStop)
def SvcDoRun(self):
servicemanager.LogMsg(servicemanager.EVENTLOG_INFORMATION_TYPE,
servicemanager.PYS_SERVICE_STARTED, (self._svc_name_, ''))
self.ReportServiceStatus(win32service.SERVICE_RUNNING)
runServer()
@werkzeug.serving.run_with_reloader
def runServer():
print 'Listening on %s...' % WEB_PORT
ws = SocketIOServer(('0.0.0.0', WEB_PORT),
SharedDataMiddleware(app, {}),
resource="socket.io",
policy_server=False)
gevent.spawn(runTaskManager).link_exception(lambda *args: sys.exit("important_greenlet died"))
ws.serve_forever()
但是,我不知道如何从 SvcStop 停止它,并且运行它有奇怪的行为,即在 runserver 被终止后发生命令行参数的服务解析。这意味着 flask 服务器运行,我可以从网络浏览器访问,但服务管理器将其列为“未启动”。例如在命令行中运行:
C:\Proyectos\TeleportServer>python service.py uninstall <--BAD PARAM, TO MAKE IT OBVIOUS
2013-02-13 16:19:30,786 - DEBUG: Connecting to localhost:9097
* Restarting with reloader
2013-02-13 16:19:32,650 - DEBUG: Connecting to localhost:9097
Listening on 5000...
Growl not available: Teleport Backup Server is started
KeyboardInterrupt <--- HERE I INTERRUPT WITH CTRL-C
Unknown command - 'uninstall'
Usage: 'service.py [options] install|update|remove|start [...]|stop|restart [...
]|debug [...]'
Options for 'install' and 'update' commands only:
--username domain\username : The Username the service is to run under
--password password : The password for the username
--startup [manual|auto|disabled] : How the service starts, default = manual
--interactive : Allow the service to interact with the desktop.
--perfmonini file: .ini file to use for registering performance monitor data
根据删除实时重新加载器的建议,这是剩下的代码。还是一样的问题
def SvcDoRun(自身): servicemanager.LogMsg(servicemanager.EVENTLOG_INFORMATION_TYPE,servicemanager.PYS_SERVICE_STARTED,(self._svc_name_, ''))
#self.timeout = 640000 #640 seconds / 10 minutes (value is in milliseconds)
self.timeout = 6000 #120 seconds / 2 minutes
# This is how long the service will wait to run / refresh itself (see script below)
notify.debug("Starting service")
ws = getServer()
while 1:
# Wait for service stop signal, if I timeout, loop again
gevent.sleep(0)
rc = win32event.WaitForSingleObject(self.hWaitStop, self.timeout)
# Check to see if self.hWaitStop happened
if rc == win32event.WAIT_OBJECT_0:
# Stop signal encountered
notify.debug("Stopping service")
ws.kill()
servicemanager.LogInfoMsg("TeleportService - STOPPED!") #For Event Log
break
else:
notify.debug("Starting web server")
ws.serve_forever()
最佳答案
要从 SvcStop 停止它,您需要在全局变量中存储对“ws”的引用(即,稍后可以检索它的地方)。 AFAIK“ws.kill()”然后应该结束循环。
run_with_reloader 装饰器似乎立即运行装饰函数,这可以解释为什么在运行 Web 服务器后处理命令行。是否需要自动重载,貌似装饰器只有在需要重载的时候才需要。
更新:添加示例服务代码
在一个不使用 flask 或 gevent 的项目中,我使用了这样的东西(删除了很多细节):
class Service (win32serviceutil.ServiceFramework):
def __init__(self, *args, **kwds):
self._mainloop = None
win32serviceutil.ServiceFramework.__init__(self, *args, **kwds)
def SvcStop(self):
self.ReportServiceStatus(win32service.SERVICE_STOP_PENDING)
if self._mainloop is not None:
self._mainloop.shutdown()
def SvcStart(self):
self.ReportServiceStatus(win32service.SERVICE_START_PENDING)
self._mainloop = ... .MainLoop()
self.ReportServiceStatus(win32service.SERVICE_RUNNING)
try:
self._mainloop.run_forever()
finally:
self.ReportServiceStatus(win32service.SERVICE_STOPPED)
win32serviceutil.HandleCommandLine(Service)
关于python - 如何制作 flask/gevent.socketio 服务器的 python windows 服务?,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/14863402/