Abrufen der Abhörport während BuildProtocol

Question

Ich bin die BuildProtocol-Methode der ServerFactory ändern, im Grunde die Fabrik hört auf Port 11000 und 12000, und ich habe zwei Protokolle, eines für jeden Port Port. Ich versuche den Port abzurufen, den der Client zum Abhören verwendet hat, damit ich das richtige Protokoll instanziieren kann.

ex. Client hört an Port 11000 zu, Protokoll 1 wird instanziiert. Client hört an Port 12000 ab, Protokoll 2 wird instanziiert.

ich denke, dies kann nur in der buildProtocol stage getan werden, gibt es eine möglichkeit zu bestimmen, welcher port verwendet wurde, um zu verbinden? Der von BuildProtocol verwendete Adressparameter ist die Clientadresse, ich benötige den Serverport.

Pseudocode:

def buildProtocol(self, address): 
    if address connects at port 11000: 
    proto = TransformProtocol() 
    else: 
    proto = TransformProtocol2() 
    proto.factory = self 
    return proto 

Answer 1

Ich denke, müssen Sie Twisted-Dienste nutzen: link text

code Sie werden so etwas wie:

from twisted.application import internet, service 
from twisted.internet import protocol, reactor 
from twisted.protocols import basic 

class UpperCaseProtocol(basic.LineReceiver): 
    def lineReceived(self, line): 
     self.transport.write(line.upper() + '\r\n') 
     self.transport.loseConnection() 

class LowerCaseProtocol(basic.LineReceiver): 
    def lineReceived(self, line): 
     self.transport.write(line.lower() + '\r\n') 
     self.transport.loseConnection() 

class LineCaseService(service.Service): 

    def getFactory(self, p): 
     f = protocol.ServerFactory() 
     f.protocol = p 
     return f 

application = service.Application('LineCase') 
f = LineCaseService() 

serviceCollection = service.IServiceCollection(application) 
internet.TCPServer(11000,f.getFactory(UpperCaseProtocol)).setServiceParent(serviceCollection) 
internet.TCPServer(12000,f.getFactory(LowerCaseProtocol)).setServiceParent(serviceCollection) 

Aber hier haben wir zwei Factory-Instanzen.