node使用Koa2搭建web项目的方法

前端之家收集整理的这篇文章主要介绍了node使用Koa2搭建web项目的方法前端之家小编觉得挺不错的,现在分享给大家,也给大家做个参考。

随着Node.js的日益火热,各种框架开始层出不穷的涌现出来,Node.js也开始逐渐的被应用到处理服务端请求的场景中。搭建Web项目的框架也随之开始出现——express、koa、koa2、egg等,当然要了解其好坏还是要自己去啃源码的。本文将不会涉及到源码,只是带领初学者简单了解下Koa2的基本使用,欢迎大家在评论中互相交流学习。

注意:koa2使用了ES7的语法,所以使用时请升级Node版本到最新。了解更详细的源码信息可以到@L_403_0@去了解

1. 项目目录结构

2. 代码逻辑解析

2.1. 包结构文件

[package.json]

MysqL":"2.13.0" },"scripts": { "start": "node app.js" },"engines": { "node": ">=6.0.0" },"author": "Fly","license": "CENTERM" }

2.2. 启动入口文件

[app.js]

app.use(router2controller());
app.listen(config.port);
console.log("Server started and listen on port " + config.port);

如果请求的报文体是XML格式,可以添加下面的代码自动解析报文(注意引用koa-xxx的版本要与koa2对应)

//start接收到的xml数据请求单独解析存储
const xmlParser = require('koa-xml-body');
app.use(xmlParser()).use((ctx,next) => {
ctx.data = ctx.request.body;
return next();
});
//end

app.use(router2controller());
app.listen(config.port);
console.log("Server started and listen on port " + config.port);

代码看到引入了一个router2controller.js的文件,这个文件是完成前端请求到具体处理方法的路由过程

2.3. 路由器文件

[router2controller.js]

该类将会自动扫描controller文件夹中的文件来加载请求映射,不需要挨个请求单独配置

koa-router原生提供方法如下:

{ this.body = 'Hello World!'; }) .post('/users',next) => { //TODO }) .put('/users/:id',next) => { //TODO }) .del('/users/:id',next) => { //TODO });

自动扫描controller包实现方法如下

function addMapping(router,mapping) {
for (var url in mapping) {
if (url.startsWith('GET ')) {
var path = url.substring(4);
router.get(path,mapping[url]);
console.log(register URL mapping: GET ${path});
} else if (url.startsWith('POST ')) {
var path = url.substring(5);
router.post(path,mapping[url]);
console.log(register URL mapping: POST ${path});
} else if (url.startsWith('PUT ')) {
var path = url.substring(4);
router.put(path,mapping[url]);
console.log(register URL mapping: PUT ${path});
} else if (url.startsWith('DELETE ')) {
var path = url.substring(7);
router.del(path,mapping[url]);
console.log(register URL mapping: DELETE ${path});
} else {
console.log(invalid URL: ${url});
}
}
}

function addControllers(router,dir) {
fs.readdirSync(dirname + '/' + dir).filter((f) => {
return f.endsWith('.js');
}).forEach((f) => {
console.log(process controller: ${f}...);
let mapping = require(
dirname + '/' + dir + '/' + f);
addMapping(router,mapping);
});
}

module.exports = function (dir) {
var controllersDir = dir || 'controller';
addControllers(router,controllersDir);
return router.routes();
};

2.4. 控制器

[userController.js]

***Controller.js是用来处理具体请求信息以及返回数据的,userController.js中处理了GET请求获取用户信息,POST请求保存用户信息

var getUserinfo = (ctx,next) => {
let query = ctx.query;
let userId = query.id;
let userInfo = userService.getUserById(userId);

let html = ''

  • '
    userinfo:' + userInfo + '
    '
  • '';
    ctx.response.type ='text/html';
    ctx.response.body = html;
    };

var saveUserinfo = (ctx,next) => {
const requestString = ctx.data;
//TODO数据处理
Console.log(requestString);
};

module.exports = {
'GET /getUserinfo': getUserinfo,'POST /saveUserinfo': saveUserinfo
};

2.5. 数据处理

[userService.js]

处理封装从***Dao.js获取到的数据返回给Controller

var getUserById = async (userId) => {
var users = userDao.getUserById(userId);
var responseContent = '';
for(let user of users) {
reaponseContent += '姓名:' + user.name + '|';
reaponseContent += '年龄:' + user.age + '|';
reaponseContent += '身高:' + user.height + '
';
}
return responseContent;
}

module.exports = {
getUserById : getUserById
};

2.6. 数据获取

[userDao.js]

通过请求传入参数来获取user数据

var getUserById = async (userId) => {
let MysqLOptions = {
sql : 'select * from table_user where user_id = ?',args : [userId]
};

var users = await MysqL.execQuery(MysqLOptions);
if(users.length == 0) {
return null;
} else {
return users;
}
};

module.exports = {
getUserById : getUserById
};

2.7. 数据库操作

[MysqLUtil.js]

包含了数据库连接池控制,连接建立、释放管理,执行Dao发起的数据库操作请求

var connectionPool = mysql.createPool({
'host' : config.database.host,'port':config.database.port,'user' : config.database.user,'password' : config.database.password,'database' : config.database.database,'charset': config.database.charset,'connectionLimit': config.database.connectionLimit,'supportBigNumbers': true,'bigNumberStrings': true
});

var release = connection => {
connection.end(function(error) {
if(error) {
console.log('Connection closed Failed.');
} else {
console.log('Connection closed succeeded.');
}
});
};

var execQuery = sqlOptions => {
var results = new Promise((resolve,reject) => {
connectionPool.getConnection((error,connection) => {
if(error) {
console.log("Get connection from MysqL pool Failed !");
throw error;
}

  var <a href="/tag/sql/" target="_blank" class="keywords">sql</a> = <a href="/tag/sql/" target="_blank" class="keywords">sql</a>Options['<a href="/tag/sql/" target="_blank" class="keywords">sql</a>'];
  var args = <a href="/tag/sql/" target="_blank" class="keywords">sql</a>Options['args'];

  if(!args) {
    var query = connection.query(<a href="/tag/sql/" target="_blank" class="keywords">sql</a>,(error,results) => {
      if(error) {
        console.log('Execute query error !');
        throw error;
      }

      resolve(results);
    });
  } else {
    var query = connection.query(<a href="/tag/sql/" target="_blank" class="keywords">sql</a>,args,function(error,results) {
      if(error) {
        console.log('Execute query error !');
        throw error;
      }

      resolve(results);
    });
  }

  connection.release(function(error) {
    if(error) {
      console.log('<a href="/tag/MysqL/" target="_blank" class="keywords">MysqL</a> connection close <a href="/tag/Failed/" target="_blank" class="keywords">Failed</a> !');
      throw error;
    }
  });
});

}).then(function (chunk) {
return chunk;
});

return results;
};

module.exports = {
release : release,execQuery : execQuery
}

以上就是本文的全部内容,希望对大家的学习有所帮助,也希望大家多多支持编程之家。

猜你在找的Node.js相关文章