express中间件的实现

1.自定义静态文件目录

/**
*自定义定义静态文件目录中间件
*/
var express=require('express');
var path=require('path');
var fs=require('fs');
var bodyParser=require('body-parser');
var app=express();
app.set('views',path.join(__dirname,'views'));
app.set('view engine','ejs');

//普安短是否是结束字符串
var endWith=function(str,endStr){  
            if(endStr==null||endStr==""||str.length==0||endStr.length>str.length)  
              return false;  
            if(str.substring(str.length-endStr.length)==endStr)  
              return true;  
            else  
              return false;  
            return true;  
        }  
function serverStatic(root){
    return function(req,res,next){
        //console.log(req.baseUrl); /public
        //console.log(req.originalUrl); ///public/index.css
        var file=req.originalUrl.slice(req.baseUrl.length+1);
        file=path.resolve(root,file);
        //判断file是否查出public范围
        if(file.indexOf('Middleware')==-1){
                next();
                return;
        }
        //判断是文件还是目录
        fs.stat(file, function(err,stats){
            if(err){
                 next();
            } else if(stats.isFile()){//是文件,直接响应
                    if(endWith(file,'.css')){
                        res.setHeader("Content-Type", "text/css");
                    } else if(endWith(file,'.html')){
                        res.setHeader("Content-Type", "text/html");
                    } 
                    
                    var stream=fs.createReadStream(file);
                    stream.pipe(res);
            }  else if(stats.isDirectory()){//是目录
                    if(file[file.length-1]!=='/'){
                        file=file+'/';
                    }
                    fs.exists(file+'index.html', function(exists){ //添加默认路径
                        if(exists){
                            res.setHeader("Content-Type", "text/html");
                            var stream=fs.createReadStream(file+"index.html");
                            stream.pipe(res);
                        } else {
                            next();
                        }
                    }); 
            }
        });
    }
}

//定义数据解析器
app.use(bodyParser.json());
app.use(bodyParser.urlencoded({extended:true}));

//定义静态文件目录
//app.use(express.static(path.join(__dirname,'public')));
//自定义静态文件目录
app.use('/public',serverStatic(path.join(__dirname,'public')));

app.get('/',function(req,res){
    res.render('index',{title:'首页'});
});

app.listen(3000,function(req,res){
    console.log('app is runing at port 3000');
});

2.自定义文件存储session会话信息

