'node.js' 태그의 글 목록 (2 Page)

'node.js'에 해당되는 글 18건

2014.09.24 [node.js] socket.io 룸 처리 방법 샘플코드
2014.09.20 [node.js] 성능 개선을 위한 클러스터(cluster) 이용
2014.09.18 [nodejs] POST 데이터 받기 express 사용 / 미사용 비교
2014.09.18 [PHP] socket.io PHP 클라이언트(client)
2014.09.15 [node.js] 리눅스 centos 소스설치
2014.09.15 [node.js] 채팅프로그램 간단한 샘플만들기
2014.09.13 [node.js] express.js 샘플
2014.09.12 [node.js] Global Objects Variables 정보

[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

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

Posted by 시니^^

[nodejs] POST 데이터 받기 express 사용 / 미사용 비교

1. http/ querystring만 사용

var http = require('http')
,qs = require('querystring');
http.createServer(function (req, res) {
if( req.url == '/' && req.method == 'POST'){
var postBody = '';
req.on('data', function (data) {
postBody += data;
});
req.on('end', function () {
var post = qs.parse(postBody);
//post데이터확인
console.log(post['postname']);
});
res.end('true');
}else{
res.writeHead(404, {'Content-Type': 'text/plain'});
res.end('404 ERROR');
}
}).listen(8001);

2. http / express / body-parser 사용

var express = require('express')
,http = require('http')
,bodyParser = require('body-parser');
var app = express();
app.use(bodyParser.urlencoded({extended: true}));
//app.use(bodyParser.json());
app.post("/", function( req, res){
res.writeHead(200,{"Content-Type" : "text/plain"});
//post데이터확인
console.log(req.param('postname',null));
res.end('test');
});
app.use(function( req, res){
res.writeHead(404,{"Content-Type" : "text/plain"});
res.end('404 ERROR');
});
http.createServer(app).listen(8001);

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

Posted by 시니^^

[PHP] socket.io PHP 클라이언트(client)

elephant.io - https://github.com/Wisembly/elephant.io

1. elephantio.php - elephant.io 다운로드 src폴더 데이터에 대한 include 또는 require 파일 만들기

<?php
$___ELEPHANTIO_DIR = dirname(__FILE__);
require $___ELEPHANTIO_DIR.'/Client.php';
require $___ELEPHANTIO_DIR.'/AbstractPayload.php';
require $___ELEPHANTIO_DIR.'/EngineInterface.php';
require $___ELEPHANTIO_DIR.'/Engine/AbstractSocketIO.php';
require $___ELEPHANTIO_DIR.'/Engine/SocketIO/Session.php';
require $___ELEPHANTIO_DIR.'/Engine/SocketIO/Version1X.php';
require $___ELEPHANTIO_DIR.'/Exception/MalformedUrlException.php';
require $___ELEPHANTIO_DIR.'/Exception/ServerConnectionFailureException.php';
require $___ELEPHANTIO_DIR.'/Exception/SocketException.php';
require $___ELEPHANTIO_DIR.'/Exception/UnsupportedActionException.php';
require $___ELEPHANTIO_DIR.'/Exception/UnsupportedTransportException.php';
require $___ELEPHANTIO_DIR.'/Payload/Decoder.php';
require $___ELEPHANTIO_DIR.'/Payload/Encoder.php';
?>

2. client.php

<?php
include 'lib/elephantio/elephantio.php';
/*
* Version1X arg2 Option : ['context'=>[], 'debug'=>false,'wait'=>100*1000,'timeout'=>ini_get("default_socket_timeout")];
*/
$EIO = new ElephantIO\Client(
new ElephantIO\Engine\SocketIO\Version1X('http://127.0.0.1:8001',['timeout'=>5])
);
$EIO->initialize();
$EIO->emit('msgIn', array('data1','data2') );
$EIO->close();
?>

3. nodejs server

var io = require('socket.io').listen(8001);
io.sockets.on('connection', function (socket){
socket.on('msgIn',function(msg){
console.log('Msg In : ',msg);
});
socket.on('disconnect', function(){
console.log('NOT USER DISCONNECT : ', socket.id);
});
});
/*
* debug
* Msg In : [ 'data1', 'data2' ]
* NOT USER DISCONNECT : NPmXDQpuVM9OFYl0AAAA
*/

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

Posted by 시니^^

[node.js] 리눅스 centos 소스설치

$ yum install gcc gcc-c++
$ yum install openssl-devel make

$ wget http://nodejs.org/dist/v0.10.31/node-v0.10.31.tar.gz
※ http://nodejs.org/download/ 최신버젼받기

$ tar xvfz node-v0.10.31.tar.gz
$ cd node-v0.10.31

$ ./configure --prefix=/data/nodejs
{ 'target_defaults': { 'cflags': [],
                       'default_configuration': 'Release',
                       'defines': [],
                       'include_dirs': [],
                       'libraries': []},
  'variables': { 'clang': 0,
                 'gcc_version': 44,
                 'host_arch': 'x64',
                 'node_install_npm': 'true',
                 'node_prefix': '/data/nodejs',
                 'node_shared_cares': 'false',
                 'node_shared_http_parser': 'false',
                 'node_shared_libuv': 'false',
                 'node_shared_openssl': 'false',
                 'node_shared_v8': 'false',
                 'node_shared_zlib': 'false',
                 'node_tag': '',
                 'node_unsafe_optimizations': 0,
                 'node_use_dtrace': 'false',
                 'node_use_etw': 'false',
                 'node_use_openssl': 'true',
                 'node_use_perfctr': 'false',
                 'node_use_systemtap': 'false',
                 'python': '/usr/bin/python',
                 'target_arch': 'x64',
                 'v8_enable_gdbjit': 0,
                 'v8_no_strict_aliasing': 1,
                 'v8_use_snapshot': 'true',
                 'want_separate_host_toolset': 0}}
creating  ./config.gypi
creating  ./config.mk

$ make && make install

##### bin Path는 계정 및 shell환경에 맞게 profile 에 등록하기##
$ vi /root/.bash_profile
PATH=$PATH:$HOME/bin
PATH=$PATH:/data/nodejs/bin ##nodjs bin등록
export PATH
source /root/.bash_profile
##############################################################

$ /data/nodejs/bin/node -v
v0.10.31


## npm 이용한 forever 데몬프로그램 설치########################
$ /data/nodejs/bin/npm install -g forever 

## npm 이용한 socket.io 설치###################################
$ /data/nodejs/bin/npm install -g socket.io

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

Posted by 시니^^

[node.js] 채팅프로그램 간단한 샘플만들기

Node.js 책 잠시 보고 만든 샘플입니다.

그냥 참고용으로!!ㅎㅎ

1. Server Side Node.js Socket.io

var io = require('socket.io').listen(80);
var clients = {};
io.sockets.on('connection', function (socket){
//입장 및 닉네임체크
socket.on('create_nickname',function(nickname,returnFunction){
//닉네임중복체크
var returnCode = 1;
for ( var i in clients ){
if ( clients[i] == nickname ){
returnCode = -1;
break;
}
}
//닉네임체크확인 결과 전달
returnFunction(returnCode);
//닉네임체크 유효화됨
if ( returnCode == 1 ) {
//클라이언트 닉네임등록
clients[socket.id] = nickname;
//새접속자로인한 전체 유저리스트 전달함
io.sockets.emit('user_list',clients);
//전체유저 메세지전송
io.sockets.emit('msgPush',{"nickname":"시스템","msg":clients[socket.id]+" 유저가 입장하셨습니다."});
console.log('CONNECT : ',nickname+' ['+socket.id+'] '+'('+Object.keys(clients).length+'명)');
}
});
socket.on('msgSend',function(data){
//자신을 제외한 전체유저에게 메세지전송
socket.broadcast.emit('msgPush',data);
/*
*socket.emit('msgPush',data);//자신에게만 보낼때
*socket.broadcast.emit('msgPush',data);//자신제외 전체유저
*io.sockets.emit('msgPush',data);//자신포함 전체유저에게
*io.sockets.in(socket_id).emit('msgPush',data);//특정유저에게 귓속말시 socket_id추가입력하면됨
*io.of('namespace').emit('msgPush', data); //of 지정된 name space의 유저
*/
console.log('Chat Msg : ','['+data['nickname']+'] '+data['msg']);
});
//접속종료시처리
socket.on('disconnect', function(){
if ( clients[socket.id] ){
//유저이탈 메세지전달
io.sockets.emit('msgPush',{"nickname":"시스템","msg":clients[socket.id]+" 유저가 나가셨습니다."});
console.log('DISCONNECT : ', clients[socket.id]);
//이탈유저닉네임삭제
delete clients[socket.id];
//유저이탈 전체유저리스트 갱신
io.sockets.emit('user_list',clients);
}else{
console.log('NOT USER DISCONNECT : ', socket.id);
}
});
});

2. Client

<!DOCTYPE html>
<html>
<head>
<meta charset="UTF-8">
<title>Chat</title>
</head>
<body>
<div id="chatJoin">
<form id="chatJoinForm">
대화명 : <input id="nickname" name="nickname" type="text"> <input type="submit" value="입장">
</form>
</div>
<div id="chatRoom" style="display:none;">
<div id="msgList" style="float:left;width:500px;height:300px;border:1px solid #1D365D;overflow:auto;"></div>
<div style="float:left;width:100px;height:300px;border:1px solid #1D365D;margin-left:3px;">
<div style="border-bottom:1px solid #1D365D;">접속자</div>
<div id="userList"></div>
</div>
<div style="clear:both;">
<form id="chatMsgForm">ChatMsg : <input id="msgText" name="msg" type="text"> <input type="submit" value="전송"></form>
</div>
</div>
</body>
<script type="text/javascript" src="jquery-1.11.1.min.js"></script>
<script type="text/javascript" src="socket.io.js"></script>
<script type="text/javascript">
$(function(){
var socket;
function createNickname(nickName){
socket.emit('create_nickname',nickName,function(returnCode){
if ( returnCode == 1 ){
//정상적인 닉네임
$('#chatJoin').hide();
$('#chatRoom').show();
$('#msgText').focus();
}else{ //아니면 닉네임중복됨
alert('존재하는 닉네임입니다.');
$('#nickname').focus();
socket.disconnect();
}
});
}
function msgAdd(data){
var sHtml = '<div><span style="color:blue;">'+data['nickname']+'</span> : '+data['msg']+'</div>';
$('#msgList').append(sHtml);
$("#msgList").scrollTop($("#msgList")[0].scrollHeight);
}
$('#chatMsgForm').submit(function(event){
event.preventDefault();
var data = {"nickname":$('#nickname').val(),"msg":$('#msgText').val()}
msgAdd(data);
$('#msgText').val('');
$('#msgText').focus();
//서버에 입력메세지전달
socket.emit('msgSend', data);
});
$('#chatJoinForm').submit(function(event){
event.preventDefault();
if ( !$('#nickname').val() ){
alert("닉네임을 입력해주세요");
$('#nickname').focus();
return false;
}
/*
*https://github.com/automattic/socket.io-client
*/
socket = io.connect('http://127.0.0.1', {'forceNew':true,reconnection:false});
socket.on('connect', function () {
createNickname($('#nickname').val());
});
socket.on('user_list',function(clients){
//심플테스트 버젼이라서 삭제하고 새로 갱신하는방안
$('#userList').html('');
for ( var i in clients ){
if ( clients[i] == $('#nickname').val() ){
sHtml = '<div style="font-weight:bold;">'+clients[i]+'</div>';
}else{
sHtml = '<div>'+clients[i]+'</div>';
}
$('#userList').append(sHtml);
}
});
socket.on('msgPush',function(data){
msgAdd(data);
});
socket.on('disconnect', function(){
$('#msgList').html('');
$('#nickname').val('');
$('#chatJoin').show();
$('#chatRoom').hide();
alert('Server Disconnect');
});
socket.on('connect_error', function (data) {
alert('CONNECT_ERROR : '+data);
});
});
});
</script>
</html>

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

Posted by 시니^^

[node.js] express.js 샘플

메뉴얼 사이트

- Application : http://expressjs.com/api.html#express

- Request : http://expressjs.com/api.html#req.params

- Response : http://expressjs.com/api.html#res.status

- Router : http://expressjs.com/api.html#router

- Middleware : http://expressjs.com/api.html#middleware.api

테스트 샘플자료 (자세한 내용은 위에 API 참조하면 방대함 정규식처리등 많음)

var express = require('express'), http = require('http');
var bodyParser = require('body-parser');
var app = express();
app.use(bodyParser());
app.all('*', function( req, res, next){
res.writeHead(200,{
"Content-Type" : "text/plain"
});
next();
});
app.get("/", function( req, res){
res.end("HOME DIR : /");
});
app.get("/test", function( req, res){
res.end("HOME DIR : /test");
});
app.get("/params/:user", function( req, res){
var sText = " Params : "+req.params.user; // OR req.param('user')
sText += "\n GET : "+req.query.q; //search?q=test OR req.param('q')
sText += "\n POST : "+req.param('name'); //POST name=tobi
//sText += "Cookie : "+req.cookies.name; // Cookie: name=tj
sText += "\n ip : "+req.ip; // req.ips When "trust proxy" is `true`, parse the "X-Forwarded-For"
res.end(sText);
});
app.get("*", function( req, res){
res.end("NOT PAGE");
});
http.createServer(app).listen(80, '127.0.0.1');
console.log('HTTP URL : http://127.0.0.1:80/');

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

Posted by 시니^^

[node.js] Global Objects Variables 정보

자세한 내용은 메뉴얼 참조 : http://nodejs.org/api/globals.html#globals_global

Global Objects

- global

- process

- console

- Class: Buffer

- require()

- require.resolve()

- require.cache

- require.extensions

- __filename

- __dirname

- module

- exports

- setTimeout(cb, ms)

- clearTimeout(t)

- setInterval(cb, ms)

- clearInterval(t)

변수류

__filename : 실행중인 경로포함 파일이름

__dirname : 실행중인 파일 경로까지만

실행한 Process 정보

- http://nodejs.org/api/process.html#process_process_versions

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

Posted by 시니^^

opens.kr

'node.js'에 해당되는 글 18건

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

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

[nodejs] POST 데이터 받기 express 사용 / 미사용 비교

[PHP] socket.io PHP 클라이언트(client)

[node.js] 리눅스 centos 소스설치

[node.js] 채팅프로그램 간단한 샘플만들기

[node.js] express.js 샘플

[node.js] Global Objects Variables 정보

카테고리

공지사항

태그목록

최근에 올라온 글

최근에 달린 댓글

최근에 받은 트랙백

글 보관함

달력

링크

티스토리툴바