EP.99 การทำ WebSocket Server ให้รองรับการทำงานในสถานการณ์ที่มีการเชื่อมต่อสูง (High Traffic)

การทำ WebSocket Server ให้รองรับการทำงานในสถานการณ์ที่มีการเชื่อมต่อสูง (High Traffic)

การพัฒนา WebSocket Server สำหรับระบบขนาดใหญ่ต้องเผชิญกับความท้าทายด้าน ประสิทธิภาพ (performance), ความเสถียร (stability) และ การรองรับผู้ใช้จำนวนมากพร้อมกัน (scalability) โดยเฉพาะเมื่อมีการเชื่อมต่อพร้อมกันนับพันหรือนับหมื่น client

บทความนี้จะพาคุณไปดูแนวทาง สเกลระบบแบบมืออาชีพ เพื่อให้ WebSocket Server ของคุณทำงานได้อย่างไหลลื่นแม้อยู่ในสภาวะ High Traffic

1. ใช้ Horizontal Scaling และ Load Balancer

รัน WebSocket Server หลาย instance แยกกัน
วาง Load Balancer (เช่น NGINX, HAProxy หรือ Cloud Load Balancer) เพื่อกระจาย traffic
ใช้ Sticky Session / Session Affinity เพื่อให้ client เชื่อมต่อกับ server เดิม

ตัวอย่างการตั้งค่า NGINX Sticky Session:

upstream websocket_backend {
    ip_hash; # ทำให้ client เดิมเจอ server เดิม
    server 10.0.0.1:8080;
    server 10.0.0.2:8080;
}

server {
    listen 80;

    location /ws {
        proxy_pass http://websocket_backend;
        proxy_http_version 1.1;
        proxy_set_header Upgrade $http_upgrade;
        proxy_set_header Connection "upgrade";
    }
}

2. ใช้ Redis Pub/Sub หรือ Message Broker

เมื่อใช้หลาย instance จำเป็นต้อง sync ข้อมูลข้าม server เช่น chat message หรือ event update

Redis Pub/Sub, NATS หรือ Kafka สามารถช่วยให้ broadcast message ได้แบบข้าม node

ตัวอย่างโค้ด Go (ใช้ Redis Pub/Sub กับ Gorilla WebSocket):

for {
    msg, err := redisSub.ReceiveMessage(context.Background())
    if err != nil {
        log.Println("Redis error:", err)
        continue
    }

    for client := range localClients {
        err := client.WriteMessage(websocket.TextMessage, []byte(msg.Payload))
        if err != nil {
            log.Println("Send error:", err)
            client.Close()
            delete(localClients, client)
        }
    }
}

3. การจัดการ Connection จำนวนมาก

เพื่อให้ server ไม่ crash ควรมีระบบจัดการ connection อย่างเป็นระบบ:

✅ กำหนดจำนวน connection ต่อ server / ต่อ IP
✅ ตรวจสอบ connection ที่ยัง active ด้วย heartbeat หรือ ping-pong
✅ ปิด connection ที่ inactive หรือ idle เกินเวลา

ตัวอย่างการตั้ง heartbeat (ฝั่ง Server):

func handleConnection(conn *websocket.Conn) {
    conn.SetReadDeadline(time.Now().Add(30 * time.Second))
    conn.SetPongHandler(func(string) error {
        conn.SetReadDeadline(time.Now().Add(30 * time.Second))
        return nil
    })

    ticker := time.NewTicker(10 * time.Second)
    defer ticker.Stop()

    for {
        <-ticker.C
        if err := conn.WriteMessage(websocket.PingMessage, nil); err != nil {
            log.Println("Ping error:", err)
            conn.Close()
            break
        }
    }
}

4. การเพิ่มประสิทธิภาพ (Performance Optimization)

เพื่อให้รองรับโหลดสูงได้:

✅ ใช้ binary encoding เช่น Protobuf หรือ MessagePack แทน JSON
✅ บีบอัด payload ด้วย gzip หรือ zlib
✅ ใช้ Batch Message หากไม่ต้องการส่งทุก event ทันที
✅ ใช้ Goroutine / Worker Pool เพื่อไม่ให้ main thread บล็อก

5. Best Practices

📊 Monitoring: ใช้ Prometheus + Grafana เพื่อติดตาม CPU, memory, network
☁️ Auto-scaling: บน Kubernetes หรือ Cloud ที่รองรับ Horizontal Pod Autoscaler
🔁 Retry & Circuit Breaker: เมื่อมี server error หรือติดต่อไม่ได้
🧪 Load Testing: ทดสอบด้วยเครื่องมือเช่น wrk, artillery, k6 ก่อน production

✅ Challenge

ลองออกแบบระบบ WebSocket ขนาดใหญ่ด้วยตัวเอง:

รัน WebSocket Server 2–3 instance
ตั้ง Load Balancer พร้อม sticky session
ใช้ Redis Pub/Sub เพื่อ sync ข้อความ
รองรับ client เชื่อมต่อพร้อมกัน 1,000 ราย
ทดสอบการ broadcast แบบ real-time และวัด latency

🚀 สรุป

WebSocket Server สำหรับ High Traffic ต้องออกแบบให้พร้อมทั้ง:

✅ Scale ได้แนวตั้งและแนวนอน
✅ ส่งข้อมูลทันทีแบบ low-latency
✅ ปลอดภัยและมีการจัดการ connection อย่างมีประสิทธิภาพ
✅ พร้อมขยายสู่ระบบระดับ Enterprise

🔜 EP ต่อไป (EP.100):

การสรุปและการพัฒนา WebSocket Server ในระดับ Enterprise
เรียนรู้การออกแบบโครงสร้างระดับองค์กร การผสานเข้ากับระบบ Microservices และระบบ monitoring ที่ครบถ้วน

อ่านบทความ Series อื่นๆ

🔵 Facebook: https://www.facebook.com/superdev.academy.th

🔴 YouTube : Superdev Academy

📸 Instagram: Superdev Academy

🎬 TikTok: https://www.tiktok.com/@superdevacademy?lang=th-TH

🌐 Website: https://www.superdevacademy.com/