Pyro4.Daemon 对象的 requestLoop 方法存在一些问题。
我想要的是远程调用“stop()”方法来释放 requestLoop 函数并关闭我的守护进程。
这个小例子不起作用
服务器
#!/usr/bin/python
# -*- coding: utf-8 -*-
from daemon import Pyro4
class Audit(object):
def start_audit(self):
with Pyro4.Daemon() as daemon:
self_uri = daemon.register(self)
ns = Pyro4.locateNS()
ns.register("Audit", self_uri)
self.running = True
print("starting")
daemon.requestLoop(loopCondition=self.still_running)
print("stopped")
self.running = None
def hi(self, string):
print string
def stop(self):
self.running = False
def still_running(self):
return self.running
def main():
# lancement de l'auditor
auditor = Audit()
auditor.start_audit()
if __name__ == "__main__" :
main()
客户
import Pyro4
def main():
with Pyro4.Proxy("PYRONAME:Audit") as au:
au.hi("hello")
au.hi("another hi")
au.stop()
我期望看到服务器打印“hello”和“another hi”,然后关闭。
但是关闭并没有发生,服务器仍然在 requestloop 方法中被阻塞。只要我愿意,我就可以使用我的代理。
但是,如果我创建另一个客户端,在第一次远程调用时,服务器将关闭,客户端将抛出错误:
Pyro4.errors.ConnectionClosedError: receiving: not enough data
我所有的测试都说我需要创建第二个代理并抛出异常以在我的服务器上传递请求循环。
有没有人知道如何清理这个问题?