摘要：介紹使用搭建服務(wù)并連接返回前端數(shù)據(jù)項(xiàng)目初始化首先保證你的環(huán)境已經(jīng)就緒創(chuàng)建項(xiàng)目文件夾創(chuàng)建文件夾，在文件夾中右鍵在此處運(yùn)行命令行運(yùn)行安裝依賴創(chuàng)建服務(wù)在項(xiàng)目文件中創(chuàng)建一個(gè)文件在項(xiàng)目跟目錄運(yùn)行瀏覽器地址輸入返回表示一次對(duì)話的上下文包括請(qǐng)求

使用koa搭建node服務(wù) 并連接mongodb返回前端數(shù)據(jù)
git https://gitee.com/wjj0720/koa...

首先保證你的node環(huán)境已經(jīng)就緒

1、創(chuàng)建項(xiàng)目文件夾

創(chuàng)建文件夾test，在文件夾中shift+右鍵 在此處運(yùn)行命令行
運(yùn)行 npm init --y

2、 安裝依賴

npm i koa koa-body koa-static koa-cors

// server.js
/*
 * 1、在項(xiàng)目文件中創(chuàng)建一個(gè)server.js文件
 * 2、在項(xiàng)目跟目錄運(yùn)行 node server.js
 * 3、瀏覽器地址輸入 http://127.0.0.1:3001/  返回 your server run seccess
 */
const Koa = require("koa");

const app = new Koa();

// ctx表示一次對(duì)話的上下文（包括 HTTP 請(qǐng)求和 HTTP 回復(fù)）
app.use(ctx => {
  ctx.body = "your server run seccess"
})

// 監(jiān)聽3001端口
app.listen(3001, () => {
  console.log("server run on 127.0.0.1:3001");
});

/*
 * 1、創(chuàng)建routers文件夾 文件夾下的每個(gè)目錄都將是一個(gè)訪問的處理
 * 2、routers文件夾 創(chuàng)建一個(gè)demo文件夾并擁有index.js
 * 3、在routers文件夾下創(chuàng)建routers.js 用戶集中路由
 * 目錄結(jié)構(gòu)
  -server.js
  -routers
    -routers.js
    -demo
      -index.js
  -router.js
*/

// ----server.js 文件 ----
const Koa = require("koa");
const koaBody = require("koa-body");
const static = require("koa-static")
//const cors = require("koa-cors")

// 引入router創(chuàng)建好的
let router = require("./router.js");

const app = new Koa();

// 解析post請(qǐng)求體
app.use(koaBody());

// 設(shè)置跨域 用不用插件都可
app.use(async (ctx, next) => {
  ctx.set("Access-Control-Allow-Origin", "*");
  return next();
});
// app.use(cors())

// 路由掛載
app.use(router.routes());

// 靜態(tài)文件處理
app.use(static(path.join(__dirname)))


// 監(jiān)聽3001端口
app.listen(3001, () => {
  console.log("server run on 127.0.0.1:3001");
});
// -------server.js 結(jié)束----------

// ------- router.js -----
let Router = require("koa-router");
let routers = require("./routers/routers.js");

let router = new Router();

routers.forEach(r => {
  router.all(r.path, r.handle)
});

module.exports = router;
//  ------ server.js  結(jié)束 ------

// ------ routers/routers.js  start-----
let demo = require("./demo/index.js")
let test = require("./test/index.js")

module.exports = [
  demo,
  test
]
// ------ routers/routers.js  end -----


// ------ routers/demo/index.js  start -----

module.exports = {
  path: "/demo/returnsomething",
  async handle(ctx, next) {
    // 拿到請(qǐng)求輸入
    let params = ctx.request.body;
    
    // 業(yè)務(wù)邏輯處理
    console.log(params);

    // 返回前端數(shù)據(jù)
    ctx.body = { res: "SUCCESS", data: "", code: 2000 };
  }
};

// ------ routers/demo/index.js  end -----

// node server 訪問 http://127.0.0.1:3001//demo/returnsomething

  /*
   * 1、首先我們?cè)趕erver.js同級(jí)目錄創(chuàng)建utils目錄 并創(chuàng)建connect.js 用公共方法的封裝
  */
  // --- utils/connect.js---
  // 安裝依賴 npm i mongodb assert
  const MongoClient = require("mongodb").MongoClient;
  const assert = require("assert");

  // Connection URL mongo服務(wù)地址
  const url = "mongodb://localhost:27017";

  // Database Name 確保mongo中有test庫
  const dbName = "test";

  // 公共的連接方法
  const connect = (tableName, callback) => {
    MongoClient.connect(
      url,
      { useNewUrlParser: true },
      function(err, client) {
        assert.equal(null, err);

        const db = client.db(dbName);
        callback(db.collection(tableName));
        client.close();
      }
    );
  };
  // 封裝一個(gè)向mongo插入多條數(shù)據(jù)的方法
  exports.insertMany = (tableName, condition, params) => {
    return new Promise((resolve, reject) => {
      connect(tableName, collection => {
        collection.insertMany(condition, params, (err, result) => {
            if (err) {
              console.log(err);
              reject();
            } else {
              resolve(result);
            }
        });
      });
    });
  };
  // 封裝一個(gè)查找數(shù)據(jù)庫的方法
  exports.findMany = (tableName, condition) => {
    return new Promise((resolve, reject) => {
      connect(
        tableName,
        collection => {
          collection.find(condition).toArray((err, result) => {
            if (err) {
              console.log(err);
              reject();
            } else {
              resolve(result);
            }
          });
        }
      );
    });
  };
  // ------ end -------

  // 在路由中調(diào)用
  // ---- routers/dome/index.js ---- 
  const { findMany } = require("../../utils/connect");
  module.exports = {
    path: "/servers/addapi",
    async handle(ctx, next) {
      let params = ctx.request.body;
      
      // 查找數(shù)據(jù)庫 返回值 參數(shù)：表明, 條件
      let res = await findMany("user", {});
      console.log(res);

      ctx.body = { res: "SUCCESS", data: res, code: 2000 };
    }
  };