EP.105 การจัดการ Event Queue และการจัดลำดับความสำคัญ

ในระบบ WebSocket ขนาดใหญ่ (Large-scale WebSocket System) ที่ต้องรับและส่งข้อมูลแบบเรียลไทม์ (Real-time) จากหลายแหล่งหลาย ส่งผลใหญ่ ข้อความแจ้ง, แจ้งเตือน, หรือการอัปเดตสถานะ จะเกิดปัญหาเรื่อง ลำดับเหตุการ (Event Order) และ ความหน่วง (Delay)

เพื่อให้ระบบทำงานได้ลื่นไหล และเสถียร เราจำเป็นต้องมี:

"ระบบจัดการคิวเหตุการณ์ (Event Queue Management)"
"กลไกก์การจัดลำดับความสำคัญ (Prioritization)"

เพื่อควบคุมให้ Event สำคัญถี่สำคัญกว่า และไม่สูญหายระหว่างการประมวลผล

🔹 1. ทำไมต้องจัดการ Event Queue?

ระบบ WebSocket ที่ไม่มีการจัดคิวอาจเจอปัญหาเหล่านี้:

❌ ข้อความเรียงลำดับผิด (Out of order events)
❌ การแจ้งเตือนบางส่วนหาย (Lost events)
❌ การหน่วงเกิดขึ้นเมื่อมีการโหลดสูง (High load latency)

Event Queue จะช่วยให้:

✅ ระบบสามารถ “buffer” ข้อมูลชั่วคราวก่อนส่ง
✅ Event สำคัญ (เช่น system alerts) ถูกประมวลผลก่อน Event ปกติ
✅ ป้องกัน server overload เมื่อมีการเชื่อมต่อจำนวนมาก

🧩 2. ออกแบบโครงสร้าง Event Queue ใน Go

เราสามารถใช้ Channel และ Priority Queue (Heap) ของ Golang เพื่อจัดการลำดับของเหตุการณ์ (Event Priority) ได้อย่างง่ายและมีประสิทธิภาพ

ตัวอย่างโค้ด Golang: Priority Event Queue

package main

import (
	"container/heap"
	"fmt"
	"time"
)

// Event แทนเหตุการณ์ในระบบ
type Event struct {
	Priority int
	Message  string
	Index    int
}

// PriorityQueue คือคิวของเหตุการณ์ตามลำดับความสำคัญ
type PriorityQueue []*Event

func (pq PriorityQueue) Len() int { return len(pq) }

func (pq PriorityQueue) Less(i, j int) bool {
	return pq[i].Priority > pq[j].Priority // ยิ่งค่ามาก ยิ่งสำคัญ
}

func (pq PriorityQueue) Swap(i, j int) {
	pq[i], pq[j] = pq[j], pq[i]
	pq[i].Index, pq[j].Index = i, j
}

func (pq *PriorityQueue) Push(x interface{}) {
	item := x.(*Event)
	item.Index = len(*pq)
	*pq = append(*pq, item)
}

func (pq *PriorityQueue) Pop() interface{} {
	old := *pq
	n := len(old)
	item := old[n-1]
	*pq = old[0 : n-1]
	return item
}

func main() {
	pq := make(PriorityQueue, 0)
	heap.Init(&pq)

	// เพิ่ม Event ลงคิว
	heap.Push(&pq, &Event{Priority: 3, Message: "📢 Chat Message"})
	heap.Push(&pq, &Event{Priority: 1, Message: "🔔 Notification"})
	heap.Push(&pq, &Event{Priority: 5, Message: "🚨 System Alert"})

	for pq.Len() > 0 {
		event := heap.Pop(&pq).(*Event)
		fmt.Printf("Processing: %s\n", event.Message)
		time.Sleep(500 * time.Millisecond)
	}
}

🧠 ผลลัพธ์:

Processing: 🚨 System Alert
Processing: 📢 Chat Message
Processing: 🔔 Notification

✅ เห็นได้ว่าระบบจัดลำดับตามความสำคัญ (Priority) อย่างถูกต้อง

⚙️ 3. การประยุกต์ในระบบ WebSocket จริง

เมื่อฝั่งเซิร์ฟเวอร์ได้รับ Event จากหลายแหล่ง (เช่น User Action, System Event, Notification) เราสามารถใช้ Queue แบบนี้เพื่อ:

แยก Event สำคัญออกจาก Event ปกติ
ควบคุมการส่งข้อมูลแบบเรียลไทม์ให้เป็นลำดับ
ป้องกันการ overload เมื่อมี traffic สูง

ตัวอย่างการเชื่อมต่อกับ Redis หรือ Kafka ก็สามารถใช้แนวคิดเดียวกันนี้ เพื่อ scale ระบบให้รองรับผู้ใช้หลักหมื่น–แสนคนพร้อมกันได้

🔧 4. Best Practices สำหรับ Event Queue Management

ใช้ Priority Tag (เช่น low, normal, high, critical) เพื่อแยกประเภทเหตุการณ์
ใช้ Worker Pool เพื่อประมวลผล Event หลายคิวพร้อมกัน
จัดการ Timeout / Retry สำหรับ Event ที่ส่งไม่สำเร็จ
ใช้ Monitoring เพื่อตรวจสอบ backlog ของ Queue

🚀 ท้าให้ลอง!

ลองสร้าง Priority Queue สำหรับ Event แบบจำลองดู จากนั้นลองเพิ่มระบบแจ้งเตือน (Notification) และข้อความ (Chat) แล้วกำหนด Priority คุณจะเห็นว่า Event สำคัญถูกประมวลผลก่อน และระบบทำงานลื่นขึ้นทันที ⚡

🌟 EP ถัดไป:

ใน EP.106 เราจะพูดถึง “Monitoring & Metrics สำหรับ WebSocket Production” เรียนรู้วิธีติดตามการทำงานของ WebSocket Server ด้วย Prometheus, Grafana และ Metrics สำคัญที่ควรรู้ในระบบจริง! 📊

อ่านบทความ 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/