node 는 Koa 2 를 사용 하여 웹 프로젝트 를 만 드 는 방법

9743 단어 Koa2web
Node.js 가 날로 뜨 거 워 지면 서 각종 프레임 워 크 가 끊임없이 등장 하기 시 작 했 고 Node.js 도 서버 의 요청 을 처리 하 는 장면 에 점점 응용 되 기 시작 했다.웹 프로젝트 를 구축 하 는 틀 도 이에 따라 나타 나 기 시작 했다.express,koa,koa 2,egg 등 은 당연히 그 좋 고 나 쁨 을 알 아야 한다.본 고 는 소스 코드 와 관련 되 지 않 고 초보 자 를 데 리 고 Koa 2 의 기본 적 인 사용 을 간단하게 이해 할 것 입 니 다.여러분 들 이 평론 에서 서로 교류 하고 공부 하 는 것 을 환영 합 니 다.
메모:koa 2 는 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('koa');
const app = new Koa();
const router2controller = require('./app/router2controller.js');
const config = require('./config/config.local.js');

app.use(router2controller());
app.listen(config.port);
console.log("Server started and listen on port " + config.port);
요청 한 신문 문체 가 XML 형식 이 라면 아래 코드 를 추가 하여 메 시 지 를 자동 으로 해석 할 수 있 습 니 다(koa-xxx 버 전 을 참조 하여 koa 2 와 대응 해 야 합 니 다)

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

//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);
코드 에서 router 2 controller.js 파일 을 도입 한 것 을 보 았 습 니 다.이 파일 은 전단 요청 을 완료 하고 구체 적 인 처리 방법 으로 가 는 경로 입 니 다.
2.3.공유 기 파일
[router2controller.js]
이 클래스 는 요청 맵 을 불 러 오기 위해 controller 폴 더 의 파일 을 자동 으로 검색 합 니 다.각각 요청 할 필요 가 없습니다.
koa-router 원생 제공 방법 은 다음 과 같 습 니 다.

router
 .get('/', async (ctx,next) => {
  this.body = 'Hello World!';
 })
 .post('/users', async (ctx,next) => {
  //TODO
 })
 .put('/users/:id', async (ctx,next) => {
  //TODO
 })
 .del('/users/:id', async (ctx,next) => {
  //TODO
 });
자동 검색 controller 패키지 구현 방법 은 다음 과 같 습 니 다.

const fs = require('fs');
const router = require('koa-router')();

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 요청 은 사용자 정 보 를 저장 합 니 다.

const userService = require('./../service/userService.js');

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

  let html = '<html><body>'
    + '<div> userinfo:&nbsp;' + userInfo + '</div>'
    + '</body></html>';
  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 에 되 돌려 줍 니 다.

const userDao = require('./../dao/userDao.js');

var getUserById = async (userId) => {
  var users = userDao.getUserById(userId);
  var responseContent = '';
  for(let user of users) {
    reaponseContent += '  ：' + user.name + '&nbsp;|';
    reaponseContent += '  ：' + user.age + '&nbsp;|';
    reaponseContent += '  ：' + user.height + '<br />';
  }
  return responseContent;
}

module.exports = {
  getUserById : getUserById
};
2.6.데이터 획득
[userDao.js]
요청 을 통 해 매개 변 수 를 입력 하여 user 데 이 터 를 가 져 옵 니 다.

const mysql = require('./../utils/mysqlUtil.js');

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 가 시작 하 는 데이터베이스 작업 요청 을 포함 합 니 다.

const mysql = require('mysql');
const config = require('./../../config/config.local.js');

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

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

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

          resolve(results);
        });
      }

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

  return results;
};

module.exports = {
  release : release,
  execQuery : execQuery
}
이상 이 바로 본 고의 모든 내용 입 니 다.여러분 의 학습 에 도움 이 되 고 저 희 를 많이 응원 해 주 셨 으 면 좋 겠 습 니 다.
Vue.js 프레임 워 크 가 무엇 입 니까?왜 선택 하 셨 습 니까?제 1 과
Node 자동화 배치 방법

좋은 웹페이지 즐겨찾기

개발자 우수 사이트 수집

개발자가 알아야 할 필수 사이트 100선 추천 우리는 당신을 위해 100개의 자주 사용하는 개발자 학습 사이트를 정리했습니다
best100-homepage