如何停止的WebSocket客戶端無需停​​止反應堆

Question

我有類似蟒蛇聊天室編寫打算做以下事情的應用程序：

1. 對用戶輸入的WebSocket服務器地址的提示。
2. 然後創建一個連接到服務器併發送/接收消息的websocket客戶端。禁用創建websocket客戶端的功能。
3. 在收到服務器的「關閉」（不是關閉幀）後，客戶端應該斷開連接並重新啓用應用程序以創建客戶端。返回1.
4. 如果用戶退出應用程序，它將退出websocket客戶端（如果有一個正在運行）。

我的方法是使用主線程來處理用戶輸入。當用戶輸入時，使用AutoBahn的扭曲模塊爲WebSocketClient創建一個線程，並將一個隊列傳遞給它。檢查反應堆是否在運行，如果不是，則啓動反應堆。 覆蓋消息方法以在「關閉」時將關閉標誌放入隊列中。主線程將忙於檢查隊列，直到收到標誌並返回開始。代碼如下所示。

主線程。

def main_thread(): 
    while True: 
     text = raw_input("Input server url or exit") 
     if text == "exit": 
      if myreactor: 
       myreactor.stop() 
      break 
     msgq = Queue.Queue() 
     threading.Thread(target=wsthread, args=(text, msgq)).start() 

     is_close = False 
     while True: 
      if msgq.empty() is False: 
       msg = msgq.get() 
       if msg == "close": 
        is_close = True 
       else: 
        print msg 
       if is_close: 
        break 
     print 'Websocket client closed!' 

工廠和協議。

class MyProtocol(WebSocketClientProtocol): 
    def onMessage(self, payload, isBinary): 
     msg = payload.decode('utf-8') 
     self.Factory.q.put(msg) 
     if msg == 'close': 
      self.dropConnection(abort=True) 

class WebSocketClientFactoryWithQ(WebSocketClientFactory): 
    def __init__(self, *args, **kwargs): 
     self.queue = kwargs.pop('queue', None) 
     WebSocketClientFactory.__init__(self, *args, **kwargs) 

客戶端線程。

def wsthread(url, q): 
    factory = WebSocketClientFactoryWithQ(url=url, queue=q) 
    factory.protocol = MyProtocol 
    connectWS(Factory) 
    if myreactor is None: 
     myreactor = reactor 
     reactor.run() 
    print 'Done' 

現在我遇到了問題。看來我的客戶端線程永遠不會停止。即使我收到「close」，它似乎仍在運行，每次我嘗試重新創建一個新客戶端時，它都會創建一個新線程。我知道第一個線程不會停止，因爲reactor.run()將永遠運行，但從第二個線程開始，它應該是非阻塞的，因爲我不再啓動它。我該如何改變它？

編輯：

我結束了

1. 斷開連接後添加stopFactory()解決它。
2. 使協議功能與reactor.callFromThread()。
3. 在第一個線程中啓動反應器並將客戶端放入其他線程並使用reactor.callInThread()來創建它們。

Answer 1

您的main_thread創建運行wsthread的新線程。 wsthread使用Twisted API。 第一個wsthread成爲反應器線程。所有後續的線程是不同的，它是不確定的，如果你使用它們的Twisted API會發生什麼。

你應該幾乎可以肯定地從應用程序中刪除使用線程。要處理基於Twisted的應用程序中的控制檯輸入，請查看twisted.conch.stdio（不是扭曲的最好記錄部分，唉，但正是你想要的）。