NodeJs Express中间件使用流程解析

app.get('/',(req,res,next) => {
	next()
})

const vm = function(req,res,next) {
  console.log('这是最简单的中间件函数');
  // 把流转关系转交给下一个中间件或路由
  next()
}

const vm = function(req,res,next) {
  console.log('这是最简单的中间件函数');
  // 把流转关系转交给下一个中间件或路由
  next()
}
app.use(vm)

app.use(function(req,res,next) {
  console.log('调用了第一个中间件');
  next()
})
app.use(function(req,res,next) {
  console.log('调用了第二个中间件');
  next()
})
app.get('/',(req,res) => {
  res.send('OK.')
})

const vm = function(req,res,next) {
  console.log('调用了局部生效的中间件');
  next()
}
app.get('/',vm,(req,res) => {
  res.send('Home Page.')
})
app.get('/user',vm,(req,res) => {
  res.send('User Page.')
})

app.get('/',mw1,mw2,(req,res) => {})
app.get('/',[mw1,mw2],(req,res) => {})

var app = express()
var router = express.Router()
router.use(function(req,res,next) {})

app.get('/',(req,res) => {
	throw new Error('服务器内部发生了错误！')
	res.send('Home Page.')
})

// 定义错误级别的中间件捕获整个项目的异常错误，从而防止程序的崩溃
app.use((err,req,res,next) => {
	res.send('Error：' + err.message)
})

app.post('/user',(req,res) => {
	// 通过 req.body 来接收客户端发送过来的请求体数据
	console.log(req.body)
	res.send('ok')
})

app.use(express.json())
app.post('/user',(req,res) => {
	console.log(req.body)
	res.send('ok')
})

app.post('/user',(req,res) => {
	console.log(req.body)
	res.send('ok')
})

app.use(express.json())
app.post('/user',(req,res) => {
	console.log(req.body)
	res.send('ok')
})

app.use(express.urlencoded({extended:false}))
app.post('/user',(req,res) => {
	console.log(req.body)
	res.send('ok')
})

const parser = require('body-parser')
app.use(parser.urlencoded({extended:false}))

app.use((req,res,next) => {<!--{cke_protected}{C}%3C!%2D%2D%20%2D%2D%3E-->})

app.use((req,res,next) => {
  // 1. 定义一个变量，专门用来存储客户端发送过来的请求体数据
  let str = ''
  // 2. 监听req的data事件
  req.on('data',(chunk) => {
    str += chunk
  })
})

app.use((req,res,next) => {
  let str = ''
  req.on('data',(chunk) => {
    str += chunk
  })
  // 3.监听req的end事件
  req.on('end',() => {
    // 在str中存放的是完整的请求体数据
    console.log(str);
  })
})

const qs = require('querystring')
app.use((req,res,next) => {
  let str = ''
  req.on('data',(chunk) => {
    str += chunk
  })
  req.on('end',() => {
    // 4.把字符串格式的请求体数据解析成对象格式
    const body = qs.parse(str)
    console.log(body)
  })
})

const qs = require('querystring')
app.use((req,res,next) => {
  let str = ''
  req.on('data',(chunk) => {
    str += chunk
  })
  req.on('end',() => {
    const body = qs.parse(str)
    // 5. 将解析出来的请求体对象挂载为 req.body 属性，最后要调用 next() 函数执行后续的业务逻辑
    req.body = body
    next()
  })
})

const qs = require('querystring')
const bodyParser = function(req,res,next) {
  let str = ''
  req.on('data',(chunk) => {
    str += chunk
  })
  req.on('end',() => {
    const body = qs.parse(str)
    req.body = body
    next()
  })
}
module.exports = bodyParser

// 导入自己封装的中间件模块
const customBodyParser = require('./custom-body-parser')
// 将自定义的中间件函数注册为全局可用的中间件
app.use(customBodyParser)