正在加载
请稍等

菜单

红楼飞雪 梦

15526773247

文章

Home nodejs 用node.js实现简单的web服务器
Home nodejs 用node.js实现简单的web服务器

用node.js实现简单的web服务器

nodejs, web服务器端开发 by

http模块已提供了基本功能,所以我主要解决两个问题,1是静态资源的处理,2是动态资源的路由。

静态资源在node.js里的意思是不变的,如图片、前端js、css、html页面等。

动态资源我们一般指aspx页面,ashx页面,asp页面,jsp页面,php页面等,而node.js里其实没动态资源这一说,它对请求的处理都是由回调方法完成的,在我实现的httserver里,借鉴了ashx的写法,把处理请求的js文件看作动态资源。

首先实现一个处理静态资源的函数,其实就是对本地文件的读取操作,这个方法已满足了上面说的静态资源的处理。

//处理静态资源
function staticResHandler(localPath, ext, response) {
    fs.readFile(localPath, "binary", function (error, file) {
        if (error) {
            response.writeHead(500, { "Content-Type": "text/plain" });
            response.end("Server Error:" + error);
        } else {
            response.writeHead(200, { "Content-Type": getContentTypeByExt(ext) });
            response.end(file, "binary");
        }
    });
}

而动态资源肯定不能一个方法搞定,就像你的网站 有register.aspx、 login.aspx等等,都需要你自己来写,在我的httpserver里,每个处理请求的js模块都导出 processRequest(request,response)即可,比如实现一个register.js(只输出字符串register)

exports.processRequest = function (request, response) {
    response.writeHead(200, { 'Content-Type': 'text/plain' });
    resp.end("register");
}

现在当请求到来时,我们要做的就是决定怎么处理,即路由。

因为静态资源url指定静态资源大家都很习惯了,所以这里不变,比如

访问http://localhost/img/logo.png  就是访问 web根目录\img\logo.png;

访问http://localhost/js/what.js 就是访问 web根目录\js\what.js;

而动态资源也是一般的js文件,即服务器端js,就比如我实现的这个httpserver.js和上面说的register.js都是不应该让用户访问的,所以路由的时候要判断,就是一些if、else,简单而强大是我的最爱,这里只看最后的的判断,

  1. fs.exists(localPath, function (exists) {
  2. if (exists) {
  3. if (staticRes) {
  4. staticResHandler(localPath, ext, response); //静态资源
  5. } else {
  6. try {
  7. <strong><span style="color: #008000;">var handler = require(localPath);</span></strong>
  8. if (handler.processRequest && typeof handler.processRequest === 'function') {
  9. <span style="color: #008000;"><strong>handler.processRequest(request, response);</strong></span> //动态资源
  10. } else {
  11. response.writeHead(404, { 'Content-Type': 'text/plain' });
  12. response.end('404:Handle Not found');
  13. }
  14. } catch (exception) {
  15. console.log('error::url:' + request.url + 'msg:' + exception);
  16. response.writeHead(500, { "Content-Type": "text/plain" });
  17. response.end("Server Error:" + exception);
  18. }
  19. }
  20. } else { //资源不存在
  21. response.writeHead(404, { 'Content-Type': 'text/plain' });
  22. response.end('404:File Not found');
  23. }
  24. });

处理静态资源上面已说过了,请看处理动态资 源的那两句,localPath是相对web根目录的后端js的路径,如果上面register.js在 根目录/src/account 文件夹里,那么你的url请求就是http://localhost/account/register,而这时localPath就是./src /account/register.js,注意这里不是MVC,只是url没有src路径和.js后缀而已,那么为什么要这样呢?就是为了和前端js文 件区分开!

再有,没有配置的程序不是好程序,不过我的配置总是很烂的配置!(你可能感觉我写的很乱,不过没关系,后面给出完整代码,看一下就清楚了,如果你感觉不错,下载了事例在你电脑上运行了,那我也倍感荣幸了!)

//配置
var config = {
    port: 80,
    denyAccess: ['./httpserver.js', './src/requirecache.js'],
    localIPs: ['127.0.0.1'],
    srcpath: '/src'
};
./src/requirecache.js这个文件是干什么的呢?这里要说明一下,require这个方法是有缓存机制的,它把加载过的模块都缓存到require.cache这个对象中,当第二次require的时候就直接回返缓存的模块了,当然这样是为性能考虑,但是我修改一下register.js是不想重启web服务器的,如果你感觉无所谓,那这个特殊的动态资源就不需要了,请明白,requirecache.js和register.js是被一样看待的,都是处理请求的js文件。requirecache.js模块的功能就是删除模板缓存:
var querystring=require('querystring');
var url=require('url');
 
