Socket.IO: เจาะลึกฟีเจอร์เด็ด สร้างแอป Real-time ขั้นเทพ

# สร้างโฟลเดอร์และเข้าไปข้างใน
mkdir socketio-chat && cd socketio-chat
 
# เริ่มโปรเจกต์ Node.js
npm init -y
 
# ติดตั้ง Express และ Socket.IO
npm install express socket.io

import express from 'express';
import { createServer } from 'http';
import { Server } from 'socket.io';
 
const app = express();
const httpServer = createServer(app);
const io = new Server(httpServer, {
  // Options (ถ้ามี)
});
 
// เมื่อมี Client เชื่อมต่อเข้ามา
io.on('connection', (socket) => {
  console.log(`✅ มีคนเชื่อมต่อเข้ามา: ${socket.id}`);
 
  // เมื่อ Client ตัดการเชื่อมต่อ
  socket.on('disconnect', () => {
    console.log(`❌ มีคนตัดการเชื่อมต่อ: ${socket.id}`);
  });
});
 
httpServer.listen(3000, () => {
  console.log('🚀 Server is running on http://localhost:3000');
});

io.on('connection', (socket) => {
  // ส่ง Event ไปหา Client ที่เพิ่งเชื่อมต่อเข้ามาเท่านั้น
  socket.emit('welcome', 'ยินดีต้อนรับสู่เซิร์ฟเวอร์!');
});

import { io } from "socket.io-client";
const socket = io("http://localhost:3000");
 
socket.on('welcome', (message) => {
  console.log('ข้อความจากเซิร์ฟเวอร์:', message); // "ยินดีต้อนรับสู่เซิร์ฟเวอร์!"
});

io.on('connection', (socket) => {
  socket.on('chat message', (msg) => {
    // ส่ง Event 'chat message' ไปหา "ทุกคน" ที่เชื่อมต่ออยู่
    io.emit('chat message', msg);
  });
});

socket.broadcast.emit('chat message', msg);

io.on('connection', (socket) => {
  // ให้ Client เข้าร่วมห้อง
  socket.on('join room', (roomName) => {
    socket.join(roomName);
    console.log(`${socket.id} ได้เข้าร่วมห้อง ${roomName}`);
 
    // ส่งข้อความทักทาย "เฉพาะคนในห้องนั้น"
    socket.to(roomName).emit('notification', `${socket.id} เข้ามาในห้องแล้ว!`);
  });
 
  // รับข้อความที่ส่งมาเฉพาะห้อง
  socket.on('message to room', ({ roomName, message }) => {
    // ส่งข้อความไปหาทุกคนในห้อง "ยกเว้น" คนส่ง
    socket.to(roomName).emit('new message', message);
  });
});

// Namespace หลัก (default คือ '/')
io.on('connection', (socket) => { /* ... Logic สำหรับผู้ใช้ทั่วไป ... */ });
 
// Namespace สำหรับ Admin
const adminNamespace = io.of('/admin');
adminNamespace.on('connection', (socket) => {
  console.log('แอดมินเชื่อมต่อเข้ามาแล้ว!');
  // ... Logic สำหรับ Admin เท่านั้น ...
  socket.on('delete user', (userId) => {
    // ...
  });
});

const adminSocket = io("http://localhost:3000/admin");
 
adminSocket.emit('delete user', 123);

// Middleware จะถูกรันก่อน Event 'connection'
io.use((socket, next) => {
  const token = socket.handshake.auth.token;
 
  // สมมติว่าเรามีฟังก์ชัน verifyToken
  if (isValidToken(token)) {
    // ถ้า Token ถูกต้อง, อนุญาตให้เชื่อมต่อ
    next();
  } else {
    // ถ้าไม่ถูกต้อง, ปฏิเสธการเชื่อมต่อ
    next(new Error("Authentication error"));
  }
});
 
io.on('connection', (socket) => {
  // โค้ดในนี้จะทำงานก็ต่อเมื่อ Middleware ผ่านเท่านั้น
  console.log('ผู้ใช้ที่ยืนยันตัวตนแล้วเชื่อมต่อเข้ามา:', socket.id);
});

socket.emit('update profile', { name: 'New Name' }, (response) => {
  if (response.success) {
    console.log('อัปเดตโปรไฟล์สำเร็จ!');
  } else {
    console.error('เกิดข้อผิดพลาด:', response.error);
  }
});

socket.on('update profile', (data, callback) => {
  try {
    // ... ทำการอัปเดตข้อมูลในฐานข้อมูล ...
    // เรียก Callback กลับไปหา Client ว่าสำเร็จ
    callback({ success: true });
  } catch (err) {
    // เรียก Callback กลับไปพร้อม Error
    callback({ success: false, error: err.message });
  }
});