以正确的方式包装Pyro的NameServer

Question

我正在尝试将Pyro的名字服务器转换成一个更方便的对象，这样我就可以随心所欲地启动和停止它。例如，我希望能够做一些

nameServer = NameServer("localhost")
nameServer.startNS()

[... make some other operations...]

nameServer.stopNS()        
nameServer = None


[... make some other operations...]

nameServer = NameServer("localhost")
nameServer.startNS()

对NameServer类使用以下定义：

^{pr2}$

到目前为止，还不错。它按预期工作。但是，如果在名称服务器运行时从另一个线程运行命令Pyro4.naming.locateNS()，那么下次调用名称服务器.stopNS（），程序冻结。有人知道为什么吗？以及编写这样一个名称服务器包装器的最佳（至少更好）方法是什么。在

Answer 1

Pyro4存储库中有一个示例，您可以加以修改。在

https://github.com/delmic/Pyro4/blob/master/examples/eventloop/server.py

from __future__ import print_function
import socket
import select
import sys
import Pyro4.core
import Pyro4.naming

if sys.version_info<(3,0):
    input=raw_input

print("Make sure that you don't have a name server running already.")
servertype=input("Servertype thread/multiplex (t/m)?")
if servertype=='t':
    Pyro4.config.SERVERTYPE="thread"
else:
    Pyro4.config.SERVERTYPE="multiplex"

hostname=socket.gethostname()

class EmbeddedServer(object):
    def multiply(self, x, y):
    return x*y


print("initializing services... servertype=%s" % Pyro4.config.SERVERTYPE)
# start a name server with broadcast server as well
nameserverUri, nameserverDaemon, broadcastServer = Pyro4.naming.startNS(host=hostname)
assert broadcastServer is not None, "expect a broadcast server to be created"

print("got a Nameserver, uri=%s" % nameserverUri)
print("ns daemon location string=%s" % nameserverDaemon.locationStr)
print("ns daemon sockets=%s" % nameserverDaemon.sockets)
print("bc server socket=%s (fileno %d)" % (broadcastServer.sock, broadcastServer.fileno()))

# create a Pyro daemon
pyrodaemon=Pyro4.core.Daemon(host=hostname)
print("daemon location string=%s" % pyrodaemon.locationStr)
print("daemon sockets=%s" % pyrodaemon.sockets)

# register a server object with the daemon
serveruri=pyrodaemon.register(EmbeddedServer())
print("server uri=%s" % serveruri)

# register it with the embedded nameserver directly
nameserverDaemon.nameserver.register("example.embedded.server",serveruri)

print("")

# below is our custom event loop.
while True:
    print("Waiting for events...")
    # create sets of the socket objects we will be waiting on
    # (a set provides fast lookup compared to a list)
    nameserverSockets = set(nameserverDaemon.sockets)
    pyroSockets = set(pyrodaemon.sockets)
    rs=[broadcastServer] # only the broadcast server is directly usable as a select() object
    rs.extend(nameserverSockets)
    rs.extend(pyroSockets)
    rs,_,_ = select.select(rs,[],[],3)
    eventsForNameserver=[]
    eventsForDaemon=[]
    for s in rs:
    if s is broadcastServer:
        print("Broadcast server received a request")
        broadcastServer.processRequest()
    elif s in nameserverSockets:
        eventsForNameserver.append(s)
    elif s in pyroSockets:
        eventsForDaemon.append(s)
    if eventsForNameserver:
    print("Nameserver received a request")
    nameserverDaemon.events(eventsForNameserver)
    if eventsForDaemon:
    print("Daemon received a request")
    pyrodaemon.events(eventsForDaemon)


nameserverDaemon.close()
broadcastServer.close()
pyrodaemon.close()
print("done")