Files
RRBEC/gestaoRaul/websocket_client/websocketClient.py

31 lines
1021 B
Python

import websockets
import asyncio
import json
async def enviar_mensagem(msg):
uri = "ws://websocket_server:8765"
try:
async with websockets.connect(uri) as websocket:
# Garante que msg seja JSON
if isinstance(msg, dict):
mensagem_json = json.dumps(msg)
else:
mensagem_json = str(msg)
await websocket.send(mensagem_json)
print(f"> Enviado: {mensagem_json}")
# Se quiser esperar uma resposta (opcional)
# resposta = await websocket.recv()
# print(f"< Recebido: {resposta}")
except websockets.exceptions.InvalidURI as e:
print(f"URI inválida: {e}")
except websockets.exceptions.InvalidHandshake as e:
print(f"Handshake WebSocket falhou: {e}")
except ConnectionRefusedError:
print("Conexão recusada. Verifique se o servidor WebSocket está rodando.")
except Exception as e:
print(f"Erro ao enviar mensagem via websocket: {e}")