twisted - OSが選択したリスンポートを取得

Question

私は、アプリケーションフレームワークを使用してツイストP2Pクライアントを作成しています。着信接続のリスンポートは、ランダム（OSによって決まる）ポート上にあります。しかし、私はそのポートがそれを作成した後であるかを判断する方法が必要です：

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は、getHost()メソッドを持つIListeningPortメソッドを返します。このメソッドは、portのオブジェクトを返します。例えば：それはprivilegedStartServiceで開始されるまで

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

しかし、TCPServerはlistenTCPを呼び出すことはありません。さらに、IListeningPortは公開API経由で実際には公開されていません。したがって、あなた自身のServiceを書く必要があります。幸いにも、これを行うのはかなり簡単です。 TCPServerはあまりしません。リスニングを開始するとすぐにポートをどこかに報告するポートレットを作成するだけです。ここでは例です：あなたはそのようにように、TACファイルでこれを使用することができます

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() 

：あなたがここにエンドポイントでこれを行う必要がある場合

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

あなたは（まだstartServiceを呼び出していませんでした）、まだサーバーを起動しなかった場合は、そのようなあなたのサーバへのポートのバインドにアクセスすることができます。

>>> serv._getPort()._realPortNumber 

エルス

あなたも行うことができます。

>>> serv._port._realPortNumber 

Answer 3

FWIWは私のためにわずかな微調整と私の実装ですローカルセットアップ（コールバックオプションもここでもうまくいくでしょう）：

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