摘要：使用，可參考執(zhí)行退出命令，只要設(shè)置，即可。下節(jié)主要實(shí)現(xiàn)注冊時(shí)的郵件驗(yàn)證保存登錄狀態(tài)異常處理，同步異步操作全棧工程技術(shù)新群上一篇公司項(xiàng)目實(shí)踐下一篇待續(xù)

???書接上回，我們搭建了WEB服務(wù)端路由、模板等功能，完成了register 通過ajax與后端的通信，今天主要完成數(shù)據(jù)與mongodb的存取，實(shí)現(xiàn)注冊 / 登錄 / 退出功能

???DEMO GIT https://github.com/xiaolulu/mynodejs.git

???上一節(jié)我們已經(jīng)安裝過了mongo，本節(jié)主要是對其操作

???nodejs對 mongo的操作，我們使用 mongoose庫

???在package.json添加mongoose，并npm install

???使用參考http://www.upopen.cn/article/info?id=559688a7f0e6e0665b000004

javascript        var mongoose = require( "mongoose"  ); //引用模塊
        mongoose.connect( "mongodb://127.0.0.1/myDB", function( err ){
            //連接mongoose，連接本地127.0.0.1,mongo的默認(rèn)端口是 27017
            if( !err ){
                console.log( "DB == connect to mongodb" );
            } else {
                throw err;
            }
        } );

        var Schema = mongoose.Schema;

        var UserSchema = new Schema({ //創(chuàng)建User表模型，數(shù)據(jù)可據(jù)需求增減
            username: String,
            password: String,
            email: String,
            disabled: Boolean, //后面加注冊后的郵件驗(yàn)證功能
            date: Date,
            power: Number  //后面會(huì)用到權(quán)限功能  
        });

        var UserModel = mongoose.model( "User", UserSchema, "User" );

        function initData( data, db ){ //對參數(shù)做預(yù)處理，以防出現(xiàn)不合要求的參數(shù)，后面這塊會(huì)做擴(kuò)展
            var query = {};
            for( var key in data ){
                if( db.tree[ key ] ){
                    query[ key ] = data[ key ];
                }
            }
            return query;
        }

        function addUser( data, cb ){ //增加用戶
            data = initData( data, UserSchema );
            ( new UserModel( data )).save( function( err, doc  ){
                cb( err, doc );
            })
        }
        function findUser( data, cb ){ //查找用戶
            data = initData( data, UserSchema );
            UserModel.findOne( data ).exec( function( err, doc ){
                cb( err, doc );
            })
        }

        module.exports = {
            addUser: addUser,
            findUser: findUser
        }

javascript        var db = require( "../db/sql" ); //添加前面定義的db操作模塊

        function addUser( req, res ){ //增加用戶
            var data = req.body; //post過來的數(shù)據(jù)在req.body里，get過來的數(shù)據(jù)在req.query里
            data.date = new Date(); //數(shù)據(jù)里增加時(shí)間
            db.addUser( data, function( err, doc ){
            if( !err ){
                res.send( { code: 0, msg: "add User Success", data: doc } );
                //對查詢結(jié)果返回，返回格式統(tǒng)一為 {code: 返回碼, msg: 返回描述, data: 返回值}
                }
            })
        }

        function findUser( req, res ){ //查找用戶
            var data = req.body;
            db.addUser( data, function( err, doc ){
                if( !err ){
                    res.send(  { code: 0, msg: "find User Success", data: doc }  );
                }
            })
        }

        module.exports = {
            addUser: addUser,
            findUser: findUser
        }

    4、修改上節(jié)在/root/web/routes/issue.js定義的register函數(shù)改為

javascript
        function registerUser( req, res ){
            user.addUser( req, res );
        }

javascript        var issue = require( "./issue" ),
              session = require( "express-session" ); //添加 express-session引用
        exports.all = function( app ){
            app.use( session({ //配置session
                resave: false,
                saveUninitialized: false,
                secret: "upopen"
            }))
            app.use( function( req, res, next){
                if( req.path != "/login" && !req.session.status ){ //判斷session狀態(tài)是否是true
                    res.redirect("/login"); //不是則跳轉(zhuǎn)到登錄頁
                } else {
                    next(); //為true，則繼續(xù)執(zhí)行其請求
                }
            })
            app.get( "/", function( req, res ){
                issue.index( req, res );
            });
        …

javascript        …
        function findUser( req, res ){
        var data = req.body;
            db.findUser( data, function( err, doc ){
                if( !err ){
                    if( doc ){ //如果登錄有查找結(jié)果
                        req.session.status = true;        //則session里記錄狀態(tài)為true
                    }
                    res.send(  { code: 0, msg: "find User Success", data: doc }  );
                }
            })
        }
        …

javascript
        module.exports = {
            "/user/center" : 1,
            "/user/info": 1,
            "/user/blog": 1
        }

javascript        …
        var privilege = require( "../config/privilege" );
        …
        app.use( function( req, res, next){
            if( privilege[ req.path ] && req.path != "/login" && !req.session.status ){
                //privilege[ req.path ] 判斷該路徑是否需要登錄權(quán)限
                if( req.method == "GET" ){ //如果是get請求
                    res.redirect("/login"); 則執(zhí)行跳轉(zhuǎn)
                } else { //其它請求，基本都是POST，是不能直接redirect
                    res.send( { code: 1001, msg: "need you to log in"}); //則返回錯(cuò)誤碼，提示需要登錄
                }
            } else {
                next();
            }
        })
        …

javascript         ...
        app.get("/logout", function( req, res ){
            req.session.status = false; //設(shè)置session狀態(tài)為未登錄
            res.setHeader("Set-Cookie","username=null;" ); //清除cookie
            res.redirect( "/" ); //跳轉(zhuǎn)到首頁
        })
        ...