Schimb de Mesaje: send_text() și receive_text() în FastAPI

Odată stabilită conexiunea WebSocket, aplicația intră de regulă într-o buclă asincronă while True pentru a asculta continuu mesajele trimise de client și a răspunde instantaneu.

Metode disponibile pe obiectul WebSocket:

• await websocket.receive_text() / await websocket.send_text(msg): pentru mesaje text simple.
• await websocket.receive_json() / await websocket.send_json(dict): serializează și deserializează automat JSON.
• await websocket.receive_bytes() / await websocket.send_bytes(data): pentru fluxuri de date binare (audio/video).

from fastapi import FastAPI, WebSocket

app = FastAPI()

@app.websocket("/ws/echo")
async def echo_endpoint(websocket: WebSocket):
    await websocket.accept()
    while True:
        data = await websocket.receive_text()
        # Răspundem imediat clientului:
        await websocket.send_text(f"Mesaj recepționat: {data}")