آپ FastAPI میں WebSockets کو کیسے سنبھالتے ہیں؟

Question

IT Interview Practice · Accepted Answer

FastAPI **WebSockets** کو سپورٹ کرتا ہے حقیقی وقت، دو طرفہ مواصلہ کے لیے (چیٹ، لائیو اپڈیٹس، اطلاعات) `@app.websocket` ڈیکوریٹر کے ذریعے۔ HTTP کی درخواست-جواب کے برعکس، WebSocket کنکشن کھلا رہتا ہے، سرور اور کلائنٹ کو آزادانہ طریقے سے پیغامات بھیجنے دیتا ہے۔

## بنیادی WebSocket اندراج

```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)
```

نمونہ: `accept()` کنکشن کو قبول کریں، پھر لوپ میں — `receive_text()`/`receive_json()` پیغامات پڑھتے ہیں، `send_text()`/`send_json()` انہیں بھیجتے ہیں۔ `WebSocketDisconnect` استثناء ظاہر کرتی ہے کہ کلائنٹ چلا گیا ہے (جہاں آپ صفائی کرتے ہیں)۔

## متعدد کلائنٹس کو نشریات (مثلاً چیٹ)

```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
```

فعال کنکشنز کی فہرست منظم کرنا آپ کو تمام کلائنٹس کو **نشریات** کرنے دیتا ہے — چیٹ اور لائیو اپڈیٹ فیچرز کی بنیاد۔

## اسکیلنگ انتباہ

```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.)
```

## یہ کیوں اہم ہے

WebSockets **حقیقی وقت، دو طرفہ** فیچرز فراہم کرتے ہیں — چیٹ، لائیو اطلاعات، موجودگی، تعاون سے ترمیم، لائیو ڈیش بورڈز — جو HTTP کی درخواست-جواب ماڈل فراہم نہیں کر سکتی (سرور کلائنٹس کو بھیج سکتا ہے، صرف جواب نہیں دے)۔

FastAPI کی WebSocket سپورٹ کو سمجھنا جدید انٹرایکٹو ایپلیکیشنز بنانے کے لیے قیمتی ہے: `@app.websocket` ڈیکوریٹر accept/receive/send لوپ کے ساتھ بنیادی حقیقی وقت مواصلہ کا احاطہ کرتا ہے، اور فعال کنکشنز کو منظم کرنا **نشریات** فراہم کرتا ہے (چیٹ جیسی متعدد صارفین کی خصوصیات کی بنیاد)۔

FastAPI کی async بنیاد WebSockets کے لیے موزوں ہے۔

انتہائی اہم **اسکیلنگ انتباہ** ہے: WebSocket کنکشنز stateful ہیں اور ایک واحد سرور instance سے منسلک ہیں، تو متعدد instances میں اسکیل کرنے کے لیے **Redis Pub/Sub backplane** کی ضرورت ہے instances کے درمیان پیغامات منتقل کرنے کے لیے — ایک عام خطرہ، کیونکہ (sessions کی طرح) کنکشن state ایک process کی میموری میں نہیں رہ سکتا جب متعدد instances چل رہے ہوں۔

بنیادی WebSocket نمونہ، نشریات، disconnect ہینڈلنگ، اور اسکیلنگ غور کو جاننا اہم سینیئر سطح کی معلومات ہے حقیقی وقت، انٹرایکٹو تجربات بنانے کے لیے جو جدید ایپلیکیشنز میں متوقع ہیں۔

بنیادی WebSocket اندراج

متعدد کلائنٹس کو نشریات (مثلاً چیٹ)

اسکیلنگ انتباہ

یہ کیوں اہم ہے

متعلقہ سوالات