실시간: Socket.io 프로덕션 패턴

import { Server } from 'socket.io';
import { createServer } from 'http';
import express from 'express';
import jwt from 'jsonwebtoken';

const app = express();
const httpServer = createServer(app);
const io = new Server(httpServer, {
  cors: { origin: process.env.FRONTEND_URL },
});

// 인증 미들웨어
io.use((socket, next) => {
  const token = socket.handshake.auth.token;
  if (!token) return next(new Error('No token'));
  try {
    const payload = jwt.verify(token, process.env.JWT_ACCESS_SECRET!) as any;
    socket.data.userId = payload.sub;
    next();
  } catch {
    next(new Error('Invalid token'));
  }
});

io.on('connection', (socket) => {
  console.log('User connected:', socket.data.userId);

  // 룸 입장
  socket.on('join-room', async (roomId) => {
    const allowed = await canAccessRoom(socket.data.userId, roomId);
    if (!allowed) return socket.emit('error', 'Forbidden');
    socket.join(`room:${roomId}`);
  });

  // 메시지 전송
  socket.on('message', async (data) => {
    const msg = await db.message.create({
      data: { content: data.content, userId: socket.data.userId, roomId: data.roomId },
    });
    io.to(`room:${data.roomId}`).emit('message', msg);
  });

  socket.on('disconnect', () => {
    console.log('User disconnected');
  });
});

import { createAdapter } from '@socket.io/redis-adapter';
import { createClient } from 'redis';

const pubClient = createClient({ url: process.env.REDIS_URL });
const subClient = pubClient.duplicate();

await Promise.all([pubClient.connect(), subClient.connect()]);
io.adapter(createAdapter(pubClient, subClient));

// 이제 여러 서버 인스턴스가 룸을 공유
// 서버 A의 io.to(room).emit() → 서버 B의 클라이언트에게도 도달

import { io as ioClient } from 'socket.io-client';

const socket = ioClient(process.env.NEXT_PUBLIC_API_URL!, {
  auth: { token: localStorage.getItem('accessToken') },
  reconnection: true,
  reconnectionAttempts: 5,
  reconnectionDelay: 1000,
});

socket.on('connect', () => console.log('Connected'));
socket.on('disconnect', () => console.log('Disconnected'));
socket.on('error', (err) => console.error(err));

// 룸 입장
socket.emit('join-room', roomId);

// 메시지 수신
socket.on('message', (msg) => {
  setMessages(prev => [...prev, msg]);
});

// 메시지 전송
socket.emit('message', { roomId, content: 'Hello' });

// 서버 — 특정 사용자에게 알림
function notifyUser(userId: string, notification: Notification) {
  io.to(`user:${userId}`).emit('notification', notification);
}

// 사용자가 connect 시 자동 룸 입장
io.on('connection', (socket) => {
  socket.join(`user:${socket.data.userId}`);
});


// 사용
async function likePost(postId: string, fromUserId: string) {
  const post = await db.post.findUnique({ where: { id: postId } });
  if (post.authorId !== fromUserId) {
    notifyUser(post.authorId, {
      type: 'like',
      postId,
      fromUserId,
      createdAt: new Date(),
    });
  }
}

네임스페이스 (Namespace):
- 완전 분리된 채널 (/, /admin, /chat 등)
- 다른 미들웨어 적용 가능

룸 (Room):
- 같은 네임스페이스 내 그룹
- 동적 생성·소멸
- 채팅방, 게임방 등에 적합


// 네임스페이스
const adminIo = io.of('/admin');
adminIo.use(adminAuth);

// 룸
socket.join('room:123');
io.to('room:123').emit('message', msg);

// 자동 cleanup
io.on('connection', (socket) => {
  const interval = setInterval(() => socket.emit('ping'), 30000);

  socket.on('disconnect', () => {
    clearInterval(interval);
    // DB에 user 상태 업데이트
    db.user.update({
      where: { id: socket.data.userId },
      data: { lastSeenAt: new Date() },
    });
  });
});