node使用Koa2搭建web項目-js教程-PHP中文網

首頁

web前端

js教程

node使用Koa2搭建web項目

小云云

Jan 15, 2018 pm 01:10 PM

koa2nodeweb

本文主要介紹了node使用Koa2建造web專案的方法，小編覺得挺不錯的，現在分享給大家，也給大家做個參考。一起跟著小編過來看看吧，希望能幫助大家。

隨著Node.js的日益火熱，各種框架開始層出不窮的湧現出來，Node.js也開始逐漸的被應用到處理服務端請求的場景中。搭建Web專案的框架也隨之開始出現──express、koa、koa2、egg等，當然要了解其好壞還是要自己去啃原始碼的。本文將不會涉及原始碼，只是帶領初學者簡單了解下Koa2的基本使用，歡迎大家在評論中互相交流學習。

注意：koa2使用了ES7的語法，所以使用時請升級Node版本到最新。了解更詳細的原始碼資訊可以到git上的koajs/koa去了解

1.專案目錄結構

##2. 程式碼邏輯解析

2.1. 套件結構檔

[package.json]

{
 "name": "weixin-node-koa",
 "version": "1.0.0",
 "description": "node.js with koa2",
 "private": true,
 "dependencies": {
  "koa": "^2.0.0",
  "koa-router": "^7.0.0",
  "mysql":"2.13.0"
 },
 "scripts": {
  "start": "node app.js"
 },
 "engines": {
  "node": ">=6.0.0"
 },
 "author": "Fly",
 "license": "CENTERM"
}

2.2. 啟動入口檔案

[app.js]

