pythonwebsocket异步高并发_Python3.5异步和多个websocket服务器

我在Ubuntu上使用pythonwebsockets4.0.1。我想有2个websocket服务器运行。我可以通过为每个线程创建2个线程和独立的事件循环来实现这一点。我所说的“某种工作”是指两个websockets都工作&＃xff0c;并且响应大约30秒&＃xff0c;然后其中一个停止。我必须重新启动程序让他们两个都重新工作。如果我只运行这两个线程中的一个&＃xff0c;那么单个websocket将永远工作。

我做错了什么&＃xff1f;如何让2个websockets永远与asyncio一起工作&＃xff1f;谢谢。# Start VL WebSocket Task

class vlWebSocketTask (threading.Thread):

def __init__(self):

threading.Thread.__init__(self)

def run(self):

# Main while loops

loop &＃61; asyncio.new_event_loop()

asyncio.set_event_loop(loop)

while True:

try:

print("Starting VL WebSocket Server...")

startVLServer &＃61; websockets.serve(vlWebsocketServer, &＃39;192.168.1.3&＃39;, 8777)

asyncio.get_event_loop().run_until_complete(startVLServer)

asyncio.get_event_loop().run_forever()

except Exception as ex:

print(ex)

time.sleep(5)

# Start IR WebSocket Task

class irWebSocketTask (threading.Thread):

def __init__(self):

threading.Thread.__init__(self)

def run(self):

loop &＃61; asyncio.new_event_loop()

asyncio.set_event_loop(loop)

while True:

try:

print("Starting IR WebSocket Server...")

startIRServer &＃61; websockets.serve(irWebsocketServer, &＃39;192.168.1.3&＃39;, 8555)

asyncio.get_event_loop().run_until_complete(startIRServer)

asyncio.get_event_loop().run_forever()

except Exception as ex:

print(ex)

time.sleep(5)

# Initialize VL WebSocket Task

#VLWebSocketTask &＃61; vlWebSocketTask()

#VLWebSocketTask.start()

# Initialize IR WebSocket Task

IRWebSocketTask &＃61; irWebSocketTask()

IRWebSocketTask.start()