当前位置：首页 > wzjs >正文

万江做网站北京网络营销培训

wzjs 2025/9/12 14:02:50

万江做网站,北京网络营销培训,wordpress 段落显示不全,网站设计自学在 Web 开发中，请求参数处理与数据校验是保障系统稳定性的第一道防线。本文将深入探讨 Egg.js 框架中参数处理的完整解决方案，涵盖常规参数获取、高效校验方案、文件流处理等核心功能，并分享企业级项目中的最佳实践。一、多场景参数获取策略…

在 Web 开发中，请求参数处理与数据校验是保障系统稳定性的第一道防线。本文将深入探讨 Egg.js 框架中参数处理的完整解决方案，涵盖常规参数获取、高效校验方案、文件流处理等核心功能，并分享企业级项目中的最佳实践。

在这里插入图片描述

一、多场景参数获取策略

1. Query 参数处理

适用于 URL 中的查询参数，通过 ctx.query 直接获取：

// GET /api/users?type=admin&page=2
async list() {const { ctx } = this;const { type = 'user', page = 1 } = ctx.query;ctx.body = await ctx.service.user.list({type: type.trim(),page: Number(page)});
}

注意点：

自动完成 URL decoding
参数值始终为字符串类型
使用解构设置默认值

2. Params 路由参数

通过路由占位符获取参数：

// router.js
router.get('/api/users/:id', controller.user.show);// controller
async show() {const { ctx } = this;const user = await ctx.service.user.find(ctx.params.id);if (!user) {ctx.throw(404, '用户不存在');}ctx.body = user;
}

3. Body 请求体处理

处理 POST/PUT 请求的请求体数据：

// config/config.default.js
exports.bodyParser = {jsonLimit: '10mb',formLimit: '10mb'
};// controller
async create() {const { ctx } = this;const { name, email } = ctx.request.body;const user = await ctx.service.user.create({name: ctx.helper.escape(name),email: email.toLowerCase()});ctx.body = user;
}

安全建议：

始终对用户输入进行转义处理
使用 ctx.validate() 验证请求类型
敏感字段需二次验证

二、数据校验强化方案

1. 安装与配置校验插件

$ npm install egg-validate --save

// config/plugin.js
exports.validate = {enable: true,package: 'egg-validate'
};

2. 基础校验实践

async create() {const { ctx } = this;ctx.validate({username: { type: 'string', required: true },password: { type: 'password', compare: 're_password' },email: { type: 'email', allowEmpty: true },age: { type: 'number', min: 18, max: 60 }});// 业务逻辑
}

3. 校验规则扩展

支持以下校验类型：

基础类型：string, number, int, float
格式验证：email, url, ip
特殊规则：date, datetime, enum
复杂校验：object, array

4. 扩展校验规则

// app.js
app.validator.addRule('mobile', (rule, value) => {const regex = /^1[3-9]\d{9}$/;if (!regex.test(value)) {return '手机号格式错误';}
});// 使用自定义规则
ctx.validate({phone: { type: 'mobile', required: true }
});

5. 统一错误处理

// app/middleware/error_handler.js
module.exports = () => async (ctx, next) => {try {await next();} catch (err) {ctx.status = err.status || 500;ctx.body = {code: ctx.status,message: err.message,details: err.errors || []};}
};// config/config.default.js
config.middleware = ['errorHandler'];

三、文件上传进阶技巧

1. 基础文件上传

// config/config.default.js
exports.multipart = {mode: 'file',fileSize: '50mb',whitelist: ['.png', '.jpg', '.gif']// whitelist也可以配置为如下方式fileExtensions: [".png", ".jpg", ".gif"]
};// app/controller
async upload() {const { ctx } = this;const stream = await ctx.getFileStream();ctx.body = await ctx.service.upload.save(stream);
}// app/service
const sendToWormhole = require('stream-wormhole');async save(stream, obj) {const { ctx } = this;try {// 创建上传目录const uploadDir = this.createUploadDir();// 生成唯一文件名const filename = `${crypto.randomUUID()}${path.extname(stream.filename)}`;const target = path.join(uploadDir, filename);// 写入文件const writeStream = fs.createWriteStream(target);stream.pipe(writeStream);// 等待写入完成await new Promise((resolve, reject) => {writeStream.on('finish', resolve);writeStream.on('error', reject);});// 返回结果return {code: 200,data: {originalName: stream.filename,fileName: filename,size: stream.bytesRead,url: `/files/${filename}`,formData: stream.fields // 其他表单字段}};} catch (err) {// 销毁未消费的流await sendToWormhole(stream);ctx.throw(500, `文件上传失败: ${err.message}`);}
}// 创建上传目录（按日期分类）
createUploadDir() {const dir = path.join(this.app.config.baseDir,'app/public/uploads',dayjs().format('YYYY-MM-DD'));if (!fs.existsSync(dir)) {fs.mkdirSync(dir, { recursive: true });}return dir;
}

2. 大文件流式处理

const sendToWormhole = require('stream-wormhole');async upload() {const stream = await ctx.getFileStream();try {// 上传到云存储const result = await cloudStorage.upload(stream);return { url: result.url };} catch (err) {// 销毁未消费的流await sendToWormhole(stream);ctx.throw(500, '上传失败');}
}

3. 文件错误处理中间件

app/middleware/error_handler.jsmodule.exports = () => async (ctx, next) => {try {await next();} catch (err) {if (err.code === 'LIMIT_FILE_SIZE') {ctx.status = 413;ctx.body = { error: '文件大小超过限制' };} else if (err.code === 'INVALID_FILE_TYPE') {ctx.status = 415;ctx.body = { error: '不支持的文件类型' };} else {ctx.status = err.status || 500;ctx.body = { error: err.message };}}
};