0

我一直在涉足一些 Twisted，但遇到了一个问题。我正在实现几个可以连接到使用的服务器telnet localhost x

我的代码是这样处理的：

reactor.listenTCP(12001, server1, ....)

reactor.listenTCP(12002, server2, ....) 等等

然后这些使用我的工厂来构建协议

我想知道如何让这些服务器相互交互。例如，假设一个客户端发送一个请求来更新每个服务器的通用值，我想将此值中继到其他服务器以更新它们的当前值。我调查了一下reactor.connectTCP，但这似乎没有做我想要的。有没有办法在不使用 telnet 命令的情况下连接到我的服务器？

4

1 回答 1

0

当然。为此，请使用普通的 Python 技术。让我们以您正在更新的值为例。我将使它成为一个简单的计数器，它可能会随着与一个服务器的连接以及发送到与另一台服务器的连接的值而增加：

from twisted.internet import reactor
from twisted.internet.protocol import ServerFactory, Protocol

class Counter(object):
    def __init__(self):
        self._value = 0

    def increment(self):
        self._value += 1

    def get(self):
        return self._value


class Incrementor(Protocol):
    def connectionMade(self):
        self.factory.value.increment()
        self.transport.loseConnection()


class Reporter(Protocol):
    def connectionMade(self):
        self.transport.write("Value is %d\n" % (self.factory.value.get(),))
        self.transport.loseConnection()

server1 = ServerFactory()
server1.protocol = Incrementor

server2 = ServerFactory()
server2.protocol = Reporter

server1.value = server2.value = Value()

reactor.listenTCP(12001, server1)
reactor.listenTCP(12002, server2)
reactor.run()

这两个工厂现在共享一个可变状态。协议可以访问它们的工厂，因为默认值ServerFactory有助于将自身设置为它实例化的协议的属性，因此协议也可以达到工厂上的共享可变状态。一个递增计数器，另一个检索值。

您可以通过对非协议、非工厂对象的共享状态和方法调用来构建许多这样的场景。

于 2011-03-03T04:22:03.337 回答