我有以下系統(tǒng):[Client] - [Web Server] - [Connecotr]。連接器是 Web 服務(wù)器和數(shù)據(jù)源之間的一種中間代碼。我需要監(jiān)視與連接器的服務(wù)器連接。如果連接丟失,那么我必須通知客戶端。Web 服務(wù)器和連接器之間的通信是使用 socketio 組織的。問題是如果連接器停止工作,那么 Web 服務(wù)器將在一分鐘后知道它(這是最好的情況)。我決定服務(wù)器應(yīng)該每秒檢查一次連接器的狀態(tài)。當(dāng)連接器連接到服務(wù)器時(shí),后臺(tái)任務(wù)將啟動(dòng)。任務(wù)的本質(zhì):每一秒:1)固定時(shí)間;2)將固定時(shí)間保存到堆棧中;3) 將回顯消息發(fā)送到連接器。(見 server.background_thread)連接器接受回顯消息和時(shí)間戳作為參數(shù),并將回顯消息發(fā)送到 Web 服務(wù)器,作為它傳遞接收到的時(shí)間戳的參數(shù)。(見client.echo)Web 服務(wù)器收到回顯消息,如果時(shí)間戳等于堆棧中的最后一個(gè)值,則從堆棧中刪除該值。(見 server.on_echo_connector)在 Web 服務(wù)器上,每次迭代都會(huì)檢查堆棧大?。ㄕ?qǐng)參閱 server.background_thread)。如果大于5,則表示連接器5次沒有響應(yīng)回顯消息,我們認(rèn)為連接器不可用,斷開連接。當(dāng)服務(wù)器意識(shí)到連接器不可用時(shí),需要終止向連接器發(fā)送回顯消息的線程。一旦堆棧大小大于 5,我退出無(wú)限循環(huán)并調(diào)用flask_socketio.disconnect (connector_sid, '/ connector'). 在這個(gè)電話之后沒有任何效果(例如print)在on_disconnect_connector(server) 方法中,thread.join()被調(diào)用并且永遠(yuǎn)不會(huì)終止。而且我需要完成線程,這樣當(dāng)連接器再次啟動(dòng)時(shí),它會(huì)連接成功,一切重新開始。如何解決這個(gè)問題呢?
添加回答
舉報(bào)
0/150
提交
取消