在Python中監聽連接時接收命令行輸入

Question

我試圖編寫一個程序，讓客戶端連接到它，同時服務器仍然能夠向所有客戶端發送命令。我正在使用「Twisted」解決方案。我怎麼去解決這個問題？這裏是我到目前爲止的代碼（我的理解是扭曲已經使用非阻塞套接字）：

import threading 
print 'threading.' 

def dock(): 
    try: 
     from twisted.internet.protocol import Factory, Protocol 
     from twisted.internet import reactor 
     import currentTime 
     print '[*]Imports succesful.' 
    except: 
     print '[/]Imports failed.' 

    #Define the class for the protocol 
    class Master(Protocol): 
     command = raw_input('> ') 
     def connectionMade(self): 
      print 'Slave connected.' 
      print currentTime.getTime() #Print current time 
      #self.transport.write("Hello") 

     def connectionLost(self, reason): 
      print 'Lost.' 
    #Assemble it in a "factory" 

    class MasterFactory(Factory): 
     protocol = Master 


    reactor.listenTCP(8800, MasterFactory()) 

    #Run it all 
    reactor.run() 

def commandline(): 
    raw_input('>') 

threading.Thread(target=dock()).start() 
threading.Thread(target=commandline()).start() 

Answer 1

既然你已經使用了雙絞線，你也應該使用它的主機部分，而不是使用raw_input在一個線程中。

Twisted的事件循環可以監視任何文件描述符以進行更改（包括標準輸入），因此您可以在輸入的新行上獲得基於事件的回調 - 它可以異步工作，無需線程。

我找到了這個example of a interactive console in a twisted application，也許你可以使用它。