opens.kr

[node.js] socket.io 룸 처리 방법 샘플코드

1. Server 예시

var io = require('socket.io').listen(8001);
io.sockets.on('connection', function (socket){
var room_id;
socket.on('joinRoom',function(data){
room_id = data;
socket.join(room_id); //룸입장
console.log('JOIN ROOM LIST', io.sockets.adapter.rooms);
});
socket.on('leaveRoom',function(){
socket.leave(room_id);//룸퇴장
console.log('OUT ROOM LIST', io.sockets.adapter.rooms);
});
socket.on('sendMsg',function(data){
io.sockets.in(room_id).emit('msgAlert',data);//자신포함 전체 룸안의 유저
//socket.broadcast.to(room_id).emit('msgAlert',data); //자신 제외 룸안의 유저
//socket.in(room_id).emit('msgAlert',data); //broadcast 동일하게 가능 자신 제외 룸안의 유저
//io.of('namespace').in(room_id).emit('msgAlert', data) //of 지정된 name space의 유저의 룸
});
socket.on('disconnect', function(){
console.log('NOT USER DISCONNECT : ', socket.id);
console.log('ROOM LIST', io.sockets.adapter.rooms);
});
/*
* 룸리스트 콘솔로그
* socket.io 1.x 에서 io.sockets.manager.rooms => io.sockets.adapter.rooms
* ROOM LIST { qNADgg3CCxESDLm5AAAA: [ qNADgg3CCxESDLm5AAAA: true ],
test_room:
[ qNADgg3CCxESDLm5AAAA: true,
'0rCX3v4pufWvQ6uwAAAB': true,
'iH0wJHGh-qKPRd2RAAAC': true ],
'0rCX3v4pufWvQ6uwAAAB': [ '0rCX3v4pufWvQ6uwAAAB': true ],
'iH0wJHGh-qKPRd2RAAAC': [ 'iH0wJHGh-qKPRd2RAAAC': true ] }
*/
});

2. Client

<!DOCTYPE html PUBLIC "-//W3C//DTD HTML 4.01 Transitional//EN" "http://www.w3.org/TR/html4/loose.dtd">
<html>
<head>
<meta http-equiv="Content-Type" content="text/html; charset=UTF-8">
<title>Insert title here</title>
<script src="/js/jquery-1.11.1.min.js"></script>
<script src="/js/socket.io.js"></script>
</head>
<body>
</body>
<script type="text/javascript">
$(function(){
var socket = io.connect('http://127.0.0.1:8001', {'forceNew':true,reconnection:false});
socket.on('connect', function () {
socket.emit('joinRoom','test_room');
socket.on('msgAlert',function(data){
alert(data);
});
});
$('#leaveRoomBut').click(function(){
socket.emit('leaveRoom');
});
$('#msgSendBut').click(function(){
socket.emit('sendMsg','TEST_MSG');
});
});
</script>
<input id="leaveRoomBut" type="button" value="leaveRoom">
<input id="msgSendBut" type="button" value="msgSend">
</html>

저작자표시 비영리 변경금지

Posted by 시니^^

[node.js] 성능 개선을 위한 클러스터(cluster) 이용

node.js는 싱글프로세스다 보니까 한개 데몬당 하나의 CPU 코어만 이용한다.

이걸 보완하고 위해서 클러스터를 이용한다.

자세한 api 설명은 아래 내용을 참고 하면 된다.

http://nodejs.org/api/cluster.html

1. 기본 샘플 사용 방법

var cluster = require('cluster');
var http = require('http');
var numCPUs = require('os').cpus().length;
if (cluster.isMaster) {
//cpu갯수만큼 프로세스 실행
for (var i = 0; i < numCPUs; i++) {
cluster.fork();
}
cluster.on('exit', function(worker, code, signal) {
console.log('worker ' + worker.process.pid + ' died');
//서버가 죽었을시 프로세스 자동 추가 실행 또는 알아서 알람sms나 이메일등 모니터링 알람 처리
cluster.fork();
});
} else {
// Workers can share any TCP connection
// In this case its a HTTP server
http.createServer(function(req, res) {
res.writeHead(200);
res.end("hello world\n");
}).listen(8001);
console.log('PID ['+process.pid+'] HTTP SERVER');
}

2. 프로세스 정보

$ node cluster.js PID [1571] HTTP SERVER PID [1573] HTTP SERVER PID [1574] HTTP SERVER PID [1575] HTTP SERVER $ ps aux | grep node root 1569 node cluster.js ### 클러스터 마스터node ###### root 1571 /data/nodejs/bin/node /data/nodejs/www/cluster.js root 1573 /data/nodejs/bin/node /data/nodejs/www/cluster.js root 1574 /data/nodejs/bin/node /data/nodejs/www/cluster.js root 1575 /data/nodejs/bin/node /data/nodejs/www/cluster.js

3. Kill 시 자동으로 프로세스 추가 실행됨

$ kill 1571
worker 1571 died
PID [1617] HTTP SERVER

$ ps aux | grep node
root      1569   node cluster.js
root      1573   /data/nodejs/bin/node /data/nodejs/www/cluster.js
root      1574   /data/nodejs/bin/node /data/nodejs/www/cluster.js
root      1575   /data/nodejs/bin/node /data/nodejs/www/cluster.js
root      1617   /data/nodejs/bin/node /data/nodejs/www/cluster.js

4. 추가적인 참고자료

Node JS 멀티코어 CPU 지원하기 - http://eclipse.or.kr/wiki/특집기사:Node_JS_멀티코어_CPU_지원하기

Cluster모듈에서 Socket.IO 사용하기 - http://blog.outsider.ne.kr/764