twisted - 获取操作系统选择的监听端口

Question

我正在使用应用程序框架编写一个扭曲的 P2P 客户端。传入连接的侦听端口将位于随机（操作系统确定的）端口上。但是，我需要一种方法来确定创建后的端口是什么：

import twisted... etc.

application = service.Application('vmesh')
peerservice = MyPeerService()
servicecollection = service.IServiceCollection(application)
factory = MyPeerFactory(peerservice)
server = internet.TCPServer(0, factory) # listen on random port
listen_port = server.getHost().port # ??? doesn't work...
server.setServiceParent(servicecollection)

我在文档中找不到任何关于查询由internet.TCPServer() 或reactor.listenTCP() 创建的端口并将其转发到的任何内容。我不能简单地等待连接发生，因为客户端必须宣布其端口才能使这些连接发生。

Answer 1

listenTCP 返回一个IListeningPort，它有一个getHost() 方法返回一个带有port 的对象。例如：

>>> from twisted.internet import reactor
>>> from twisted.internet.protocol import Factory
>>> port = reactor.listenTCP(0, Factory())
>>> port.getHost().port
55791

但是，TCPServer 不会调用 listenTCP，直到它以 privilegedStartService 开头。另外，IListeningPort 实际上并没有通过公共 API 公开。因此，您需要编写自己的Service。幸运的是，这很容易做到。 TCPServer 做的不多。您只需要编写一个在它开始侦听时在某处报告其端口的程序。这是一个例子：

from twisted.internet import reactor
from twisted.application.service import Service

class PortReporter(Service, object):
    def __init__(self, factory, reportPort):
        self.factory = factory
        self.reportPort = reportPort

    def privilegedStartService(self):
        self.listeningPort = reactor.listenTCP(0, self.factory)
        self.reportPort(self.listeningPort.getHost().port)
        return super(PortReporter, self).privilegedStartService()

    def stopService(self):
        self.listeningPort.stopListening()
        return super(PortReporter, self).stopService()

然后您可以在 tac 文件中使用它，如下所示：

from twisted.internet.protocol import Factory
from twisted.application.service import Application
application = Application("test")
def showPortNumber(n):
    print("The port number is: %d" % (n,))
PortReporter(Factory(), showPortNumber).setServiceParent(application)

Answer 2

如果您需要使用端点执行此操作，这里是我的实现，对我的本地设置稍作调整（回调选项在这里也可以很好地工作）：

class PortReporter(StreamServerEndpointService, object):
    def __init__(self, endpoint, factory):
        StreamServerEndpointService.__init__(self, endpoint, factory)
    self._reportedPort = None

def privilegedStartService(self):
    r = super(PortReporter, self).privilegedStartService()
    self._waitingForPort.addCallback(self.port_cb)
    return r

def port_cb(self, port):
    self._reportedPort = port.getHost().port
    return port

def getReportedPort(self):
    return self._reportedPort

Answer 3

如果您还没有启动服务器（还没有调用startService），您可以像这样访问绑定到服务器的端口：

>>> serv._getPort()._realPortNumber

你也可以这样做：

>>> serv._port._realPortNumber