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

2019-11-19 16:31:20

字體：大中小

來源：轉(zhuǎn)載

供稿：網(wǎng)友

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

1）增加接口不需要重啟

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

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

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

-----  |----HamstrerServlet  | ------ command3G    | ------ login.js  //登錄腳本(這里只是簡單演示) | --- 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;

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, '中文測試');   } ], 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ì)輸出：