Node.js 實(shí)現(xiàn)簡(jiǎn)單的接口服務(wù)器的實(shí)例代碼

更新時(shí)間：2017年05月23日 10:14:15 作者：zhangjianying

這篇文章主要介紹了Node.js 實(shí)現(xiàn)簡(jiǎn)單的接口服務(wù)器的實(shí)例代碼，非常具有實(shí)用價(jià)值，需要的朋友可以參考下

通過Node.js來實(shí)現(xiàn)接口服務(wù)器的功能。主要特點(diǎn)為：

1）增加接口不需要重啟

2）異步執(zhí)行，但接口閱讀的時(shí)候是同步的代碼（從上而下），或者可以按需求并行，串行

這里只是拋出基本思路，所以使用GET,也沒有加密之類的

首先啟動(dòng)監(jiān)聽端口，配置好訪問規(guī)則。（通過識(shí)別特定URL ，動(dòng)態(tài)執(zhí)行相應(yīng)的接口腳本）

-----
  |----HamstrerServlet
  | ------ command3G
    | ------ login.js  //登錄腳本(這里只是簡(jiǎn)單演示)
 | --- server.js (主啟動(dòng)腳本)
 | --- dbutil (數(shù)據(jù)庫操作)

server.js

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("執(zhí)行的腳本文件:" + 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);

dbutil.js

var mysql = require('mysql'); //導(dǎo)入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;

login.js

console.log("beigin"); 
 
//并行處理，相當(dāng)于2個(gè)map最后再做一個(gè)ReReduce 
async.parallel([ 
  function(callback){ 
    // 從數(shù)據(jù)庫中獲取當(dāng)前時(shí)間 
    dbutil.query("SELECT CURTIME() AS DATE",null,function(rows,fields){ 
      callback(null, rows[0].DATE); 
    }); 
  }, 
  function(callback){ 
    //隨便返回一個(gè)值 
    callback(null, '中文測(cè)試'); 
  } 
], 
function(err, results){ 
  console.log(results); 
  var retVal ={ 
    "currentTime": results[0], 
    "desc": results[1] 
  }; 
  res.sendBody(JSON.stringify(retVal)); 
});

node server.js 啟動(dòng)后通過訪問 http://localhost:8080/HamstrerServlet/command3G/login

就會(huì)輸出：