간단하게 테스트할려고. socket.io를 설치 없이 node.js 단에서 한 테스트..
// Github: http://github.com/ncr/node.ws.js
// Compatible with node v0.1.91
// Author: Jacek Becela
// Contributors:
// Michael Stillwell http://github.com/ithinkihaveacat
// Nick Chapman http://github.com/nchapman
// Dmitriy Shalashov http://github.com/skaurus
// Johan Dahlberg
// Andreas Kompanez
// Samuel Cyprian http://github.com/samcyp
// License: MIT
// Based on: http://github.com/Guille/node.websocket.js
function nano(template, data) {
return template.replace(/\{([\w\.]*)}/g, function (str, key) {
var keys = key.split("."), value = data[keys.shift()];
keys.forEach(function (key) { value = value[key];});
return value;
});
}
function pack(num) {
var result = '';
result += String.fromCharCode(num >> 24 & 0xFF);
result += String.fromCharCode(num >> 16 & 0xFF);
result += String.fromCharCode(num >> 8 & 0xFF);
result += String.fromCharCode(num & 0xFF);
return result;
}
var sys = require("sys"),
net = require("net"),
crypto = require("crypto"),
requiredHeaders = {
'get': /^GET (\/[^\s]*)/,
'upgrade': /^websocket$/,
'connection': /^Upgrade$/,
'host': /^(.+)$/,
'origin': /^(.+)$/
},
handshakeTemplate75 = [
'HTTP/1.1 101 Web Socket Protocol Handshake',
'Upgrade: websocket',
'Connection: Upgrade',
'WebSocket-Origin: {origin}',
'WebSocket-Location: {protocol}://{host}{resource}',
'',
''
].join("\r\n"),
handshakeTemplate76 = [
'HTTP/1.1 101 WebSocket Protocol Handshake', // note a diff here
'Upgrade: websocket',
'Connection: Upgrade',
'Sec-WebSocket-Origin: {origin}',
'Sec-WebSocket-Location: {protocol}://{host}{resource}',
'',
'{data}'
].join("\r\n"),
flashPolicy = '<cross-domain-policy><allow-access-from domain="*" to-ports="*" /></cross-domain-policy>';
exports.createSecureServer = function (websocketListener, credentials, options) {
if (!options) options = {};
options.secure = credentials;
return this.createServer(websocketListener, options);
};
exports.createServer = function (websocketListener, options) {
if (!options) options = {};
if (!options.flashPolicy) options.flashPolicy = flashPolicy;
// The value should be a crypto credentials
if (!options.secure) options.secure = null;
return net.createServer(function (socket) {
//Secure WebSockets
var wsProtocol = 'ws';
if(options.secure) {
wsProtocol = 'wss';
socket.setSecure(options.secure);
}
console.info("1");
socket.setTimeout(0);
socket.setNoDelay(true);
socket.setKeepAlive(true, 0);
console.info("2");
var emitter = new process.EventEmitter(),
handshaked = false,
buffer = "";
console.info("3");
function handle(data) {
buffer += data;
console.info("4");
var chunks = buffer.split("\ufffd"),
count = chunks.length - 1; // last is "" or a partial packet
console.info("5");
for(var i = 0; i < count; i++) {
var chunk = chunks[i];
if(chunk[0] == "\u0000") {
console.info("6");
emitter.emit("data", chunk.slice(1));
} else {
console.info("7");
socket.end();
return;
}
}
buffer = chunks[count];
console.info("6");
}
function handshake(data) {
console.info("handshake");
var _headers = data.split("\r\n");
if ( /<policy-file-request.*>/.exec(_headers[0]) ) {
socket.write( options.flashPolicy );
socket.end();
console.info("handshake-1");
return;
}
// go to more convenient hash form
var headers = {}, upgradeHead, len = _headers.length;
if ( _headers[0].match(/^GET /) ) {
headers["get"] = _headers[0];
} else {
console.info("handshake-2");
socket.end();
return;
}
console.info("handshake-3");
if ( _headers[ _headers.length - 1 ] ) {
upgradeHead = _headers[ _headers.length - 1 ];
len--;
}
while (--len) { // _headers[0] will be skipped
var header = _headers[len];
if (!header) continue;
var split = header.split(": ", 2); // second parameter actually seems to not work in node
headers[ split[0].toLowerCase() ] = split[1];
}
console.info("handshake-4");
// check if we have all needed headers and fetch data from them
var data = {}, match;
for (var header in requiredHeaders) {
// regexp actual header value
// modified
console.info("handshake-5 header param - [" + header + "] : " + headers[header] );
if ( match = requiredHeaders[ header ].exec( headers[header] ) ) {
data[header] = match;
} else {
console.info("handshake-5 end.. requiredHeader");
socket.end();
return;
}
}
console.info("handshake-6");
// draft auto-sensing
if ( headers["sec-websocket-key1"] && headers["sec-websocket-key2"] && upgradeHead ) { // 76
console.info("handshake-7");
var strkey1 = headers["sec-websocket-key1"]
, strkey2 = headers["sec-websocket-key2"]
, numkey1 = parseInt(strkey1.replace(/[^\d]/g, ""), 10)
, numkey2 = parseInt(strkey2.replace(/[^\d]/g, ""), 10)
, spaces1 = strkey1.replace(/[^\ ]/g, "").length
, spaces2 = strkey2.replace(/[^\ ]/g, "").length;
if (spaces1 == 0 || spaces2 == 0 || numkey1 % spaces1 != 0 || numkey2 % spaces2 != 0) {
console.info("handshake-7 end");
socket.end();
return;
}
var hash = crypto.createHash("md5")
, key1 = pack(parseInt(numkey1/spaces1))
, key2 = pack(parseInt(numkey2/spaces2));
hash.update(key1);
hash.update(key2);
hash.update(upgradeHead);
socket.write(nano(handshakeTemplate76, {
protocol: wsProtocol,
// modified
resource: data.get[1],
host: data.host[1],
origin: data.origin[1],
data: hash.digest("binary")
}), "binary");
} else { // 75
console.info("handshake-8");
socket.write(nano(handshakeTemplate75, {
protocol: wsProtocol,
//modified
resource: data.get[1],
host: data.host[1],
origin: data.origin[1]
}));
}
handshaked = true;
emitter.emit("connect", data.get[1]);
console.info("handshake-9");
}
socket.addListener("data", function (data) {
if(handshaked) {
handle(data.toString("utf8"));
} else {
handshake(data.toString("binary")); // because of draft76 handshakes
}
}).addListener("end", function () {
console.info("handshake-9 end..");
socket.end();
}).addListener("close", function () {
if (handshaked) { // don't emit close from policy-requests
emitter.emit("close");
}
}).addListener("error", function (exception) {
if (emitter.listeners("error").length > 0) {
emitter.emit("error", exception);
} else {
console.info("exception");
throw exception;
}
});
console.info("9");
emitter.remoteAddress = socket.remoteAddress;
emitter.write = function (data) {
try {
socket.write('\u00', 'binary');
socket.write(data, 'utf8');
socket.write('\uff', 'binary');
} catch(e) {
console.info("socket error -9");
// Socket not open for writing,
// should get "close" event just before.
socket.end();
}
};
console.info("10");
emitter.end = function () {
console.info("emitter.end");
socket.end();
};
websocketListener(emitter); // emits: "connect", "data", "close", provides: write(data), end()
});
};
클라이언트 (브라주져. ws.html) 코드
내가 가지고 있는 크롬 웹 브라우져에서는 connection을 맺자마자 바로 fin 패킷을 보내면서 connection을 종료한다. 어딘가 약간 잘못된 것 같기는 하지만, 데모용으로만 쓸 거라서, 문제 원인을 자세히 파악하는 것은 패쓰.. 맛만 봤다는 점에서 통과해야겠음.
cpu는 최대한 활용하고 있다. 엔진의 이슈일까??
#3. 코드 관리
자바스크립트 특성상, 코드 관리를 잘 해야 한다. BO가 들어가는 순간부터 복잡해질 것 같다. ...
