Skip to content

Instantly share code, notes, and snippets.

@Miserlou
Created January 12, 2012 04:14
Embed
What would you like to do?
proxy.js
/*
node-http-proxy
with websockets from socketio
*/
var util = require('util'),
colors = require('colors'),
websocket = require('../../vendor/websocket'),
httpProxy = require('../../lib/node-http-proxy');
try {
var utils = require('socket.io/lib/socket.io/utils'),
io = require('socket.io');
}
catch (ex) {
console.error('Socket.io is required for this example:');
console.error('npm ' + 'install'.green + ' socket.io@0.6.18'.magenta);
process.exit(1);
}
//
// Your routes and certificates [untested]
//
var options = {
//https: {
// key: fs.readFileSync('path/to/your/key.pem', 'utf8'),
// cert: fs.readFileSync('path/to/your/cert.pem', 'utf8')
//},
hostnameOnly: true,
router: {
'node.YOURDOMAIN.com': '127.0.0.1:8001',
'apache.YOURDOMAIN.com': '127.0.0.1:9000'
}
}
var preProxyServer = httpProxy.createServer(options);
preProxyServer.listen(8000);
//
// Setup our server to proxy standard HTTP requests
//
var proxy = new httpProxy.HttpProxy({
target: {
host: 'localhost',
port: 8080
}
});
var proxyServer = http.createServer(function (req, res) {
proxy.proxyRequest(req, res);
});
//
// Listen to the `upgrade` event and proxy the
// WebSocket requests as well.
//
proxyServer.on('upgrade', function (req, socket, head) {
var buffer = httpProxy.buffer(socket);
setTimeout(function () {
proxy.proxyWebSocketRequest(req, socket, head, buffer);
}, 1000);
});
proxyServer.listen(8001);
//
// Setup the web socket against our proxy
//
var ws = new websocket.WebSocket('ws://localhost:8080/socket.io/websocket/', 'borf'); //why borf?
ws.on('open', function () {
ws.send(utils.encode('from client'));
});
ws.on('message', function (msg) {
util.debug('Got message: ' + utils.decode(msg));
});
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment