ในระบบ WebSocket ที่มีผู้ใช้จำนวนมากและเชื่อมต่อพร้อมกันแบบเรียลไทม์ หนึ่งในปัญหาที่มักเกิดขึ้นคือ “ข้อความหลุดลำดับ” (Out-of-Order Message) 😩

เช่น ผู้ใช้ A ส่งข้อความ 3 ข้อความติดกัน แต่ผู้ใช้ B กลับได้รับข้อความในลำดับ: 2 → 1 → 3

สาเหตุที่พบบ่อยได้แก่:

• การส่งข้อมูลพร้อมกันจากหลาย goroutine
• การ reconnect โดยที่ event ยังไม่ sync ทัน
• การ broadcast ข้าม instance โดยไม่มีการจัดลำดับที่เหมาะสม

EP นี้จะพาคุณเรียนรู้ เทคนิคการจัดเรียงลำดับข้อความ (Message Ordering) และ การจัดการ Event Sequence เพื่อให้ระบบ WebSocket ของคุณ แม่นยำ 100% และพร้อมใช้งานจริงใน Production 🚀

🧩 1. ทำไม Message Ordering สำคัญ?

ในระบบเรียลไทม์ เช่น:

• ระบบแชท (Chat)
• เกมออนไลน์ (Game)
• ระบบแก้ไขร่วมกัน (Collaborative App)

ลำดับของข้อความมีผลโดยตรงต่อความถูกต้องของข้อมูล

⚙️ 2. การกำหนด Sequence Number ให้ทุก Message

ทุกข้อความที่ส่งผ่าน WebSocket ควรมีฟิลด์ sequence_id ซึ่งเป็นเลขจำนวนเต็ม (int)
ใช้เพื่อระบุลำดับข้อความของผู้ใช้แต่ละคน

ตัวอย่างโครงสร้าง JSON:

{
  "user_id": "u123",
  "sequence_id": 42,
  "message": "Hello world",
  "timestamp": "2025-11-23T21:15:00Z"
}

ในฝั่ง Go Server:

type Message struct {
	UserID     string `json:"user_id"`
	SequenceID int    `json:"sequence_id"`
	Content    string `json:"message"`
	Timestamp  string `json:"timestamp"`
}

✅ เมื่อผู้ใช้ส่งข้อความใหม่ → ระบบจะเพิ่ม sequence_id ขึ้นทีละ 1 และบันทึกไว้ในฐานข้อมูล

🔀 3. การตรวจสอบลำดับก่อน Broadcast

ในระบบที่มีผู้ใช้จำนวนมาก และ broadcast พร้อมกันหลาย goroutine

ข้อความอาจหลุดลำดับได้ ต้องใช้ queue ต่อห้องแชท (chat room) และ ใช้ goroutine เดียวในการส่ง

ตัวอย่างโค้ด:

func broadcastMessages(roomID string, msgChan <-chan Message) {
	lastSeq := 0
	for msg := range msgChan {
		if msg.SequenceID == lastSeq+1 {
			for client := range rooms[roomID] {
				client.Conn.WriteJSON(msg)
			}
			lastSeq = msg.SequenceID
		} else {
			log.Printf("Skipped or delayed message: %v", msg.SequenceID)
		}
	}
}

✅ การใช้ Goroutine เดียวต่อห้อง ช่วยลดปัญหาแย่ง resource และทำให้ข้อความเรียงลำดับถูกต้อง

🧠 4. Sync Event ข้าม Instance ด้วย Redis Pub/Sub

หากคุณใช้ระบบแบบ multi-instance เช่นรันหลาย Pods บน Kubernetes

จำเป็นต้อง sync ข้อความระหว่างแต่ละ instance ด้วย Redis Pub/Sub

ตัวอย่าง:

func handleRedisMessages() {
	sub := redisClient.Subscribe(ctx, "event_channel")
	for msg := range sub.Channel() {
		var event Message
		json.Unmarshal([]byte(msg.Payload), &event)
		eventQueue <- event
	}
}

✅ ดึง event จาก Redis → ส่งเข้า eventQueue กลาง เพื่อจัดเรียงตาม sequence_id ก่อน broadcast

📈 5. วิธีจัดการ Out-of-Order Recovery

ถ้า client ได้รับ message 45 แต่ขาด 44

ควรมีระบบ resync หรือ request backlog จาก server

แนวคิด:

func handleResync(conn *websocket.Conn, lastReceived int) {
	missing := getMessagesSince(lastReceived)
	for _, m := range missing {
		conn.WriteJSON(m)
	}
}

✅ Server จะส่งเฉพาะ message ที่ client ขาดไป

🔒 6. Best Practices สำหรับ Message Ordering

🚀 ท้าให้ลอง!

ลองสร้างระบบ Chat ที่ใส่ sequence_id ให้ทุกข้อความแล้วให้ client ตรวจสอบว่าข้อความเรียงลำดับถูกต้องหรือไม่ 🔢 คุณจะเข้าใจทันทีว่า "Message Ordering" คือหัวใจของระบบเรียลไทม์ระดับ Production! 💬

🌟 EP ถัดไป: EP.112 — การสร้าง Notification แบบเรียลไทม์

ในตอนถัดไป เราจะพูดถึง "การสร้างระบบแจ้งเตือนแบบเรียลไทม์ (Real-time Notification System)"
เรียนรู้การส่ง Push Notification ผ่าน WebSocket เพื่อแจ้งให้ผู้ใช้ทราบทันทีเมื่อมี Event สำคัญเกิดขึ้นในระบบ 🔔