Node.js 实现简单的接口服务器的实例代码

-----  |----HamstrerServlet  | ------ command3G    | ------ login.js  //登录脚本(这里只是简单演示) | --- server.js (主启动脚本) | --- dbutil (数据库操作)

var $ = require('jquery'); var _ = require('underscore'); var vm = require('vm'); var fs = require('fs'); var journey = require('journey'); var async = require('async'); var dbutil = require('./dbutil');  String.prototype.replaceAll = function(s1, s2) {   var demo = this   while (demo.indexOf(s1) != - 1)   demo = demo.replace(s1, s2);   return demo; } // Create a Router var router = new(journey.Router);  // Create the routing table router.map(function() {   // this.root.bind(function (req, res) { res.send("Welcome") });   this.get(/HamstrerServlet//(/w*/W*/w*)*/).bind(function(req, res, id) {     var runJsPath = this.request.url.pathname.replaceAll("/HamstrerServlet", "") + ".js";     console.log("执行的脚本文件:" + runJsPath);      //传入的绑定变量     var sandbox = {       req: req,       res: res,       $: $,       dbutil: dbutil,       async: async,       console: console     };      fs.readFile('./HamstrerServlet' + runJsPath, function(err, data) {       vm.runInNewContext(data, sandbox, 'myfile.vm');     });    });   this.post('/^HamstrerServlet//(/w*)$/)').bind(function(req, res, data) {     res.send(200);   }); });  require('http').createServer(function(request, response) {   var body = "";    request.addListener('data', function(chunk) {     body += chunk   });   request.addListener('end', function() {     router.handle(request, body, function(result) {       response.writeHead(result.status, result.headers);       response.end(result.body);     });   }); }).listen(8080); 

var mysql = require('mysql'); //导入mysql Module  var pool = mysql.createPool({   host: '192.168.140.237',   user: 'root',   password: '123456',   database: 'command3G' });  //查询sql语句 function query(strSQL, param, callback) {   pool.getConnection(function(err, connection) {     connection.query(strSQL, param, function(err, rows, fields) {       if (err) throw err;       callback(rows, fields);       connection.end();       // connection.destroy();     });   }); }  exports.query = query; 

console.log("beigin");  //并行处理，相当于2个map最后再做一个ReReduce async.parallel([   function(callback){     // 从数据库中获取当前时间     dbutil.query("SELECT CURTIME() AS DATE",null,function(rows,fields){       callback(null, rows[0].DATE);     });   },   function(callback){     //随便返回一个值     callback(null, '中文测试');   } ], function(err, results){   console.log(results);   var retVal ={     "currentTime": results[0],     "desc": results[1]   };   res.sendBody(JSON.stringify(retVal)); });