目前我正在使用 Python 中的 SimpleXMLRPCServer 模块编写一个应用程序。
此应用程序的基本目标是继续在服务器上运行并继续检查队列中的任何任务。如果它在队列中遇到任何新请求,则为该请求提供服务。
我正在尝试做的快照:
类 MyClass():
"""
This class will have methods which will be exposed to the clients
"""
def __init__(self):
taskQ = Queue.Queue()
def do_some_task(self):
while True:
logging.info("Checking the Queue for any Tasks..")
task = taskQ.get()
# Do some processing based on the availability of some task
Run Code Online (Sandbox Code Playgroud)
如果名称==“主要”:
server = SimpleXMLRPCServer.SimpleXMLRPCServer((socket.gethostname(), Port)
classObj = MyClass()
rpcserver.register_function(classObj.do_some_task)
rpcserver.serve_forever()
Run Code Online (Sandbox Code Playgroud)
一旦服务器启动,它就会永远留在 do_some_task 方法中的循环中,以不断检查队列中的任何任务。这就是我想要实现的目标。但现在我想优雅地关闭服务器。在这种情况下,我无法关闭服务器。
到目前为止,我已经尝试将全局标志 STOP_SERVER 用于“True”,并在 do_some_task while 循环中检查其状态以退出并停止服务器。但没有帮助。
尝试使用 SimpleXMLRPCServer 的 SHUTDOWN() …