给初学者 - Nodejs实现数据库增删改查的路由方式，可应用于多模块的复杂应用系统

#一个简单的路由

本方法通过简单的路由定义，实现复杂的业务逻辑。 路由定义如下：

var routes={
  "module1":{  //模块
		"action1":function(v,cb){require('module1.js').fn_a(v,cb);}   //引用功能模块1的操作1
		,"action2":function(v,cb){require('module1.js').fn_b(v,cb);}   //引用功能模块1的操作2		
		}
	,"module2":{  //模块
		"action1":function(v,cb){require('module2.js').fn_a(v,cb);}   //引用功能模块2的操作1
		,"action2":function(v,cb){require('module2.js').fn_b(v,cb);}   //引用功能模块2的操作2		
		}		
};

客户端ajax发送请求的url定义如下：

var v={
	"m":"module1"
	,"a":"action1"
	,"v":{...}//发往服务器端的复杂的数据结构，根据业务需求而定
};
var url='query?q='+JSON.strignify(v});

服务器端url解析如下：

    var querystring=require('querystring')
	,url=require('url');
	var sql_json=JSON.parse(querystring.parse(url.parse(req.url).query)['q']); 

调用路由：

routes[sql_json.m][sql_json.a]（sql_json.v,function(err,data){
	...
	});	

下面为稍详细的代码

#服务器端

###app.js

var http=require('http')
,path=require('path')
,fs=require('fs')
,route=require('./routes/route.js');
var session=new (require(’./session’))();
http.createServer(function(request,response){
route(request,response,session);
}).listen(3000);

###session.js --通过内存管理session的类 function session(){ var sessions=[]; this.isInSession=function(req){…} this.signIn=function(req){} this.signOut=function(req){} //从header里提取cookie信息
function objectifyCookie(req){ … return u_id;} } } ##route.js
var querystring=require(‘querystring’) ,url=require(‘url’); module.exports=function(req,res,session){ switch(req.url){ case ‘/’: returnFile(‘index’,res); break; case ‘/signin’: session.signIn(req,res); break; case ‘/signout’: session.signOut(req,res); break; default: returnData(req,res,session); break;
}
} function returnData(req,res,session){ if(!session.isInSession(req)){return …;}
var sql_json=JSON.parse(querystring.parse(url.parse(req.url).query)[‘q’]);
routes[sql_json.m][sql_json.a](sql_json.v,function(err,data){ … }); } var routes={ “module1”:{ “action1”:function(v,cb){(require(‘./module1.js’).fn_a(v,cb);} ,“action2”:function(v,cb){(require(‘./module1.js’).fn_b(v,cb);}
} ,“module2”:{ “action3”:function(v,cb){(require(‘./module2.js’).fn_c(v,cb);}
,“action4”:function(v,cb){(require(‘./module2.js’).fn_d(v,cb);} } }; function returFile(…){…} ##module1.js --负责具体业务逻辑的模块 //具体业务功能模块//module1.js //引用node-mysql及其设置 var mysql=require(…);

function fn_a(v,cb){...}
function fn_b(v,cb){...}
exports.fn_a=fn_a;
exports.fn_b=fn_b;

//module2.js
var mysql=require(...);
function fn_c(v,cb){...}
function fn_d(v,cb){...}
exports.fn_c=fn_c;
exports.fn_d=fn_d;

##客户端

ajax函数

function queryData(v,cb,isPost){
    var url=’query?q=’+JSON.strignify(v);
    var req=new XMLHttpRequest();
    req.onreadystatechange=function(){
	    if(req.readyState==4 && req.status==200){
	    	if(JSON.parse(req.responseText).msg=='not login'){
	      		renderSignIn();
	    } else{
	    	return cb(null,req.responseText);
	    }
    }
    } ;
    if(isPost){req.open('post',url,false);}else{req.open('get',url,false);}
    req.send(null);
}

###调用ajax var v={ “m”:”module1" //此处可使用简单的模块别称或者序号 ,”a”:”query”//此处可使用简单的操作别称或者序号 ,”v”:{…} // 此处可根据业务逻辑定义复杂的数据结构 }; queryData(v,function(err,data){ var _data=JSON.parse(data); //获得服务器传来对象 … });