{"id":2098,"date":"2026-08-28T22:28:42","date_gmt":"2026-08-28T22:28:42","guid":{"rendered":"https:\/\/wayhope.kro.kr\/?p=2098"},"modified":"2026-08-31T07:33:00","modified_gmt":"2026-08-31T07:33:00","slug":"node-js-cluster%ec%99%80-socket-io","status":"publish","type":"post","link":"https:\/\/wayhope.kro.kr\/?p=2098","title":{"rendered":"Node.js Cluster\uc640 Socket.IO"},"content":{"rendered":"\n

Node.js \uc11c\ubc84\ub97c \uc5ec\ub7ec \ud504\ub85c\uc138\uc2a4\ub85c \ud655\uc7a5\ud558\uba74 CPU \uc790\uc6d0\uc744 \ub354 \ud65c\uc6a9\ud560 \uc218 \uc788\ub2e4.<\/p>\n\n\n\n

\ud558\uc9c0\ub9cc \ud504\ub85c\uc138\uc2a4\uac00 \ubd84\ub9ac\ub418\ub294 \uc21c\uac04 \ud558\ub098\uc758 \ubb38\uc81c\uac00 \uc0dd\uae34\ub2e4.<\/p>\n\n\n\n

\ud504\ub85c\uc138\uc2a4\uc758 \uba54\ubaa8\ub9ac\ub294 \uc11c\ub85c \uacf5\uc720\ub418\uc9c0 \uc54a\ub294\ub2e4.<\/strong><\/p>\n\n\n\n

\uc77c\ubc18\uc801\uc778 HTTP \uc11c\ubc84\ub77c\uba74 \uc774 \ubb38\uc81c\ub97c \uc678\ubd80 DB\ub098 \uce90\uc2dc\ub97c \ud1b5\ud574 \uc27d\uac8c \ud574\uacb0\ud560 \uc218 \uc788\uc9c0\ub9cc, Socket.IO\ucc98\ub7fc \uc9c0\uc18d\uc801\uc778 \uc5f0\uacb0\uc744 \uc720\uc9c0\ud558\ub294 \uc2dc\uc2a4\ud15c\uc5d0\uc11c\ub294 \uc774\uc57c\uae30\uac00 \ub2ec\ub77c\uc9c4\ub2e4.<\/p>\n\n\n\n

Client -> Socket.IO Worker -> Connection State<\/code><\/p>\n\n\n\n

\uc5ec\uae30\uc11c Worker\uac00 \uc5ec\ub7ec \uac1c\uac00 \ub418\uba74 \uc5f0\uacb0 \uc0c1\ud0dc \uc5ed\uc2dc \ubd84\ub9ac\ub41c\ub2e4.<\/p>\n\n\n\n

Worker 1 -> Connection A<\/code><\/p>\n\n\n\n

Worker 2 -> Connection B<\/code><\/p>\n\n\n\n

\ub530\ub77c\uc11c \uc11c\ub85c \ub2e4\ub978 Worker\uc5d0 \uc5f0\uacb0\ub41c \ud074\ub77c\uc774\uc5b8\ud2b8 \uc0ac\uc774\uc5d0\uc11c \uc774\ubca4\ud2b8\ub97c \uc804\ub2ec\ud558\ub824\uba74 \ud504\ub85c\uc138\uc2a4 \uac04 \ud1b5\uc2e0 \uacc4\uce35<\/strong>\uc774 \ud544\uc694\ud558\ub2e4.<\/p>\n\n\n\n

\n\n\n\n

Node.js Cluster \uae30\ubcf8 \uad6c\uc870<\/h1>\n\n\n\n

Node.js\uc758 Cluster\ub97c \uc774\uc6a9\ud558\uba74 \uc5ec\ub7ec Worker \ud504\ub85c\uc138\uc2a4\ub97c \uc2e4\ud589\ud560 \uc218 \uc788\ub2e4.<\/p>\n\n\n\n

\uac04\ub2e8\ud55c \uc608\uc81c\ub97c \ubcf4\uc790.<\/p>\n\n\n\n

const cluster = require('cluster');\nconst http = require('http');\nconst os = require('os');\n\nif (cluster.isPrimary) {\n    const cpuCount = os.cpus().length;\n\n    for (let i = 0; i < cpuCount; i++) {\n        cluster.fork();\n    }\n\n    cluster.on('exit', (worker) => {\n        console.log(`Worker ${worker.process.pid} exited`);\n    });\n}\nelse {\n    const server = http.createServer((req, res) => {\n        res.writeHead(200);\n        res.end(`Worker PID: ${process.pid}`);\n    });\n\n    server.listen(3000);\n\n    console.log(`Worker started: ${process.pid}`);\n}\n<\/code><\/pre>\n\n\n\n
\uc2e4\ud589\ud558\uba74 \ud558\ub098\uc758 Primary Process\uac00 \uc5ec\ub7ec Worker\ub97c \uc0dd\uc131\ud55c\ub2e4.<\/p>\n\n\n\n
Primary -> Worker 1 \/ Worker 2 \/ Worker 3 \/ Worker 4<\/code><\/p>\n\n\n\n
\uac01 Worker\ub294 \ubcc4\ub3c4\uc758 Node.js \ud504\ub85c\uc138\uc2a4\ub2e4.<\/p>\n\n\n\n
\ub530\ub77c\uc11c \ub2e4\uc74c\uacfc \uac19\uc740 \ubcc0\uc218\ub294 \uc11c\ub85c \uacf5\uc720\ub418\uc9c0 \uc54a\ub294\ub2e4.<\/p>\n\n\n\n
let users = [];\n\nusers.push('PlayerA');\n<\/code><\/pre>\n\n\n\n
Worker 1\uc5d0\uc11c users<\/code>\uc5d0 PlayerA\ub97c \ub123\uc5c8\ub2e4\uace0 \ud574\ub3c4 Worker 2\uc758 users<\/code>\uc5d0\ub294 PlayerA\uac00 \uc874\uc7ac\ud558\uc9c0 \uc54a\ub294\ub2e4.<\/p>\n\n\n\n
Worker 1 -> users = [PlayerA]<\/code><\/p>\n\n\n\n
Worker 2 -> users = []<\/code><\/p>\n\n\n\n
\uc774\uac83\uc774 Cluster \ud658\uacbd\uc5d0\uc11c \uac00\uc7a5 \uba3c\uc800 \uc774\ud574\ud574\uc57c \ud558\ub294 \ubd80\ubd84\uc774\ub2e4.<\/p>\n\n\n\n
\n\n\n\n
Socket.IO \ub2e8\uc77c \ud504\ub85c\uc138\uc2a4<\/h1>\n\n\n\n
Cluster\ub97c \uc801\uc6a9\ud558\uae30 \uc804\uc5d0 Socket.IO\uc758 \uae30\ubcf8 \uad6c\uc870\ubd80\ud130 \ubcf4\uba74 \uc774\ud574\ud558\uae30 \uc27d\ub2e4.<\/p>\n\n\n\n
const http = require('http');\nconst { Server } = require('socket.io');\n\nconst server = http.createServer();\n\nconst io = new Server(server);\n\nio.on('connection', (socket) => {\n    console.log(`Connected: ${socket.id}`);\n\n    socket.on('chat', (message) => {\n        io.emit('chat', message);\n    });\n});\n\nserver.listen(3000);\n<\/code><\/pre>\n\n\n\n
\ub2e8\uc77c \ud504\ub85c\uc138\uc2a4\uc5d0\uc11c\ub294 \ub9e4\uc6b0 \ub2e8\uc21c\ud558\ub2e4.<\/p>\n\n\n\n
Client A -> Socket.IO Server -> Client B<\/code><\/p>\n\n\n\n
\uc11c\ubc84 \ud558\ub098\uac00 \ubaa8\ub4e0 Socket \uc5f0\uacb0\uc744 \uad00\ub9ac\ud558\uae30 \ub54c\ubb38\uc774\ub2e4.<\/p>\n\n\n\n
\uc608\ub97c \ub4e4\uc5b4 A\uac00 \uba54\uc2dc\uc9c0\ub97c \ubcf4\ub0b4\uba74 \uc11c\ubc84\uac00 \ubaa8\ub4e0 \ud074\ub77c\uc774\uc5b8\ud2b8\uc5d0\uac8c \uc804\ub2ec\ud560 \uc218 \uc788\ub2e4.<\/p>\n\n\n\n
socket.on('chat', (message) => {\n    io.emit('chat', message);\n});\n<\/code><\/pre>\n\n\n\n
\ubb38\uc81c\ub294 \uc11c\ubc84\ub97c \uc5ec\ub7ec Worker\ub85c \ub098\ub204\ub294 \uc21c\uac04 \ubc1c\uc0dd\ud55c\ub2e4.<\/p>\n\n\n\n
\n\n\n\n
Cluster + Socket.IO<\/h1>\n\n\n\n
\ub2e4\uc74c\uacfc \uac19\uc774 Socket.IO \uc11c\ubc84\ub97c Cluster \ud658\uacbd\uc5d0\uc11c \uc2e4\ud589\ud55c\ub2e4\uace0 \ud558\uc790.<\/p>\n\n\n\n
const cluster = require('cluster');\nconst http = require('http');\nconst os = require('os');\nconst { Server } = require('socket.io');\n\nif (cluster.isPrimary) {\n    const cpuCount = os.cpus().length;\n\n    for (let i = 0; i < cpuCount; i++) {\n        cluster.fork();\n    }\n}\nelse {\n    const server = http.createServer();\n    const io = new Server(server);\n\n    io.on('connection', (socket) => {\n        console.log(\n            `Worker ${process.pid} connected: ${socket.id}`\n        );\n\n        socket.on('chat', (message) => {\n            io.emit('chat', message);\n        });\n    });\n\n    server.listen(3000);\n}\n<\/code><\/pre>\n\n\n\n
\uac89\ubcf4\uae30\uc5d0\ub294 \uc815\uc0c1\uc801\uc73c\ub85c \ub3d9\uc791\ud560 \uac83\ucc98\ub7fc \ubcf4\uc778\ub2e4.<\/p>\n\n\n\n
\ud558\uc9c0\ub9cc Worker\uac00 \uc5ec\ub7ec \uac1c \uc874\uc7ac\ud55c\ub2e4.<\/p>\n\n\n\n
Worker 1 -> Socket A<\/code><\/p>\n\n\n\n
Worker 2 -> Socket B<\/code><\/p>\n\n\n\n
A\uac00 Worker 1\uc5d0 \uc5f0\uacb0\ub418\uace0 B\uac00 Worker 2\uc5d0 \uc5f0\uacb0\ub410\ub2e4\uace0 \ud558\uc790.<\/p>\n\n\n\n
A\uac00 \uba54\uc2dc\uc9c0\ub97c \ubcf4\ub0b8\ub2e4.<\/p>\n\n\n\n
socket.on('chat', (message) => {\n    io.emit('chat', message);\n});\n<\/code><\/pre>\n\n\n\n
\uc5ec\uae30\uc11c io.emit()<\/code>\uc740 \ud604\uc7ac Worker\uc758 Socket.IO \uc778\uc2a4\ud134\uc2a4\uac00 \uad00\ub9ac\ud558\ub294 \uc5f0\uacb0<\/strong>\uc744 \uae30\uc900\uc73c\ub85c \ub3d9\uc791\ud55c\ub2e4.<\/p>\n\n\n\n
\ub530\ub77c\uc11c Worker 1\uc5d0\uc11c \ubc1c\uc0dd\ud55c \uc774\ubca4\ud2b8\ub97c Worker 2\uac00 \uc790\ub3d9\uc73c\ub85c \uc54c \uc218 \uc788\ub294 \uac83\uc740 \uc544\ub2c8\ub2e4.<\/p>\n\n\n\n
Worker 1 -> io.emit() -> Worker 1\uc758 Socket<\/code><\/p>\n\n\n\n
Worker 1 -X-> Worker 2\uc758 Socket<\/code><\/p>\n\n\n\n
\uc774\uac83\uc774 \uba40\ud2f0 \ud504\ub85c\uc138\uc2a4 Socket.IO\uc758 \ud575\uc2ec \ubb38\uc81c\ub2e4.<\/p>\n\n\n\n
\n\n\n\n
Redis\ub97c \ucd94\uac00\ud55c\ub2e4<\/h1>\n\n\n\n
\uc774 \ubb38\uc81c\ub97c \ud574\uacb0\ud558\ub824\uba74 Worker \uc0ac\uc774\uc5d0\uc11c \uba54\uc2dc\uc9c0\ub97c \uc804\ub2ec\ud560 \uc218 \uc788\ub294 \uacf5\uc720 \uacc4\uce35\uc774 \ud544\uc694\ud558\ub2e4.<\/p>\n\n\n\n
\uc5ec\uae30\uc11c Redis\ub97c \uc0ac\uc6a9\ud560 \uc218 \uc788\ub2e4.<\/p>\n\n\n\n
Worker 1 \/ Worker 2 \/ Worker 3 -> Redis<\/code><\/p>\n\n\n\n
Redis\uc758 Pub\/Sub\uc744 \uc774\uc6a9\ud558\uba74 \ud55c Worker\uac00 \ubc1c\ud589\ud55c \uc774\ubca4\ud2b8\ub97c \ub2e4\ub978 Worker\uc5d0\uac8c \uc804\ub2ec\ud560 \uc218 \uc788\ub2e4.<\/p>\n\n\n\n
Worker 1 -> Publish -> Redis -> Subscribe -> Worker 2<\/code><\/p>\n\n\n\n
Socket.IO\uc5d0\uc11c\ub294 \uc774 \uae30\ub2a5\uc744 \uc9c1\uc811 \uad6c\ud604\ud558\uae30\ubcf4\ub2e4 Redis Adapter\ub97c \uc0ac\uc6a9\ud558\ub294 \uac83\uc774 \uc77c\ubc18\uc801\uc774\ub2e4.<\/p>\n\n\n\n
\n\n\n\n
Socket.IO Redis Adapter<\/h1>\n\n\n\n
\ud604\uc7ac Socket.IO\uc5d0\uc11c\ub294 @socket.io\/redis-adapter<\/code>\ub97c \uc0ac\uc6a9\ud560 \uc218 \uc788\ub2e4.<\/p>\n\n\n\n
\ud544\uc694\ud55c \ud328\ud0a4\uc9c0\ub97c \uc124\uce58\ud55c\ub2e4.<\/p>\n\n\n\n
npm install socket.io @socket.io\/redis-adapter redis\n<\/code><\/pre>\n\n\n\n
\uc11c\ubc84 \ucf54\ub4dc\ub294 \ub2e4\uc74c\uacfc \uac19\uc774 \uad6c\uc131\ud560 \uc218 \uc788\ub2e4.<\/p>\n\n\n\n
const http = require('http');\nconst { Server } = require('socket.io');\n\nconst { createClient } = require('redis');\nconst { createAdapter } = require('@socket.io\/redis-adapter');\n\nasync function startServer() {\n    const server = http.createServer();\n\n    const io = new Server(server);\n\n    const pubClient = createClient({\n        url: 'redis:\/\/localhost:6379'\n    });\n\n    const subClient = pubClient.duplicate();\n\n    await Promise.all([\n        pubClient.connect(),\n        subClient.connect()\n    ]);\n\n    io.adapter(\n        createAdapter(pubClient, subClient)\n    );\n\n    io.on('connection', (socket) => {\n        console.log(`Connected: ${socket.id}`);\n\n        socket.on('chat', (message) => {\n            io.emit('chat', message);\n        });\n    });\n\n    server.listen(3000, () => {\n        console.log('Server started');\n    });\n}\n\nstartServer();\n<\/code><\/pre>\n\n\n\n
\ud575\uc2ec\uc740 \ub2e4\uc74c \ucf54\ub4dc\ub2e4.<\/p>\n\n\n\n
io.adapter(\n    createAdapter(pubClient, subClient)\n);\n<\/code><\/pre>\n\n\n\n
\uc774 \uc124\uc815\uc744 \ud558\uba74 Socket.IO\uc758 \uc11c\ubc84 \uac04 \uc774\ubca4\ud2b8 \uc804\ub2ec\uc744 Redis\ub97c \ud1b5\ud574 \ucc98\ub9ac\ud560 \uc218 \uc788\ub2e4.<\/p>\n\n\n\n
\n\n\n\n
Cluster\uc640 Redis Adapter \uacb0\ud569<\/h1>\n\n\n\n
\uc774\uc81c Cluster\uc640 Redis Adapter\ub97c \uacb0\ud569\ud560 \uc218 \uc788\ub2e4.<\/p>\n\n\n\n
const cluster = require('cluster');\nconst os = require('os');\n\nif (cluster.isPrimary) {\n    const cpuCount = os.cpus().length;\n\n    for (let i = 0; i < cpuCount; i++) {\n        cluster.fork();\n    }\n}\nelse {\n    startWorker();\n}\n\nasync function startWorker() {\n    const http = require('http');\n    const { Server } = require('socket.io');\n\n    const { createClient } = require('redis');\n    const { createAdapter } = require('@socket.io\/redis-adapter');\n\n    const server = http.createServer();\n    const io = new Server(server);\n\n    const pubClient = createClient({\n        url: 'redis:\/\/localhost:6379'\n    });\n\n    const subClient = pubClient.duplicate();\n\n    await Promise.all([\n        pubClient.connect(),\n        subClient.connect()\n    ]);\n\n    io.adapter(\n        createAdapter(pubClient, subClient)\n    );\n\n    io.on('connection', (socket) => {\n        console.log(\n            `Worker ${process.pid}: ${socket.id}`\n        );\n\n        socket.on('chat', (message) => {\n            io.emit('chat', {\n                worker: process.pid,\n                message\n            });\n        });\n    });\n\n    server.listen(3000);\n}\n<\/code><\/pre>\n\n\n\n
\uad6c\uc870\ub294 \uc774\ub807\uac8c \ub41c\ub2e4.<\/p>\n\n\n\n
Primary -> Worker 1 \/ Worker 2 \/ Worker 3 \/ Worker 4<\/code><\/p>\n\n\n\n
\uac01 Worker\ub294 \uc790\uc2e0\uc758 Socket \uc5f0\uacb0\uc744 \uad00\ub9ac\ud55c\ub2e4.<\/p>\n\n\n\n
Worker 1 -> Client A<\/code><\/p>\n\n\n\n
Worker 2 -> Client B<\/code><\/p>\n\n\n\n
Worker 3 -> Client C<\/code><\/p>\n\n\n\n
\uadf8\ub9ac\uace0 Worker \uc0ac\uc774\uc758 \uc774\ubca4\ud2b8 \uc804\ub2ec\uc740 Redis\ub97c \uc0ac\uc6a9\ud55c\ub2e4.<\/p>\n\n\n\n
Worker 1 -> Redis -> Worker 2 \/ Worker 3 \/ Worker 4<\/code><\/p>\n\n\n\n
\ub530\ub77c\uc11c A\uac00 \uba54\uc2dc\uc9c0\ub97c \ubcf4\ub0b4\uba74 \ub2e4\uc74c\uacfc \uac19\uc740 \ud750\ub984\uc774 \ub9cc\ub4e4\uc5b4\uc9c4\ub2e4.<\/p>\n\n\n\n
Client A -> Worker 1 -> Redis -> Worker 2 \/ Worker 3 -> Client B \/ Client C<\/code><\/p>\n\n\n\n
\n\n\n\n
Redis Pub\/Sub\uc758 \uae30\ubcf8 \uc6d0\ub9ac<\/h1>\n\n\n\n
Redis Adapter\uc758 \ub0b4\ubd80 \uac1c\ub150\uc744 \uc774\ud574\ud558\ub824\uba74 Pub\/Sub \uc790\uccb4\ub97c \uc774\ud574\ud558\uba74 \ub41c\ub2e4.<\/p>\n\n\n\n
Redis\uc5d0\ub294 Publish\uc640 Subscribe\ub77c\ub294 \uac1c\ub150\uc774 \uc788\ub2e4.<\/p>\n\n\n\n
Publisher\ub294 \uba54\uc2dc\uc9c0\ub97c \ubc1c\ud589\ud55c\ub2e4.<\/p>\n\n\n\n
await publisher.publish(\n    'chat',\n    JSON.stringify({\n        user: 'PlayerA',\n        message: 'Hello'\n    })\n);\n<\/code><\/pre>\n\n\n\n
Subscriber\ub294 \ud2b9\uc815 Channel\uc744 \uad6c\ub3c5\ud55c\ub2e4.<\/p>\n\n\n\n
await subscriber.subscribe(\n    'chat',\n    (message) => {\n        const data = JSON.parse(message);\n\n        console.log(data);\n    }\n);\n<\/code><\/pre>\n\n\n\n
\uad6c\uc870\ub294 \ub2e4\uc74c\uacfc \uac19\ub2e4.<\/p>\n\n\n\n
Publisher -> Redis Channel -> Subscriber<\/code><\/p>\n\n\n\n
Socket.IO\uc5d0\uc11c\ub294 \uc774 \uac1c\ub150\uc744 \uc11c\ubc84 \uac04 \uc774\ubca4\ud2b8 \uc804\ub2ec\uc5d0 \ud65c\uc6a9\ud55c\ub2e4.<\/p>\n\n\n\n
Socket.IO Worker -> Redis Adapter -> Redis -> Redis Adapter -> Socket.IO Worker<\/code><\/p>\n\n\n\n
\n\n\n\n
Room\uc5d0\uc11c\ub3c4 \uac19\uc740 \ubb38\uc81c\uac00 \ubc1c\uc0dd\ud55c\ub2e4<\/h1>\n\n\n\n
Socket.IO\uc758 Room\uc744 \uc0ac\uc6a9\ud558\ub294 \uacbd\uc6b0\uc5d0\ub3c4 \uba40\ud2f0 \uc11c\ubc84 \ud658\uacbd\uc744 \uace0\ub824\ud574\uc57c \ud55c\ub2e4.<\/p>\n\n\n\n
\uc608\ub97c \ub4e4\uc5b4 \uac8c\uc784 \ubc29\uc744 \ub9cc\ub4e0\ub2e4\uace0 \ud558\uc790.<\/p>\n\n\n\n
socket.join('room-1');\n<\/code><\/pre>\n\n\n\n
\uadf8\ub9ac\uace0 \ubc29\uc5d0 \uba54\uc2dc\uc9c0\ub97c \ubcf4\ub0b8\ub2e4.<\/p>\n\n\n\n
io.to('room-1').emit('gameState', data);\n<\/code><\/pre>\n\n\n\n
\ub2e8\uc77c \uc11c\ubc84\uc5d0\uc11c\ub294 \uac04\ub2e8\ud558\ub2e4.<\/p>\n\n\n\n
\ud558\uc9c0\ub9cc \uc5ec\ub7ec Worker\uac00 \uc874\uc7ac\ud558\uba74 Room\uacfc Socket \uc5f0\uacb0\uc774 \uac01\uac01 \ub2e4\ub978 Worker\uc5d0 \uc874\uc7ac\ud560 \uc218 \uc788\ub2e4.<\/p>\n\n\n\n
Worker 1 -> Room 1 -> Player A<\/code><\/p>\n\n\n\n
Worker 2 -> Room 1 -> Player B<\/code><\/p>\n\n\n\n
\uc774\ub54c Worker 1\uc5d0\uc11c \ubc1c\uc0dd\ud55c Room \uc774\ubca4\ud2b8\uac00 Worker 2\uae4c\uc9c0 \uc804\ub2ec\ub418\uc5b4\uc57c \ud55c\ub2e4.<\/p>\n\n\n\n
Redis Adapter\ub97c \uc0ac\uc6a9\ud558\uba74 \uc774\ub7ec\ud55c \uc11c\ubc84 \uac04 \uc774\ubca4\ud2b8 \uc804\ub2ec\uc744 \ucc98\ub9ac\ud560 \uc218 \uc788\ub2e4.<\/p>\n\n\n\n
socket.join('room-1');\n\nsocket.on('gameState', (data) => {\n    io.to('room-1').emit('gameState', data);\n});\n<\/code><\/pre>\n\n\n\n
\uad6c\uc870\ub294 \ub2e4\uc74c\uacfc \uac19\ub2e4.<\/p>\n\n\n\n
Player A -> Worker 1 -> Redis -> Worker 2 -> Player B<\/code><\/p>\n\n\n\n
\ub530\ub77c\uc11c Room \uae30\ubc18 \uac8c\uc784\uc774\ub098 \ucc44\ud305 \uc2dc\uc2a4\ud15c\uc5d0\uc11c \ud2b9\ud788 \uc911\uc694\ud55c \uad6c\uc870\uac00 \ub41c\ub2e4.<\/p>\n\n\n\n
\n\n\n\n
Sticky Session<\/h1>\n\n\n\n
Redis Adapter\ub97c \uc0ac\uc6a9\ud55c\ub2e4\uace0 \ud574\uc11c \ubaa8\ub4e0 \uc5f0\uacb0 \ubb38\uc81c\uac00 \ud574\uacb0\ub418\ub294 \uac83\uc740 \uc544\ub2c8\ub2e4.<\/p>\n\n\n\n
Load Balancer\ub97c \uc0ac\uc6a9\ud55c\ub2e4\uba74 Socket.IO\uc758 \uc5f0\uacb0 \ubc29\uc2dd\uacfc \uc138\uc158 \uad00\ub9ac\ub3c4 \uace0\ub824\ud574\uc57c \ud55c\ub2e4.<\/p>\n\n\n\n
\uc608\ub97c \ub4e4\uc5b4 \ub2e4\uc74c\uacfc \uac19\uc740 \uad6c\uc870\uac00 \uc788\ub2e4.<\/p>\n\n\n\n
Client -> Load Balancer -> Server A \/ Server B<\/code><\/p>\n\n\n\n
Client\uac00 \ucd5c\ucd08 \uc5f0\uacb0\ud55c \uc11c\ubc84\uc640 \uc774\ud6c4 \uc694\uccad\uc774 \uc804\ub2ec\ub418\ub294 \uc11c\ubc84\uac00 \ub2ec\ub77c\uc9c8 \uc218 \uc788\ub2e4.<\/p>\n\n\n\n
\ud2b9\ud788 HTTP Long-Polling\uc744 \uc0ac\uc6a9\ud558\ub294 \uacbd\uc6b0\uc5d0\ub294 \uc138\uc158 \uace0\uc815\uc774 \ud544\uc694\ud560 \uc218 \uc788\ub2e4.<\/p>\n\n\n\n
\uc774\ub97c Sticky Session\uc774\ub77c\uace0 \ud55c\ub2e4.<\/p>\n\n\n\n
\uac1c\ub150\uc801\uc73c\ub85c\ub294 \ub2e4\uc74c\uacfc \uac19\ub2e4.<\/p>\n\n\n\n
Client A -> Load Balancer -> Server A<\/code><\/p>\n\n\n\n
\uc774\ud6c4\uc5d0\ub3c4<\/p>\n\n\n\n
Client A -> Load Balancer -> Server A<\/code><\/p>\n\n\n\n
\ub97c \uc720\uc9c0\ud55c\ub2e4.<\/p>\n\n\n\n
WebSocket\uc73c\ub85c \uc5c5\uadf8\ub808\uc774\ub4dc\ub41c \uc774\ud6c4\uc5d0\ub294 \uc5f0\uacb0 \uc790\uccb4\uac00 \uc720\uc9c0\ub418\uc9c0\ub9cc, \ucd08\uae30 \uc5f0\uacb0 \uacfc\uc815\uacfc \uc560\ud50c\ub9ac\ucf00\uc774\uc158 \uad6c\uc131\uc5d0 \ub530\ub77c \uc138\uc158 \ubb38\uc81c\ub97c \uace0\ub824\ud574\uc57c \ud55c\ub2e4.<\/p>\n\n\n\n
\ub530\ub77c\uc11c \uc2e4\uc11c\ube44\uc2a4\uc5d0\uc11c\ub294 \ub2e4\uc74c\uc744 \ud568\uaed8 \uc124\uacc4\ud55c\ub2e4.<\/p>\n\n\n\n
Load Balancer -> Sticky Session \/ WebSocket \uc124\uc815 -> Socket.IO Adapter -> Redis<\/code><\/p>\n\n\n\n
\n\n\n\n
Redis\uac00 \ubaa8\ub4e0 \uc0c1\ud0dc \uc800\uc7a5\uc18c\ub294 \uc544\ub2c8\ub2e4<\/h1>\n\n\n\n
Redis\ub97c \uc0ac\uc6a9\ud55c\ub2e4\uace0 \ud574\uc11c \ubaa8\ub4e0 \ub370\uc774\ud130\ub97c Redis\uc5d0 \ub123\ub294 \uac83\uc740 \uc88b\uc740 \uc124\uacc4\uac00 \uc544\ub2c8\ub2e4.<\/p>\n\n\n\n
\uac01 \uc2dc\uc2a4\ud15c\uc758 \uc5ed\ud560\uc744 \ubd84\ub9ac\ud574\uc57c \ud55c\ub2e4.<\/p>\n\n\n\n
\uc601\uad6c \ub370\uc774\ud130 -> Database<\/code><\/p>\n\n\n\n
\uce90\uc2dc -> Redis<\/code><\/p>\n\n\n\n
\uc138\uc158 -> Redis<\/code><\/p>\n\n\n\n
\uc2e4\uc2dc\uac04 \uc774\ubca4\ud2b8 -> Redis Pub\/Sub<\/code><\/p>\n\n\n\n
\ub300\uaddc\ubaa8 \uc774\ubca4\ud2b8 \uc2a4\ud2b8\ub9bc -> Kafka \ub4f1\uc758 Message Broker<\/code><\/p>\n\n\n\n
Redis Pub\/Sub\uc740 \uba54\uc2dc\uc9c0\ub97c \uc2e4\uc2dc\uac04\uc73c\ub85c \uc804\ub2ec\ud558\ub294 \ub370 \uc801\ud569\ud558\uc9c0\ub9cc \uba54\uc2dc\uc9c0\ub97c \uc601\uad6c\uc801\uc73c\ub85c \ubcf4\uad00\ud558\ub294 Queue\uc640\ub294 \uc131\uaca9\uc774 \ub2e4\ub974\ub2e4.<\/p>\n\n\n\n
\ub530\ub77c\uc11c \uba54\uc2dc\uc9c0\uc758 \uc720\uc2e4\uc744 \ud5c8\uc6a9\ud560 \uc218 \uc788\ub294\uac00<\/strong>, \uc7ac\ucc98\ub9ac\uac00 \ud544\uc694\ud55c\uac00<\/strong>, \uc21c\uc11c \ubcf4\uc7a5\uc774 \ud544\uc694\ud55c\uac00<\/strong> \ub4f1\uc5d0 \ub530\ub77c \uc2dc\uc2a4\ud15c\uc744 \uc120\ud0dd\ud574\uc57c \ud55c\ub2e4.<\/p>\n\n\n\n
\n\n\n\n
\uac8c\uc784 \uc11c\ubc84\uc5d0\uc11c\uc758 \uc751\uc6a9<\/h1>\n\n\n\n
\uc774 \uad6c\uc870\ub294 \uac8c\uc784 \uc11c\ubc84\uc5d0\uc11c\ub3c4 \uadf8\ub300\ub85c \uc801\uc6a9\ud560 \uc218 \uc788\ub2e4.<\/p>\n\n\n\n
\uc608\ub97c \ub4e4\uc5b4 \uc5ec\ub7ec \uac8c\uc784 \uc11c\ubc84\uac00 \uc874\uc7ac\ud55c\ub2e4\uace0 \ud558\uc790.<\/p>\n\n\n\n
Game Server 1 \/ Game Server 2 \/ Game Server 3<\/code><\/p>\n\n\n\n
\uac01 \uc11c\ubc84\uac00 \ub3c5\ub9bd\uc801\uc73c\ub85c \ud50c\ub808\uc774\uc5b4\ub97c \uad00\ub9ac\ud55c\ub2e4.<\/p>\n\n\n\n
Player A -> Game Server 1<\/code><\/p>\n\n\n\n
Player B -> Game Server 2<\/code><\/p>\n\n\n\n
A\uc640 B\uac00 \uac19\uc740 \uac8c\uc784 \uc774\ubca4\ud2b8\ub97c \uacf5\uc720\ud574\uc57c \ud55c\ub2e4\uba74 \uc11c\ubc84 \uac04 \uba54\uc2dc\uc9c0 \uc804\ub2ec\uc774 \ud544\uc694\ud558\ub2e4.<\/p>\n\n\n\n
Game Server 1 -> Message Broker -> Game Server 2<\/code><\/p>\n\n\n\n
\uc5ec\uae30\uc11c Redis Pub\/Sub\uc744 \uc0ac\uc6a9\ud560 \uc218\ub3c4 \uc788\uace0, \uac8c\uc784\uc758 \uc694\uad6c\uc0ac\ud56d\uc5d0 \ub530\ub77c \ub2e4\ub978 Message Broker\ub97c \uc0ac\uc6a9\ud560 \uc218\ub3c4 \uc788\ub2e4.<\/p>\n\n\n\n
\uc911\uc694\ud55c \uac83\uc740 \ud2b9\uc815 \uae30\uc220\uc774 \uc544\ub2c8\ub2e4.<\/p>\n\n\n\n
\uc11c\ubc84 \uac04 \ud1b5\uc2e0\uc744 \uc11c\ubc84 \ub0b4\ubd80 \uba54\ubaa8\ub9ac\uc5d0 \uc758\uc874\ud558\uc9c0 \uc54a\ub3c4\ub85d \ub9cc\ub4dc\ub294 \uac83<\/strong>\uc774\ub2e4.<\/p>\n\n\n\n
\n\n\n\n
\ud575\uc2ec \ucf54\ub4dc\ub9cc \ubcf4\uba74<\/h1>\n\n\n\n
\uacb0\uad6d \uc911\uc694\ud55c \ucf54\ub4dc\ub294 \ub9ce\uc9c0 \uc54a\ub2e4.<\/p>\n\n\n\n
Cluster\ub294 Worker\ub97c \ub9cc\ub4e0\ub2e4.<\/p>\n\n\n\n
if (cluster.isPrimary) {\n    for (let i = 0; i < os.cpus().length; i++) {\n        cluster.fork();\n    }\n}\n<\/code><\/pre>\n\n\n\n
Socket.IO\ub294 \uc5f0\uacb0\uc744 \uad00\ub9ac\ud55c\ub2e4.<\/p>\n\n\n\n
io.on('connection', (socket) => {\n    socket.on('chat', (message) => {\n        io.emit('chat', message);\n    });\n});\n<\/code><\/pre>\n\n\n\n
Redis Adapter\ub294 Worker \/ Server \uc0ac\uc774\uc758 Socket.IO \uc774\ubca4\ud2b8 \uc804\ub2ec\uc744 \uc5f0\uacb0\ud55c\ub2e4.<\/p>\n\n\n\n
io.adapter(\n    createAdapter(pubClient, subClient)\n);\n<\/code><\/pre>\n\n\n\n
\uc774 \uc138 \uac1c\ub97c \ud569\uce58\uba74 \uad6c\uc870\uac00 \uc644\uc131\ub41c\ub2e4.<\/p>\n\n\n\n
Cluster -> Multi Process<\/code><\/p>\n\n\n\n
Socket.IO -> Connection Management<\/code><\/p>\n\n\n\n
Redis Adapter -> Cross Process \/ Server Event Propagation<\/code><\/p>\n\n\n\n
\n\n\n\n
\ucd5c\uc885 \uad6c\uc870<\/h1>\n\n\n\n
\uc804\uccb4 \uc2dc\uc2a4\ud15c\uc744 \ud558\ub098\uc758 \ud750\ub984\uc73c\ub85c \ud45c\ud604\ud558\uba74 \ub2e4\uc74c\uacfc \uac19\ub2e4.<\/p>\n\n\n\n
Client -> Load Balancer -> Node.js Worker -> Socket.IO -> Redis Adapter -> Redis -> Other Worker -> Socket.IO -> Client<\/code><\/p>\n\n\n\n
\uc11c\ubc84\uac00 \uc5ec\ub7ec \ub300\ub77c\uba74 \ub2e4\uc74c\uacfc \uac19\uc774 \ud655\uc7a5\ub41c\ub2e4.<\/p>\n\n\n\n
Client -> Load Balancer -> Server A \/ Server B \/ Server C -> Redis -> Server A \/ Server B \/ Server C<\/code><\/p>\n\n\n\n
\uc5ec\uae30\uc11c \uac01\uac01\uc758 \uc5ed\ud560\uc740 \uba85\ud655\ud558\ub2e4.<\/p>\n\n\n\n
Node.js Cluster -> CPU \ucf54\uc5b4 \ud65c\uc6a9<\/code><\/p>\n\n\n\n
Socket.IO -> \uc2e4\uc2dc\uac04 \uc5f0\uacb0 \uad00\ub9ac<\/code><\/p>\n\n\n\n
Redis -> \uc11c\ubc84 \uac04 \uc774\ubca4\ud2b8 \uc804\ub2ec<\/code><\/p>\n\n\n\n
Redis Adapter -> Socket.IO\uc640 Redis \uc5f0\uacb0<\/code><\/p>\n\n\n\n
Load Balancer -> \uc11c\ubc84 \ubd84\uc0b0<\/code><\/p>\n\n\n\n
\n\n\n\n
\ub9c8\ubb34\ub9ac<\/h1>\n\n\n\n
Node.js Cluster\ub97c \uc801\uc6a9\ud558\ub294 \uac83\uc740 \ub2e8\uc21c\ud788 Worker\ub97c \uc5ec\ub7ec \uac1c \ub9cc\ub4dc\ub294 \uc791\uc5c5\uc774\ub2e4.<\/p>\n\n\n\n
\uc9c4\uc9dc \ubb38\uc81c\ub294 \uadf8 \ub2e4\uc74c\uc5d0 \ubc1c\uc0dd\ud55c\ub2e4.<\/p>\n\n\n\n
\ud504\ub85c\uc138\uc2a4\uac00 \ubd84\ub9ac\ub418\uba74 \uba54\ubaa8\ub9ac\ub3c4 \ubd84\ub9ac\ub41c\ub2e4.<\/p>\n\n\n\n
Process A -> Memory A<\/code><\/p>\n\n\n\n
Process B -> Memory B<\/code><\/p>\n\n\n\n
\ub530\ub77c\uc11c Stateful\ud55c Socket \uc5f0\uacb0\uc744 \uc5ec\ub7ec \ud504\ub85c\uc138\uc2a4\uc5d0\uc11c \ucc98\ub9ac\ud558\ub824\uba74 \uacf5\uc720 \uacc4\uce35\uc774 \ud544\uc694\ud558\ub2e4.<\/p>\n\n\n\n
Worker A -> Redis -> Worker B<\/code><\/p>\n\n\n\n
Socket.IO\uc5d0\uc11c\ub294 Redis Adapter\ub97c \uc774\uc6a9\ud574 \uc774 \ubb38\uc81c\ub97c \ud574\uacb0\ud560 \uc218 \uc788\ub2e4.<\/p>\n\n\n\n
Socket.IO A -> Redis Adapter -> Redis -> Redis Adapter -> Socket.IO B<\/code><\/p>\n\n\n\n
\uacb0\uad6d \ud575\uc2ec\uc740 \uba40\ud2f0 \ud504\ub85c\uc138\uc2a4 \ud658\uacbd\uc5d0\uc11c \uc5f0\uacb0 \uc0c1\ud0dc\uc640 \uc774\ubca4\ud2b8 \uc804\ub2ec\uc744 \uc5b4\ub5bb\uac8c \ubd84\ub9ac\ud560 \uac83\uc778\uac00<\/strong>\ub2e4.<\/p>\n\n\n\n
Cluster\ub294 \uc11c\ubc84\ub97c \ub298\ub9b0\ub2e4.<\/p>\n\n\n\n
Socket.IO\ub294 \uc5f0\uacb0\uc744 \uad00\ub9ac\ud55c\ub2e4.<\/p>\n\n\n\n
Redis\ub294 \ud504\ub85c\uc138\uc2a4\uc640 \uc11c\ubc84 \uc0ac\uc774\uc758 \uc774\ubca4\ud2b8\ub97c \uc804\ub2ec\ud55c\ub2e4.<\/p>\n\n\n\n
\uc774 \uc138 \uac00\uc9c0\uc758 \uc5ed\ud560\uc744 \ubd84\ub9ac\ud574\uc11c \uc774\ud574\ud558\uba74 Node.js \uc2e4\uc2dc\uac04 \uc11c\ubc84\uc758 \uc2a4\ucf00\uc77c \uc544\uc6c3 \uad6c\uc870\ub97c \ud6e8\uc52c \uba85\ud655\ud558\uac8c \ubcfc \uc218 \uc788\ub2e4.<\/p>\n","protected":false},"excerpt":{"rendered":"
Node.js \uc11c\ubc84\ub97c \uc5ec\ub7ec \ud504\ub85c\uc138\uc2a4\ub85c \ud655\uc7a5\ud558\uba74 CPU \uc790\uc6d0\uc744 \ub354 \ud65c\uc6a9\ud560 \uc218 \uc788\ub2e4. \ud558\uc9c0\ub9cc \ud504\ub85c\uc138\uc2a4\uac00 \ubd84\ub9ac\ub418\ub294 \uc21c\uac04 \ud558\ub098\uc758 \ubb38\uc81c\uac00 \uc0dd\uae34\ub2e4. \ud504\ub85c\uc138\uc2a4\uc758 \uba54\ubaa8\ub9ac\ub294 \uc11c\ub85c \uacf5\uc720\ub418\uc9c0 \uc54a\ub294\ub2e4. \uc77c\ubc18\uc801\uc778 HTTP \uc11c\ubc84\ub77c\uba74 \uc774 \ubb38\uc81c\ub97c \uc678\ubd80 DB\ub098 \uce90\uc2dc\ub97c \ud1b5\ud574 \uc27d\uac8c \ud574\uacb0\ud560 \uc218 \uc788\uc9c0\ub9cc, Socket.IO\ucc98\ub7fc \uc9c0\uc18d\uc801\uc778 \uc5f0\uacb0\uc744 \uc720\uc9c0\ud558\ub294 \uc2dc\uc2a4\ud15c\uc5d0\uc11c\ub294 \uc774\uc57c\uae30\uac00 \ub2ec\ub77c\uc9c4\ub2e4. Client -> Socket.IO Worker -> Connection State \uc5ec\uae30\uc11c Worker\uac00 \uc5ec\ub7ec \uac1c\uac00 \ub418\uba74 […]<\/p>\n","protected":false},"author":1,"featured_media":0,"comment_status":"closed","ping_status":"closed","sticky":false,"template":"","format":"standard","meta":{"footnotes":""},"categories":[49],"tags":[],"class_list":["post-2098","post","type-post","status-publish","format-standard","hentry","category-server"],"_links":{"self":[{"href":"https:\/\/wayhope.kro.kr\/index.php?rest_route=\/wp\/v2\/posts\/2098","targetHints":{"allow":["GET"]}}],"collection":[{"href":"https:\/\/wayhope.kro.kr\/index.php?rest_route=\/wp\/v2\/posts"}],"about":[{"href":"https:\/\/wayhope.kro.kr\/index.php?rest_route=\/wp\/v2\/types\/post"}],"author":[{"embeddable":true,"href":"https:\/\/wayhope.kro.kr\/index.php?rest_route=\/wp\/v2\/users\/1"}],"replies":[{"embeddable":true,"href":"https:\/\/wayhope.kro.kr\/index.php?rest_route=%2Fwp%2Fv2%2Fcomments&post=2098"}],"version-history":[{"count":1,"href":"https:\/\/wayhope.kro.kr\/index.php?rest_route=\/wp\/v2\/posts\/2098\/revisions"}],"predecessor-version":[{"id":2099,"href":"https:\/\/wayhope.kro.kr\/index.php?rest_route=\/wp\/v2\/posts\/2098\/revisions\/2099"}],"wp:attachment":[{"href":"https:\/\/wayhope.kro.kr\/index.php?rest_route=%2Fwp%2Fv2%2Fmedia&parent=2098"}],"wp:term":[{"taxonomy":"category","embeddable":true,"href":"https:\/\/wayhope.kro.kr\/index.php?rest_route=%2Fwp%2Fv2%2Fcategories&post=2098"},{"taxonomy":"post_tag","embeddable":true,"href":"https:\/\/wayhope.kro.kr\/index.php?rest_route=%2Fwp%2Fv2%2Ftags&post=2098"}],"curies":[{"name":"wp","href":"https:\/\/api.w.org\/{rel}","templated":true}]}}