2

客户：

#!/usr/bin/env python

from twisted.internet import reactor, protocol

class EchoClient(protocol.Protocol):
    def __init__(self, arg):
        self.arg = arg

    def connectionMade(self):
        self.transport.write("hello, world!")

    def dataReceived(self, data):
        print "Server said:", data
        self.transport.loseConnection()

    def connectionLost(self, reason):
        print "connection lost"

class EchoFactory(protocol.ClientFactory):
    protocol = EchoClient

    def buildProtocol(self, address):
        proto = protocol.ClientFactory.buildProtocol(self, address, 12)
        self.connectedProtocol = proto
        return proto

    def clientConnectionFailed(self, connector, reason):
        print "Connection failed - goodbye!"
        reactor.stop()

    def clientConnectionLost(self, connector, reason):
        print "Connection lost - goodbye!"
        reactor.stop()

def main():
    f = EchoFactory()
    reactor.connectTCP("localhost", 8000, f)
    reactor.run()

if __name__ == '__main__':
    main()

服务器：

#!/usr/bin/env python

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

class Echo(protocol.Protocol):
    def dataReceived(self, data):
        self.transport.write(data)

def main():
    factory = protocol.ServerFactory()
    factory.protocol = Echo
    reactor.listenTCP(8000,factory)
    reactor.run()

if __name__ == '__main__':
    main()

错误：

exceptions.TypeError: buildProtocol() takes exactly 2 arguments (3 given)

问题：

如何让EchoClient类中的类CLIENT接受参数并分配实例变量（如EchoClient上面构造函数中的 arg）？如下所述，之前有人建议我重写该buildProtocol函数，但我这样做的尝试导致我出现上述错误。我不确定从这里去哪里。我想我的问题可以概括为：如何将实例变量添加到协议中？

4

2 回答 2

7

你写了：

def buildProtocol(self, address):
    proto = protocol.ClientFactory.buildProtocol(self, address, 12)

也就是说，您正在ClientFactory.buildProtocol使用不同于它知道如何处理的签名来覆盖和调用父类。

将数据从工厂传递给客户端只是有点棘手。你可以为工厂提供任何__init__你想要的东西，但是 twisted 会创建IProtocol它自己的实例。factory幸运的是，一旦协议准备就绪，大多数工厂都会将自己分配给协议的属性：

class MyClientProtocol(protocol.Protocol):
    def connectionMade(self):
        # use self.factory here:
        self.transport.write(self.factory.arg)

class MyClientFactory(protocol.ClientFactory):
    protocol = MyClientProtocol

    def __init__(self, arg):
        self.arg = arg

其实整个ProtocolFactory业务都是支持这种使用的；但要注意；许多实例Protocol将共享其工厂的单个实例；使用工厂进行配置，但在协议中 管理状态。

协议/工厂标准系列的实现方式当然可能不适合您的需求，这也是合理的，只要您完全实现IProtocol和IProtocolFactory接口。基类的存在是因为它们为您处理大多数情况，而不是因为它们是唯一可能的实现。

于 2013-06-03T02:32:55.520 回答
1

从你的问题中不清楚你到底尝试了什么以及错误到底是什么，但无论如何你必须做两个步骤：

  1. MakeEchoClient的构造函数采用您需要它采用的任何参数并初始化您需要它初始化的任何字段。
  2. 覆盖buildProtocol工厂中的方法以将这些参数提供给您的协议。
于 2013-06-02T08:04:08.527 回答