Websocket在线程内部的异步循环中立即断开连接

Question

我正在开发一个应用程序，该应用程序使用多个线程用于各种通信渠道。其中之一是Websocket，我正在使用Asyncio循环运行：

class Rotator():
    def __init__(self):
        # some irrelevant stuff here...
        self._readThread = threading.Thread(target=self._ReadThread, daemon=True)
        self._usbThread = threading.Thread(target=self._UsbThread, daemon=True)
        self._webThread = threading.Thread(target=self._WebThread, daemon=True)
        self._socketThread = threading.Thread(target=self._SocketThread, daemon=True)
        self.InitializeRotator()

    def InitializeRotator(self):
        # some more irrelevant stuff here
        self._readThread.start()
        self._usbThread.start()
        self._webThread.start()
        self._socketThread.start()

    # not including _ReadThread() and _UsbThread() as they are irrelevant in this context

    def _WebThread(self): # including _WebThread() as illustration
        handler_object = server.WebHttpRequestHandler
        _httpServer = socketserver.TCPServer(("",self.webPort), handler_object)
        _httpServer.serve_forever()

    async def ws_handler(websocket, path):
        data = await websocket.recv()
        reply = f"Data recieved as:  {data}!"
        await websocket.send(reply)

    def _SocketThread(self):
        loop = asyncio.new_event_loop()
        asyncio.set_event_loop(loop)
        start_server = websockets.serve(self.ws_handler, str(self.DHCPIP), 8000)

        loop.run_until_complete(start_server)
        loop.run_forever()

与此通信的前端JS代码：

    var ws;
    
    function startWebsocket() {
        ws = new WebSocket('ws://192.168.200.76:8000')

        ws.onopen = function(e){
            console.log('Connection established')
            ws.send('Connection established')
        }

        ws.onmessage = function(e){
            console.log('websocket message event:', e)
        }

        ws.onclose = function(){
            // connection closed, discard old websocket and create a new one in 5s
            console.log('Connection lost, will reconnect in 5s...')
            ws = null
            setTimeout(startWebsocket, 5000)
        }
    }

    startWebsocket();

包含前端的网页由_webthread（）运行的服务器提供服务。问题在于，建立后的连接正在立即关闭。我假设问题是由异步/线程组合中的某些冲突引起的，因为我单独测试了服务器端代码，并且像魅力一样工作。我在做什么错？

Answer 1

我重新创建了您的示例，并设法使用两个更改来修复它：

1. ws_handler缺少self参数。由于这是一个实例方法，因此实例本身将作为第一个参数传递。实际的Websocket对象将是第二个。

2. 在WS_HANDLER中，我在true 循环时添加了。我在此处的文档中遵循了 https：// https：// websockets.readthedocs.io/en/stable/intro/tutorial1.html#bootstrap-the-server

   


最终结果：

    async def ws_handler(self, websocket, path):
        while True:
            data = await websocket.recv()
            reply = f"Data recieved as:  {data}!"
            await websocket.send(reply)

我所做的其他更改是使用8000用作HTTP服务器的端口，Websocket的8001和“ localhost”，而不是192.168.200.76。但是我很确定这无关紧要