扭曲的服务器-客户端数据共享

Question

我在这个站点上稍微修改了一个服务器-客户端 Twisted 程序，它提供了一个可以充当服务器和客户端的程序 (How to write a twisted server that is also a client?)。我能够将服务器客户端连接到一侧的外部客户端和另一侧的外部服务器。我想通过服务器-客户端程序将数据从外部客户端传输到外部服务器。我遇到的问题是将 ServerProtocol 类(在服务器-客户端程序中)接收到的行放入 ClientProtocol 类(在服务器-客户端程序中)。我已经尝试了很多方法，包括尝试使用工厂引用，正如您从 def 中看到的那样。初始化 但我无法让它工作。 (目前我只是将文字来回发送到外部服务器和客户端)这是服务器-客户端代码:

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


    class ServerProtocol(basic.LineReceiver):        
        def lineReceived(self, line):
            print "line recveived on server-client",line
            self.sendLine("Back at you from server-client")
            factory = protocol.ClientFactory()
            factory.protocol = ClientProtocol
            reactor.connectTCP('localhost', 1234, factory)

    class ClientProtocol(basic.LineReceiver):
        def __init__(self, factory):
            self.factory = factory

        def connectionMade(self):
            self.sendLine("Hello from server-client!")
            #self.transport.loseConnection()
        
        def lineReceived(self, line):
            print "line recveived on server-client1.py",line
            #self.transport.loseConnection()
          
    def main():
        import sys
        from twisted.python import log

        log.startLogging(sys.stdout)
        factory = protocol.ServerFactory()
        factory.protocol = ServerProtocol
        reactor.listenTCP(4321, factory)
        reactor.run()

    if __name__ == '__main__':
        main()

我应该提一下，我能够分别在端口 4321 和 1234 上通过外部服务器和外部客户端连接到服务器-客户端程序，它们只是回显。此外，我还没有展示我多次尝试使用 self.factory 引用。任何意见或建议将不胜感激。

Answer 1

这个问题与 Twisted FAQ 中的一个流行问题非常相似:

How do I make input on one connection result in output on another?

与您关于一个传入客户端连接和一个传出客户端连接的问题相反，FAQ 项目谈论到一台服务器的许多客户端连接没有任何显着差异。您在不同连接之间共享数据的方式是相同的。

该常见问题解答项目的基本要点是，基本上您想做的任何事情都涉及某种方法调用，并且 Twisted 中的方法调用与任何其他 Python 程序中的方法调用相同。您所需要的只是引用正确的对象来调用该方法。因此，例如，调整您的代码:

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

class ServerProtocol(basic.LineReceiver):        
    def lineReceived(self, line):
        self._received = line
        factory = protocol.ClientFactory()
        factory.protocol = ClientProtocol
        factory.originator = self
        reactor.connectTCP('localhost', 1234, factory)

    def forwardLine(self, recipient):
        recipient.sendLine(self._received)

class ClientProtocol(basic.LineReceiver):
    def connectionMade(self):
        self.factory.originator.forwardLine(self)
        self.transport.loseConnection()

def main():
    import sys
    from twisted.python import log

    log.startLogging(sys.stdout)
    factory = protocol.ServerFactory()
    factory.protocol = ServerProtocol
    reactor.listenTCP(4321, factory)
    reactor.run()

if __name__ == '__main__':
    main()

注意如何:

我摆脱了__init__ ClientProtocol上的方法. ClientFactory不带参数调用它的协议(protocol)。一个 __init__需要参数将导致 TypeError被抚养。此外，ClientFactory已经将自己设置为它创建的协议(protocol)的工厂属性。

我给了ClientProtocol对 ServerProtocol 的引用实例通过设置 ServerProtocol实例为 originator客户端工厂的属性。由于ClientProtocol实例引用了 ClientFactory例如，这意味着它引用了 ServerProtocol实例。

我添加了 forwardLine方法ClientProtocol可以直接使用ServerProtocol做任何你的应用程序逻辑，一旦ClientProtocol连接建立。请注意，由于上一点，ClientProtocol调用这个方法没有问题。