深入理解 Express.js 中间件与 next 函数：构建高效请求处理流程

const express = require('express');
const app = express();

// 示例中间件函数
const simpleMiddleware = (req, res, next) => {
  console.log('--- 这是一个简单的中间件 ---');
  // 在这里可以处理请求、修改req/res对象等

  // 调用 next() 将控制权传递给下一个中间件或路由处理器
  next(); 
};

app.get('/test', simpleMiddleware, (req, res) => {
  res.send('请求通过中间件并到达路由处理器。');
});

app.listen(3000, () => {
  console.log('Server running on port 3000');
});

const express = require('express');
const app = express();

// 模拟的认证逻辑
function checkAuthentication(req) {
  // 在实际应用中，这里会验证用户会话、JWT token、API Key等
  // 假设我们通过请求头中的 'Authorization' token 来判断用户是否认证
  if (req.headers.authorization && req.headers.authorization.startsWith('Bearer ')) {
    const token = req.headers.authorization.split(' ')[1];
    // 实际中会调用服务验证 token 的有效性，例如：
    // const user = someFunctionToVerifyToken(token);
    // return user; // 返回用户对象
    return { id: 'user123', name: 'Authenticated User' }; // 简化示例，直接返回一个模拟用户
  } else {
    return false; // 未认证
  }
}

// 身份验证中间件
const authMiddleware = (req, res, next) => {
  console.log('--- 执行 authMiddleware ---');
  const isAuthenticated = checkAuthentication(req);

  if (isAuthenticated) {
    // 如果用户已认证，可以将用户信息附加到请求对象上，供后续处理器使用
    req.user = isAuthenticated; 
    console.log('用户已认证，传递控制权。');
    next(); // 用户已认证，继续执行下一个中间件或路由处理器
  } else {
    console.log('用户未认证，终止请求。');
    // 用户未认证，发送 401 Unauthorized 响应并终止请求
    res.status(401).send('Unauthorized: Please provide a valid authentication token.');
  }
};

// 应用身份验证中间件到特定路由
app.get('/protected', authMiddleware, (req, res) => {
  // 只有当 authMiddleware 调用 next() 后，才会执行到这里
  res.send(`欢迎，${req.user.name}！您已访问受保护的路由。`);
});

// 公共路由
app.get('/', (req, res) => {
  res.send('欢迎访问主页，无需认证。');
});

// 启动服务器
app.listen(3000, () => {
  console.log('Server is listening on port 3000');
});

const express = require('express');
const app = express();

// 模拟认证函数
function checkAuthentication(req) {
  return req.headers.authorization === 'Bearer valid_token';
}

// 认证中间件
const authMiddleware = (req, res, next) => {
  if (checkAuthentication(req)) {
    req.user = { id: 'user123', name: 'Authenticated User' }; // 附加用户信息
    next();
  } else {
    res.status(401).send('Unauthorized');
  }
};

// 另一个中间件，用于添加额外数据
const dataMiddleware = (req, res, next) => {
  req.additionalData = { timestamp: new Date().toISOString(), source: 'dataMiddleware' };
  console.log('--- dataMiddleware 添加了数据 ---');
  next();
};

// 第三个中间件，用于日志记录
const loggingMiddleware = (req, res, next) => {
  console.log(`[${new Date().toISOString()}] 请求方法: ${req.method}, 路径: ${req.path}`);
  console.log(`用户数据: ${JSON.stringify(req.user)}`);
  console.log(`附加数据: ${JSON.stringify(req.additionalData)}`);
  next();
};

// 将多个中间件应用于一个路由
app.get('/api/resource', authMiddleware, dataMiddleware, loggingMiddleware, (req, res) => {
  // 所有中间件都已执行，并且数据已附加到 req 对象
  res.json({
    message: '成功访问受保护资源',
    user: req.user,
    details: req.additionalData
  });
});

app.listen(3000, () => {
  console.log('Server running on port 3000');
});