const Koa = require(&#39;koa&#39;);
const app = new Koa();
const router2controller = require(&#39;./app/router2controller.js&#39;);
const config = require(&#39;./config/config.local.js&#39;);

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

如果請求的封包是XML格式，可以加入下面的程式碼自動解析封包（注意引用koa-xxx的版本要與koa2對應）

const Koa = require(&#39;koa&#39;);
const app = new Koa();
const router2controller = require(&#39;./app/router2controller.js&#39;);
const config = require(&#39;./config/config.local.js&#39;);

//start接收到的xml数据请求单独解析存储
const xmlParser = require(&#39;koa-xml-body&#39;);
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原生提供方法如下：

router
 .get(&#39;/&#39;, async (ctx,next) => {
  this.body = &#39;Hello World!&#39;;
 })
 .post(&#39;/users&#39;, async (ctx,next) => {
  //TODO
 })
 .put(&#39;/users/:id&#39;, async (ctx,next) => {
  //TODO
 })
 .del(&#39;/users/:id&#39;, async (ctx,next) => {
  //TODO
 });

自動掃描controller套件實作方法如下

const fs = require(&#39;fs&#39;);
const router = require(&#39;koa-router&#39;)();

function addMapping(router, mapping) {
  for (var url in mapping) {
    if (url.startsWith(&#39;GET &#39;)) {
      var path = url.substring(4);
      router.get(path, mapping[url]);
      console.log(`register URL mapping: GET ${path}`);
    } else if (url.startsWith(&#39;POST &#39;)) {
      var path = url.substring(5);
      router.post(path, mapping[url]);
      console.log(`register URL mapping: POST ${path}`);
    } else if (url.startsWith(&#39;PUT &#39;)) {
      var path = url.substring(4);
      router.put(path, mapping[url]);
      console.log(`register URL mapping: PUT ${path}`);
    } else if (url.startsWith(&#39;DELETE &#39;)) {
      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 + &#39;/&#39; + dir).filter((f) => {
    return f.endsWith(&#39;.js&#39;);
  }).forEach((f) => {
    console.log(`process controller: ${f}...`);
    let mapping = require(__dirname + &#39;/&#39; + dir + &#39;/&#39; + f);
    addMapping(router, mapping);
  });
}

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

2.4.控制器

# #[userController.js]

***Controller.js是用來處理具體請求資訊以及返回資料的，userController.js中處理了GET請求獲取使用者資訊，POST請求保存使用者資訊

const userService = require(&#39;./../service/userService.js&#39;);

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

  let html = &#39;<html><body>&#39;
    + &#39;<p> userinfo: &#39; + userInfo + &#39;</p>&#39;
    + &#39;</body></html>&#39;;
  ctx.response.type =&#39;text/html&#39;;
  ctx.response.body = html;
};

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

module.exports = {
  &#39;GET /getUserinfo&#39;: getUserinfo,
  &#39;POST /saveUserinfo&#39;: saveUserinfo
};

2.5. 資料處理

[userService.js]

處理封裝從***Dao .js取得到的資料回傳至Controller

const userDao = require(&#39;./../dao/userDao.js&#39;);

var getUserById = async (userId) => {
  var users = userDao.getUserById(userId);
  var responseContent = &#39;&#39;;
  for(let user of users) {
    reaponseContent += &#39;姓名：&#39; + user.name + &#39; |&#39;;
    reaponseContent += &#39;年龄：&#39; + user.age + &#39; |&#39;;
    reaponseContent += &#39;身高：&#39; + user.height + &#39;<br />&#39;;
  }
  return responseContent;
}

module.exports = {
  getUserById : getUserById
};

2.6.資料取得

[userDao.js]

透過請求傳入參數來取得user資料

const mysql = require(&#39;./../utils/mysqlUtil.js&#39;);

var getUserById = async (userId) => {
  let mysqlOptions = {
    sql : &#39;select * from table_user where user_id = ?&#39;,
    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發起的資料庫操作請求

###########

const mysql = require(&#39;mysql&#39;);
const config = require(&#39;./../../config/config.local.js&#39;);

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

var release = connection => {
  connection.end(function(error) {
    if(error) {
      console.log(&#39;Connection closed failed.&#39;);
    } else {
      console.log(&#39;Connection closed succeeded.&#39;);
    }
  });
};

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 sql = sqlOptions[&#39;sql&#39;];
      var args = sqlOptions[&#39;args&#39;];

      if(!args) {
        var query = connection.query(sql, (error, results) => {
          if(error) {
            console.log(&#39;Execute query error !&#39;);
            throw error;
          }

          resolve(results);
        });
      } else {
        var query = connection.query(sql, args, function(error, results) {
          if(error) {
            console.log(&#39;Execute query error !&#39;);
            throw error;
          }

          resolve(results);
        });
      }

      connection.release(function(error) {
        if(error) {
          console.log(&#39;Mysql connection close failed !&#39;);
          throw error;
        }
      });
    });
  }).then(function (chunk) {
    return chunk;
  });

  return results;
};

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

###相關推薦：############有關koa2的文章推薦10篇############nodejs6中使用koa2框架的教學########### ##分享nodejs中使用koa2框架的實例教學######

以上是node使用Koa2搭建web項目的詳細內容。更多資訊請關注PHP中文網其他相關文章！

陳述

本文內容由網友自願投稿，版權歸原作者所有。本站不承擔相應的法律責任。如發現涉嫌抄襲或侵權的內容，請聯絡admin@php.cn

JavaScript的演變：當前的趨勢和未來前景Apr 10, 2025 am 09:33 AM

JavaScript的最新趨勢包括TypeScript的崛起、現代框架和庫的流行以及WebAssembly的應用。未來前景涵蓋更強大的類型系統、服務器端JavaScript的發展、人工智能和機器學習的擴展以及物聯網和邊緣計算的潛力。

神秘的JavaScript：它的作用以及為什麼重要Apr 09, 2025 am 12:07 AM

JavaScript是現代Web開發的基石，它的主要功能包括事件驅動編程、動態內容生成和異步編程。 1)事件驅動編程允許網頁根據用戶操作動態變化。 2)動態內容生成使得頁面內容可以根據條件調整。 3)異步編程確保用戶界面不被阻塞。 JavaScript廣泛應用於網頁交互、單頁面應用和服務器端開發，極大地提升了用戶體驗和跨平台開發的靈活性。