本文轉載自https://segmentfault.com/a/1190000019155991 初始化項目 使用 koa-generator 腳手架工具 npm install koa-generator -g #全局安裝 koa2 demo #創建demo項目 cd demo && npm in ...
本文轉載自https://segmentfault.com/a/1190000019155991
初始化項目
使用 koa-generator 腳手架工具
npm install koa-generator -g #全局安裝
koa2 demo #創建demo項目
cd demo && npm install #安裝依賴
預設生成項目結構如下
修改配置
用腳手架生成的項目,預設是伺服器渲染,即響應的是html視圖。而我們要開發介面,響應的是json數據。所以要刪除渲染視圖的代碼。增加響應json的配置。
首先刪除views文件夾,接下來就是修改 app.js
1. 刪除視圖配置
以下是要刪除的代碼
const views = require('koa-views')
app.use(views(__dirname + '/views', {
extension: 'pug'
}))
2. 修改路由的註冊方式,通過遍歷routes
文件夾讀取文件
const fs = require('fs')
fs.readdirSync('./routes').forEach(route=> {
let api = require(`./routes/${route}`)
app.use(api.routes(), api.allowedMethods())
})
3. 添加jwt認證,同時過濾不需要認證的路由,如獲取token
const jwt = require('koa-jwt')
app.use(jwt({ secret: 'yourstr' }).unless({
path: [
/^\/$/, /\/token/, /\/wechat/,
{ url: /\/papers/, methods: ['GET'] }
]
}));
4. 全局錯誤捕獲並響應
// error
app.use(async (ctx, next) => {
try {
await next()
} catch(err) {
ctx.status = err.statusCode || err.status || 500;
ctx.body = err.message
ctx.app.emit('error', err, ctx);
}
})
5. 跨域處理
當介面發佈到線上,前端通過ajax請求時,會報跨域的錯誤。koa2使用koa2-cors
這個庫非常方便的實現了跨域配置,使用起來也很簡單
const cors = require('koa2-cors');
app.use(cors());
連接資料庫
我們使用mongodb資料庫,在koa2中使用mongoose
這個庫來管理整個資料庫的操作。
1. 創建配置文件
根目錄下新建config文件夾,新建mongo.js
// config/mongo.js
const mongoose = require('mongoose').set('debug', true);
const options = {
autoReconnect: true
}
// username 資料庫用戶名
// password 資料庫密碼
// localhost 資料庫ip
// dbname 資料庫名稱
const url = 'mongodb://username:password@localhost:27017/dbname'
module.exports = {
connect: ()=> {
mongoose.connect(url,options)
let db = mongoose.connection
db.on('error', console.error.bind(console, '連接錯誤:'));
db.once('open', ()=> {
console.log('mongodb connect suucess');
})
}
}
然後在app.js中引入
const mongoConf = require('./config/mongo');
mongoConf.connect();
連接資料庫完成!
2. Schema 和 Model
mongoose有兩個核心概念,Schema
和Model
。Schema是預先定義的資料庫模型骨架,定義集合存儲的數據結構;Model是依據Schema構造生成的模型,有資料庫操作的能力。
下麵是案例,新建一個用戶集合:
根目錄下新建models文件夾,新建users.js
const mongoose = require('mongoose');
mongoose.Promise = global.Promise;
const Schema = mongoose.Schema
const ObjectId = mongoose.Types.ObjectId
// Schema
const usersSchema = new Schema({
_id: { type: ObjectId }, // 預設生成,不加也可以
username: { type: String, required: [true,'username不能為空'] },
sex: { type: String, enum: ['man','woman'], required: [true,'sex不能為空'] },
age: { type: Number required: [true,'age不能為空'] },
avatar: { type: String, default: '' }
})
// Model
const users = mongoose.model('users',usersSchema);
module.exports = users;
這樣,一個用戶集合的model就建好了,接下來在路由中直接引入這個model,就可以進行資料庫操作了
註冊路由
按照app.js的配置,routes文件夾下每一個文件都要註冊成為一個路由
1. 基本結構
一個基本的, RESTful風格的用戶增查改刪介面路由文件如下,包含了增查改刪的通用寫法
const router = require('koa-router')()
router.prefix('/users')
router.get('/', function (ctx, next) {
ctx.body = '獲取所有用戶'
})
router.get('/:id', function (ctx, next) {
let id = ctx.params.id
ctx.body = '獲取單個用戶'
})
router.post('/', function (ctx, next) {
let data = ctx.request.body
ctx.body = '新增用戶'
})
router.put('/:id', function (ctx, next) {
let id = ctx.params.id
ctx.body = '修改用戶信息'
})
router.delete('/:id', function (ctx, next) {
let id = ctx.params.id
ctx.body = '刪除用戶'
})
module.exports = router
2. 請求參數驗證
任何一次請求介面傳來的參數,首先要在最前面做一次參數驗證。如果請求參數不合法,那麼直接返回錯誤信息,無需繼續走下麵的業務邏輯。
參數驗證,推薦使用 Joi 這個庫,它是 hapijs 內置的參數驗證模塊,也是使用Schema定義數據結構。
比如創建用戶介面,對用戶傳來的數據進行驗證
const Joi = require('joi')
router.post('/', function (ctx, next) {
let data = ctx.request.body
let schema = Joi.object().keys({
username: Joi.string().required(),
sex: Joi.string().required(),
age: Joi.number().required()
})
let result = Joi.validate(data, schema);
if(result.error) {
return ctx.body = result.error.details
}
let reqdata = result.value; #經過驗證後的數據
})
這樣就完成了一個簡單的驗證,具體驗證請看joi文檔
3. 資料庫操作
之前已經創建了users的model,現在我們可以直接在路由文件中使用該模塊,進行資料庫操作
// 引入上一步創建的model
const Users = require('../models/users');
router.get('/', async (ctx, next)=> {
ctx.body = await Users.find()
})
router.get('/:_id', async (ctx, next)=> {
let _id = ctx.params._id
ctx.body = await Users.findOne({_id})
})
// 創建用戶
router.post('/', async (ctx, next)=> {
let data = ctx.request.body
ctx.body = await Users.create(data)
})
router.put('/:_id', async (ctx, next)=> {
let _id = ctx.params._id
let data = ctx.request.body
ctx.body = await Users.update({_id}, { $set: data }, {
runValidators: true
})
})
router.delete('/:_id', async (ctx, next)=> {
let _id = ctx.params._id
ctx.body = await Users.deleteOne({_id})
})
這是基本的增查改刪的操作。這裡用到了koa2最大的亮點,就是async
,await
非同步處理方案。只要await 後面返回的是 promise,就可以直接使用。這比在 express 框架上使用 then 方法處理要優雅的多的多。
上一步講的請求參數驗證,是第一層驗證。其實在model操作中,數據進入資料庫時,也會進行一層驗證,就是mongoose的Schema定義的數據類型和欄位,如果不匹配,則會拒絕寫入並返回錯誤。這就是mongoose的好處之一,可以防止寫入不規範的數據。
這裡不做mongoose的詳解,附上文檔地址:mongoose
運行與部署
1. pm2
應用啟動文件是 www/bin
,所以我們可以通過 node www/bin
開啟動應用,預設是9000埠。
這樣啟動會有一個問題,就是在修改代碼之後,程式不會自動運行最新的代碼,需要手動斷開重新啟動。
pm2的誕生就是用來解決這個問題。他是一個nodejs應用程式管理器,通過pm2啟動nodejs應用,開啟監聽模式,它就可以自動監聽文件變化重啟應用。
當然pm2的作用還有很多,首先啟動應用:
pm2 start --name koa2 bin/www --watch
結果如下:
然後可以刪除或重啟:
pm2 list # 查看進程列表
pm2 restart koa2 # 重啟名稱為koa2的應用
pm2 delete koa2 # 刪除名稱為koa2的進程
pm2 logs koa2 # 查看名稱為koa2的進程日誌
2. nginx配置
koa2應用在linux服務端部署,首先需要pm2來啟動應用。但是koa2項目啟動一般不使用80埠,所以線上上部署時,還需要nginx做反向代理以及功能變數名稱配置。
配置如下:
server {
listen 80;
server_name api.xxxxx.com;
location / {
proxy_pass http://127.0.0.1:9000;
#相容scoket.io
proxy_http_version 1.1;
proxy_set_header Upgrade $http_upgrade;
proxy_set_header Connection "upgrade";
proxy_set_header Host $host;
}
}
這樣訪問 api.xxxxx.com 就能訪問koa2的應用了!
如果是https
,需要修改下配置:
server {
listen 80;
server_name api.xxxxx.com;
rewrite ^(.*) https://$host$1 permanent;
}
server {
listen 443 ssl;
server_name api.ruidoc.com;
ssl on;
ssl_certificate 1_api.xxxxx.com_bundle.crt; #ssl證書
ssl_certificate_key 2_api.xxxxx.com.key;
location / {
proxy_pass http://127.0.0.1:9000;
#相容scoket.io
proxy_http_version 1.1;
proxy_set_header Upgrade $http_upgrade;
proxy_set_header Connection "upgrade";
proxy_set_header Host $host;
}
}
此時你可以上傳你的應用了!
3. 快速上傳源碼
一般上傳源碼的時候,可能會用ftp服務之類的。如果是Mac用戶,那麼可以配置一條快捷命令,直接上傳,方便省事
rsync -avz ./* root@1.23.45.67:/home/api
root 是伺服器用戶名;
1.23.45.67 是伺服器IP地址;
/home/api 是源碼在伺服器的存放路徑
然後輸入伺服器密碼,就可以快速上傳了,而且只會上傳修改過的源碼,非常快速。
還可以將命令配置到package.json
文件的scripts下,如
"scripts": {
"upload": "rsync -avz ./* [email protected]:/home/api"
}
此時你可以這樣上傳:
npm run upload
這樣配置上傳效率非常高,一起試試吧!
寫博客能賺錢嗎?如果不賺錢,那這個簽名又有什麼意義!所以大家多多給我發紅包,多多祈禱,祈禱我成為萬元戶,然後普渡眾生!