ねじれたサーバーにコマンドを送信します。

Question

私は、別のアプリケーションからデータを送受信するために使用している単純なねじれTCPサーバーを持っています。私は接続が確立されたら、このアプリケーションに連絡してメッセージを送信することができます。

私ができるようにしたいのは、（接続されているときではなく）サードパーティのアプリケーションに送信するとき、および何を外部モジュールコマンドにするかです。たとえば、ここに私のサーバーコードです：

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インタフェースが運営）、別のモジュールを持って送信するためにどのようなメッセージを定義し、このメッセージは

connectionMade

に「MSG」として渡される必要がありますこれを行う最善の方法は何ですか？

Answer 1

サードパーティの通話はconnectionMadeから発生し、直接呼び出さないでください。 connectionMadeはTwistedコールバックであり、クライアントが反対側にいることを知らせるためにそこにあります。それ以降に何が起こるかは、あなた次第です。だから、一連のDeferred /コールバックをself.transport（これは関連するクライアントデータを保持する）にするようなことができます。コールバックのこれらのシリーズでは、あなたがクライアント

これにメッセージを送信するサードパーティ

検証し、クライアント

と通信

1. ためのロジックを持っているだろうことは、それの要旨であります：

   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)