/*
--path   session存储路径默认 ./sessions
--ttl   session 过期时间 默认3600

--retries   默认从session文件中读取的次数.默认 5
--factor    重用的指数因子默认为 1
--minTimeout    第一次尝试间隔时间,默认 50
--maxTimeout 最大两次重试的时间间隔,默认 100

--reapIntervalObject [OUT] Contains intervalObject if reap was scheduled
--reapInterval      Interval to clear expired sessions in seconds or -1 if do not need. Defaults to 1 hour
--reapAsync         use distinct worker process for removing stale sessions. Defaults to false
--reapSyncFallback  reap stale sessions synchronously if can not do it asynchronously. Default to false

--logFn             日志信息. 默认存储在console.log
--fallbackSessionFn 返回 fallback session object 当所有的尝试失败了 无默认值
--encrypt 存储和读取加密
*/
//完全参考session-file-store
var helper=require('./file-helper');
var fs = require('fs-extra');
module.exports=function(session){//获得session
    //此处可以看出闭包的威力
    var Store=session.Store;//获得session的Store一会需要继承它
    //定义一个对象,继承自session的Store
    function FileStore(options){
        var self=this;
        Store.call(this,options);//因为参数不固定,所以用了call
        self.options = helper.defaults(options);//获得默认参数
        fs.mkdirsSync(self.options.path);//创建目录
    }
    /**
   *集成Store对象
   prototype.__proto__指向prototype类的原型。
   这里不是单纯的覆盖原型,而是更在更高一层覆盖。
   FileStore.prototype= Store.prototype;这样就直接覆盖了
   */
  FileStore.prototype.__proto__ = Store.prototype;

  /**
   * 根据sessionId 获得Session
   *
   * @param  {String}   sessionId
   * @param  {Function} callback
   *
   * @api public
   */
  FileStore.prototype.get = function (sessionId, callback) {
    helper.get(sessionId, this.options, callback);
  };

  /**
   *设置Session
   *
   * @param {String}   sessionId
   * @param {Object}   session
   * @param {Function} callback (optional)
   *
   * @api public
   */
  FileStore.prototype.set = function (sessionId, session, callback) {
    helper.set(sessionId, session, this.options, callback);
  };

  /**
   * 跟新session
   *
   * @param {string} sessionId
   * @param {object} session
   * @param {function} callback
   *
   * @api public
   */

  FileStore.prototype.touch = function (sessionId, session, callback) {
    // will update last access time
    helper.set(sessionId, session, this.options, callback);
  };

  /**
   * 删除Session
   *
   * @param  {String}   sessionId   Files are serialized to disk by their
   *                                sessionId
   * @param  {Function} callback
   *
   * @api public
   */
  FileStore.prototype.destroy = function (sessionId, callback) {
    helper.destroy(sessionId, this.options, callback);
  };

  /**
   * 获得Session的长度
   *
   * @param  {Function} callback
   *
   * @api public
   */
  FileStore.prototype.length = function (callback) {
    helper.length(this.options, callback);
  };

  /**
   * 清空session
   *
   * @param  {Function} callback
   *
   * @api public
   */
  FileStore.prototype.clear = function (callback) {
    helper.clear(this.options, callback);
  };

  /**
   * 获得所有的session
   *
   * @param  {Function} callback
   *
   * @api public
   */
  FileStore.prototype.list = function (callback) {
    helper.list(this.options, callback);
  };

  /**
   * 判断session是否过期
   *
   * @param  {String}   sessionId
   * @param  {Function} callback
   *
   * @api public
   */
  FileStore.prototype.expired = function (sessionId, callback) {
    helper.expired(sessionId, this.options, callback);
  };
  return FileStore;
}
最后编辑于
©著作权归作者所有,转载或内容合作请联系作者
  • 序言:七十年代末,一起剥皮案震惊了整个滨河市,随后出现的几起案子,更是在滨河造成了极大的恐慌,老刑警刘岩,带你破解...
    沈念sama阅读 194,761评论 5 460
  • 序言:滨河连续发生了三起死亡事件,死亡现场离奇诡异,居然都是意外死亡,警方通过查阅死者的电脑和手机,发现死者居然都...
    沈念sama阅读 81,953评论 2 371
  • 文/潘晓璐 我一进店门,熙熙楼的掌柜王于贵愁眉苦脸地迎上来,“玉大人,你说我怎么就摊上这事。” “怎么了?”我有些...
    开封第一讲书人阅读 141,998评论 0 320
  • 文/不坏的土叔 我叫张陵,是天一观的道长。 经常有香客问我,道长,这世上最难降的妖魔是什么? 我笑而不...
    开封第一讲书人阅读 52,248评论 1 263
  • 正文 为了忘掉前任,我火速办了婚礼,结果婚礼上,老公的妹妹穿的比我还像新娘。我一直安慰自己,他们只是感情好,可当我...
    茶点故事阅读 61,130评论 4 356
  • 文/花漫 我一把揭开白布。 她就那样静静地躺着,像睡着了一般。 火红的嫁衣衬着肌肤如雪。 梳的纹丝不乱的头发上,一...
    开封第一讲书人阅读 46,145评论 1 272
  • 那天,我揣着相机与录音,去河边找鬼。 笑死,一个胖子当着我的面吹牛,可吹牛的内容都是我干的。 我是一名探鬼主播,决...
    沈念sama阅读 36,550评论 3 381
  • 文/苍兰香墨 我猛地睁开眼,长吁一口气:“原来是场噩梦啊……” “哼!你这毒妇竟也来了?” 一声冷哼从身侧响起,我...
    开封第一讲书人阅读 35,236评论 0 253
  • 序言:老挝万荣一对情侣失踪,失踪者是张志新(化名)和其女友刘颖,没想到半个月后,有当地人在树林里发现了一具尸体,经...
    沈念sama阅读 39,510评论 1 291
  • 正文 独居荒郊野岭守林人离奇死亡,尸身上长有42处带血的脓包…… 初始之章·张勋 以下内容为张勋视角 年9月15日...
    茶点故事阅读 34,601评论 2 310
  • 正文 我和宋清朗相恋三年,在试婚纱的时候发现自己被绿了。 大学时的朋友给我发了我未婚夫和他白月光在一起吃饭的照片。...
    茶点故事阅读 36,376评论 1 326
  • 序言:一个原本活蹦乱跳的男人离奇死亡,死状恐怖,灵堂内的尸体忽然破棺而出,到底是诈尸还是另有隐情,我是刑警宁泽,带...
    沈念sama阅读 32,247评论 3 313
  • 正文 年R本政府宣布,位于F岛的核电站,受9级特大地震影响,放射性物质发生泄漏。R本人自食恶果不足惜,却给世界环境...
    茶点故事阅读 37,613评论 3 299
  • 文/蒙蒙 一、第九天 我趴在偏房一处隐蔽的房顶上张望。 院中可真热闹,春花似锦、人声如沸。这庄子的主人今日做“春日...
    开封第一讲书人阅读 28,911评论 0 17
  • 文/苍兰香墨 我抬头看了看天上的太阳。三九已至,却和暖如春,着一层夹袄步出监牢的瞬间,已是汗流浃背。 一阵脚步声响...
    开封第一讲书人阅读 30,191评论 1 250
  • 我被黑心中介骗来泰国打工, 没想到刚下飞机就差点儿被人妖公主榨干…… 1. 我叫王不留,地道东北人。 一个月前我还...
    沈念sama阅读 41,532评论 2 342
  • 正文 我出身青楼,却偏偏与公主长得像,于是被迫代替她去往敌国和亲。 传闻我的和亲对象是个残疾皇子,可洞房花烛夜当晚...
    茶点故事阅读 40,739评论 2 335

推荐阅读更多精彩内容

  • 1. Java基础部分 基础部分的顺序:基本语法,类相关的语法,内部类的语法,继承相关的语法,异常的语法,线程的语...
    子非鱼_t_阅读 31,505评论 18 399
  • Spring Cloud为开发人员提供了快速构建分布式系统中一些常见模式的工具(例如配置管理,服务发现,断路器,智...
    卡卡罗2017阅读 134,497评论 18 139
  • Spring Boot 参考指南 介绍 转载自:https://www.gitbook.com/book/qbgb...
    毛宇鹏阅读 46,679评论 6 342
  • 从三月份找实习到现在,面了一些公司,挂了不少,但最终还是拿到小米、百度、阿里、京东、新浪、CVTE、乐视家的研发岗...
    时芥蓝阅读 42,139评论 11 349
  • 有人说,王国春每一步点踩的都很正,读的通讯专业、赶上了3G移动互联网、遇上了企业移动信息化的大潮,但是很多人忽略了...
    崔强阅读 864评论 0 1