nodejs实用示例 缩址还原

　　var net = require('net'),

　　http = require('http'),

　　url = require('url'),

　　fs = require('fs');

　　var DEFAULT_PORTS = {

　　'http:': 80,

　　'https:': 443

　　};

　　var INDEX_TPL = fs.readFileSync('index.html');

　　function _write(str, res, content_type) {

　　if(res.jsonp_cb) {

　　str = res.jsonp_cb + '("' + str + '")';

　　}

　　res.writeHead(200, {

　　'Content-Length': str.length,

　　'Content-Type': content_type || 'text/plain'

　　});

　　res.end(str);

　　};

　　function expand(short_url, res) {

　　var info = url.parse(short_url);

　　// console.log('info: ' + JSON.stringify(info));

　　if(info.protocol != 'http:') { // 无法请求https的url?

　　_write(short_url, res);

　　return;

　　}

　　var client = http.createClient(info.port || DEFAULT_PORTS[info.protocol], info.hostname);

　　var path = info.pathname || '/';

　　if(info.search) {

　　path += info.search;

　　}

　　var headers = {

　　host: info.hostname,

　　'User-Agent': 'NodejsSpider/1.0'

　　};

　　var request = client.request('GET', path, headers);

　　request.end();

　　request.on('response', function (response) {

　　if(response.statusCode == 302 || response.statusCode == 301) {

　　expand(response.headers.location, res);

　　} else {

　　_write(short_url, res);

　　}

　　});

　　};

　　//expand('http://sinaurl.cn/hbMUII');

　　// http服务

　　http.createServer(function(req, res){

　　if(req.url.indexOf('/api?') == 0) {

　　var params = url.parse(req.url, true);

　　if(params.query && params.query.u) {

　　if(params.query.cb) { // 支持jsonp跨域请求

　　res.jsonp_cb = params.query.cb;

　　}

　　expand(params.query.u, res);

　　} else {

　　_write('', res);

　　}

　　} else {

　　_write(INDEX_TPL, res, 'text/html');

　　}

　　}).listen(1235);

　　process.on('uncaughtException', function (err) {

　　console.log('Caught exception: ' + err);

　　});