...

print("[+] Iniciando serviço")

import asyncio
import websockets
import json
import _thread

...

async def webSocket(websocket, path):
    comando = await websocket.recv()  # Método Bloqueante
    comando = json.loads(comando)
    try:
        tipo_comando = comando['comando']
        usuario = comando['username']

        if tipo_comando == "...":
            ...
            await websocket.send(json.dumps({"ok": False, "mensagem_usuario": "Conta atual está conecatada."}))
        elif tipo_comando == "...":
            ...
            await websocket.send(json.dumps({"ok": True, "mensagem_usuario": "...Mensagem..."}))
        else:
            await websocket.send(json.dumps({"ok": False, "mensagem_usuario": "Comando não reconhecido."}))
    except KeyError:
        await websocket.send(json.dumps({"ok": False, "mensagem_usuario": "Comando mal formatado."}))
    print("[i] Encerando conexão Socket")


start_server = websockets.serve(webSocket, '127.0.0.1', 8765)

asyncio.get_event_loop().run_until_complete(start_server)
asyncio.get_event_loop().run_forever()