exports.processRequest = function (request, response) {
    response.writeHead(200, { 'Content-Type': 'text/html' });
    var qs= querystring.parse(url.parse(request.url).query);
    if(qs.key){
        delete require.cache[qs.key];
    }
    response.write('<html><head></head><body>');
    for(var key in require.cache){
        response.write('<a href="?key='+key+'">'+key+'</a><br/>');
    }
    response.write('<a href="?">View</a><br/>');
    response.end('</body></html>');   
}

运行了node httpserver.js后,打开http://localhost/requirecache大概是这样:

然后就是删哪个点哪个就可以(对于httpserver.js来说,是一个很实用小功能)。

源代码有两个文件:

httpserver.js(这个是必须的)

var http = require('http');
var url = require('url');
var fs = require('fs');
var path = require('path');
 
//配置
var config = {
    port: 80,
    denyAccess: ['./httpserver.js', './src/requirecache.js'],
    localIPs: ['127.0.0.1'],
    srcpath: '/src'
};
 
 
//开始HTTP服务器
http.createServer(processRequestRoute).listen(config.port);
console.log("Server has started. port:"+config.port);
 
//路由URL
function processRequestRoute(request, response) {
    var pathname = url.parse(request.url).pathname;
    if (pathname === '/') {
        pathname = "/index.html"; //默认页面
    }
    var ext = path.extname(pathname);
    var localPath = ''; //本地相对路径
    var staticres = false; //是否是静态资源
    if (ext.length > 0) {
        localPath = '.' + pathname;
        staticRes = true;
    } else {
        localPath = '.' + config.srcpath + pathname + '.js';
        staticRes = false;
    }
    //禁止远程访问
    if (config.denyAccess && config.denyAccess.length > 0) {
        var islocal = false;
        var remoteAddress = request.connection.remoteAddress;
        for (var j = 0; j < config.localIPs.length; j++) {
            if (remoteAddress === config.localIPs[j]) {
                islocal = true;
                break;
            }
        }
        if (!islocal) {
            for (var i = 0; i < config.denyAccess.length; i++) {
                if (localPath === config.denyAccess[i]) {
                    response.writeHead(403, { 'Content-Type': 'text/plain' });
                    response.end('403:Deny access to this page');
                    return;
                }
            }
        }
    }
    //禁止访问后端js
    if (staticRes && localPath.indexOf(config.srcpath) >= 0) {
        response.writeHead(403, { 'Content-Type': 'text/plain' });
        response.end('403:Deny access to this page');
        return;
    }
 
    fs.exists(localPath, function (exists) {
        if (exists) {
            if (staticRes) {
                staticResHandler(localPath, ext, response); //静态资源
            } else {
                try {
                    var handler = require(localPath);
                    if (handler.processRequest && typeof handler.processRequest === 'function') {
                        handler.processRequest(request, response); //动态资源
                    } else {
                        response.writeHead(404, { 'Content-Type': 'text/plain' });
                        response.end('404:Handle Not found');
                    }
                } catch (exception) {
                    console.log('error::url:' + request.url + 'msg:' + exception);
                    response.writeHead(500, { "Content-Type": "text/plain" });
                    response.end("Server Error:" + exception);
                }
            }
        } else { //资源不存在
            response.writeHead(404, { 'Content-Type': 'text/plain' });
            response.end('404:File Not found');
        }
    });
}
 
//处理静态资源
function staticResHandler(localPath, ext, response) {
    fs.readFile(localPath, "binary", function (error, file) {
        if (error) {
            response.writeHead(500, { "Content-Type": "text/plain" });
            response.end("Server Error:" + error);
        } else {
            response.writeHead(200, { "Content-Type": getContentTypeByExt(ext) });
            response.end(file, "binary");
        }
    });
}
 
//得到ContentType
function getContentTypeByExt(ext) {
    ext = ext.toLowerCase();
    if (ext === '.htm' || ext === '.html')
        return 'text/html';
    else if (ext === '.js')
        return 'application/x-javascript';
    else if (ext === '.css')
        return 'text/css';
    else if (ext === '.jpe' || ext === '.jpeg' || ext === '.jpg')
        return 'image/jpeg';
    else if (ext === '.png')
        return 'image/png';
    else if (ext === '.ico')
        return 'image/x-icon';
    else if (ext === '.zip')
        return 'application/zip';
    else if (ext === '.doc')
        return 'application/msword';
    else
        return 'text/plain';
}

requirecache.js(这个是很有用的,要放到config.srcpath路径下)

var querystring=require('querystring');
var url=require('url');
 
exports.processRequest = function (request, response) {
    response.writeHead(200, { 'Content-Type': 'text/html' });
    var qs= querystring.parse(url.parse(request.url).query);
    if(qs.key){
        delete require.cache[qs.key];
    }
    response.write('<html><head></head><body>');
    for(var key in require.cache){
        response.write('<a href="?key=' + key + '">' + key + '</a><br/>');
    }
    response.write('<a href="?">View</a><br/>');
    response.end('</body></html>');
}

完成例子下载


 

19 2015-06

 

我要 分享

 

 

本文 作者

 

相关 文章