向扭曲服务器发送命令

Question

我有一个简单的扭曲 TCP 服务器，用于从另一个应用程序发送和接收数据。建立连接后，我就可以与此应用程序通信并向其发送消息。

我希望能够有一个外部模块命令何时以及将什么发送到第 3 方应用程序（而不是在连接时）。例如，这是我的服务器代码：

from twisted.internet import reactor, protocol

# Twisted
class Tcp(protocol.Protocol):
    def dataReceived(self, data):
        self.transport.write(data)
        print 'data received: ', data
        # do something with data


    def connectionMade(self, msg):
        # Want to only transport message when I command not immediately when connected
        self.transport.write(msg)


class TcpFactory(protocol.Factory):
    def buildProtocol(self, addr):
        return Tcp()

reactor.listenTCP(8001, TcpFactory())
reactor.run()

我有另一个模块（由 GUI 界面操作），它定义了要发送的消息，并且该消息需要作为“msg”传递到 connectionMade

最好的方法是什么？

Answer 1

您的第 3 方呼叫将发生在 connectionMade 内，不应直接呼叫。 connectionMade 是一个 Twisted 回调，它在那里表示客户端在另一端。由你决定之后会发生什么。因此，您可以执行一系列 Deferreds/callbacks 之类的操作，这些回调采用 self.transport（其中包含相关的客户端数据）。在这一系列回调中，您将拥有自己的逻辑

1. 与第 3 方通信
2. 验证客户端
3. 向客户端发送消息

这是它的要点：

def connectionMade(self):
    d = Deferred()
    d.addCallback(self.thirdPartyComm).addErrBack(self.handleError)
    d.addCallback(sendMsg)
    d.callback(self.transport)

def thirdPartyComm(self, transport):
    # logic for talking to 3rd party goes here
    # 3rd party should validate the client then provide a msg
    # or raise exception if client is invalid
    return msg

def handleError(self, error):
    # something went wrong, kill client connection
    self.transport.loseConnection()

def sendMsg(self, msg):
    self.transport.write(msg)