꼬인 서버에 명령 보내기

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 (관련 클라이언트 데이터 보유)과 같이 설정할 수 있습니다. 콜백의 그 시리즈, 클라이언트

이 메시지를 전송하는 제 3 자

확인하는 클라이언트

와 통신

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)