Kif tħadditħ WebSocket f'FastAPI?

Question

Accepted Answer

FastAPI jappoġġja **WebSocket** għal komunikazzjoni real-time, bidirezzjonali (chat, aġġornamenti live, notifiki) permezz tad-dekoratur `@app.websocket`. Bħala differenza mill-mudell ta' talaħħa-rispons ta' HTTP, il-konnessjoni WebSocket tibqa' miftuħa, u tħalli s-server u l-kliyent jibagħtu messaġġi liberament.

## Endpoint WebSocket bażiku

```python
from fastapi import WebSocket, WebSocketDisconnect

@app.websocket("/ws")
async def websocket_endpoint(websocket: WebSocket):
    await websocket.accept()                  # accept the connection
    try:
        while True:
            data = await websocket.receive_text()    # receive a message from the client
            await websocket.send_text(f"Echo: {data}")  # send a message back
    except WebSocketDisconnect:
        print("client disconnected")           # handle disconnection (cleanup)
```

Il-mudell: `accept()` il-konnessjoni, imbagħad loop — `receive_text()`/`receive_json()` jaqra messaġġi, `send_text()`/`send_json()` jibagħthom. Eċċezzjoni `WebSocketDisconnect` tissinjalizza li l-kliyent ħa mixi (fejn tiddiskrivi).

## Trażmissjoni lejn numru ta' kliyenti (eż. chat)

```python
class ConnectionManager:
    def __init__(self): self.active: list[WebSocket] = []
    async def connect(self, ws): await ws.accept(); self.active.append(ws)
    def disconnect(self, ws): self.active.remove(ws)
    async def broadcast(self, msg):
        for conn in self.active:
            await conn.send_text(msg)          # send to ALL connected clients

manager = ConnectionManager()

@app.websocket("/chat")
async def chat(ws: WebSocket):
    await manager.connect(ws)
    try:
        while True:
            msg = await ws.receive_text()
            await manager.broadcast(msg)        # everyone gets the message
    except WebSocketDisconnect:
        manager.disconnect(ws)                  # remove on disconnect
```

Id-direzzjoni ta' lista ta' konnessjonijiet attivi tħallielek **ttrażmetti** lil-kliyenti kollha — il-bażi ta' karatteristiċi chat u aġġornamenti live.

## Avvertiement ta' skalament

```text
⚠️ WebSocket connections are STATEFUL and live on ONE server instance.
To scale across multiple instances, use a Redis Pub/Sub (or similar) backplane so
messages/broadcasts reach clients connected to OTHER instances.
(Like sessions, don't keep connection state only in one process when scaling horizontally.)
```

## Għaliex din hija importanti

WebSocket japabilita karatteristiċi **real-time, bidirezzjonali** — chat, notifiki live, preżenza, edizzjoni kooperattiva, dashboard live — li l-mudell ta' talaħħa-rispons ta' HTTP ma jistax jipprovdi (is-server jista' jbiegħ lill-kliyenti, mhux biss jirrispondi).

Il-fehim tas-supp ta' WebSocket ta' FastAPI huwa valur għall-kostruzzjoni ta' applikazzjonijiet moderni interattivi: id-dekoratur `@app.websocket` bl-accept/receive/send loop ġo-qafas il-komunikazzjoni real-time bażika, u d-direzzjoni ta' konnessjonijiet attivi tapabilita **trażmissjoni** (il-qalb ta' karatteristiċi multi-user bħal chat).

Il-fondazzjoni asinkrona ta' FastAPI hija adattata ħaļiex għal WebSocket.

Critically importanti huwa l-**avvertiement ta' skalament**: il-konnessjonijiet WebSocket huma stateful u marbuta ma' istanza ta' server waħda, għalhekk is-skalament fuq numru ta' istanzi jeħtieġ **backplane Redis Pub/Sub** biex jirrelaj messaġġi bejn l-istanzi — trampa komuni, billi (bħal-sessjonijiet) l-istat tal-konnessjoni ma jistax jgħix fil-memorja ta' proċess wieħed meta jaħdmu numru ta' istanzi.

Il-fehim tal-mudell WebSocket bażiku, trażmissjoni, immaniġġ tad-disconnessjoni, u l-konsiderazzjoni ta' skalament huwa għarif importanti ta' livell senior għall-kostruzzjoni ta' esperjenzi real-time, interattivi li dejjem aktar mibnija f'applikazzjonijiet moderni.