twisted - OS가 선택한 수신 대기 포트 받기

Question

응용 프로그램 프레임 워크를 사용하여 트위스트 P2P 클라이언트를 작성하고 있습니다. 들어오는 연결의 수신 포트는 임의로 (OS가 결정한) 포트에 있습니다. 그러나, 나는 그 포트를 생성 한 후이 무엇인지 확인하는 방법이 필요합니다 : 나는 internet.TCPServer()에 의해 생성 된 포트를 쿼리에 대해 또는 reactor.listenTCP()가 전달에 의해 문서에서 아무것도 찾을 수 없습니다

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) 

. 나는 클라이언트가 그 연결이 일어날 수 있도록 포트를 발표해야하기 때문에 단순히 연결이 일어날 때까지 기다릴 수 없다. 아직 서버를 시작하지 않은 경우

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은별로 도움이되지 않습니다. 듣기 시작하자마자 포트를 어딘가에보고하는 포트를 작성하면됩니다.

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