Node.js中多字段多文件上传与MongoDB路径存储：Multer实践指南

<form action="/membershipApplication/Register" method="POST" enctype="multipart/form-data">
    <div>
        <label for="image1">上传图片1</label>
        <input type="file" id="image1" name="image1" accept="image/*">
    </div>
    <div>
        <label for="image2">上传图片2</label>
        <input type="file" id="image2" name="image2" accept="image/*">
    </div>
    <!-- 其他用户注册字段 -->
    <button type="submit">注册</button>
</form>

const path = require('path');
const multer = require('multer');

// 配置磁盘存储引擎
const storage = multer.diskStorage({
    // 确定文件存储的目标文件夹
    destination: (req, file, cb) => {
        if (file.fieldname === 'image1') {
            cb(null, './logic/uploads'); // image1 存储到 uploads 文件夹
        } else if (file.fieldname === 'image2') {
            cb(null, './logic/uploadp'); // image2 存储到 uploadp 文件夹
        } else {
            // 处理其他字段或默认情况
            cb(new Error('Invalid fieldname for file upload'), null);
        }
    },
    // 确定文件中在目标文件夹中的名称
    filename: (req, file, cb) => {
        // 使用原始文件名、时间戳和扩展名来创建唯一文件名
        const uniqueSuffix = Date.now() + '-' + Math.round(Math.random() * 1E9);
        cb(null, file.fieldname + '-' + uniqueSuffix + path.extname(file.originalname));
        console.log(`新图片已保存: ${file.fieldname}-${uniqueSuffix}${path.extname(file.originalname)}`);
    }
});

// 导出配置好的 Multer 实例
module.exports = multer({ storage: storage });

const express = require('express');
const router = express.Router();
const upload = require('../logic/multer'); // 导入 Multer 配置

// 导入用户注册逻辑
const { userSignup, userLogin } = require('../logic/Membership_Application');

// 定义用户注册路由
router.post('/Register',
    upload.fields([
        { name: 'image1', maxCount: 1 }, // 允许 image1 字段上传最多1个文件
        { name: 'image2', maxCount: 1 }, // 允许 image2 字段上传最多1个文件
    ]),
    userSignup // 处理注册逻辑的控制器
);

router.post('/login', userLogin);
module.exports = router;

const Users = require('../models/Users'); // 导入用户模型
const bcrypt = require('bcryptjs'); // 用于密码哈希
const path = require('path'); // 用于构建文件路径，尽管我们这里直接用Multer生成的文件名

exports.userSignup = async (req, res) => {
    try {
        const { name, email, phone, password, nationality } = req.body;

        // 检查文件是否上传成功
        if (!req.files || !req.files['image1'] || !req.files['image2']) {
            return res.status(400).json({ message: '请上传所有必要的图片文件。' });
        }

        // 从 req.files 中获取上传文件的信息
        const image1File = req.files['image1'][0]; // image1 字段的第一个文件
        const image2File = req.files['image2'][0]; // image2 字段的第一个文件

        // 构建文件在服务器上的相对或绝对路径，用于存储到数据库
        // 注意：这里我们存储的是 Multer 保存后的相对路径，方便后续访问
        const img1Path = path.join('/logic/uploads', image1File.filename);
        const img2Path = path.join('/logic/uploadp', image2File.filename);

        // 对密码进行哈希处理
        const hashedPassword = await bcrypt.hash(password, 10);

        // 创建新的用户实例
        const newUser = new Users({
            name,
            email,
            phone,
            password: hashedPassword,
            nationality,
            img: img1Path, // 存储 image1 的文件路径
            img2: img2Path // 存储 image2 的文件路径
        });

        // 保存用户到数据库
        await newUser.save();

        res.status(201).json({ message: '用户注册成功，图片路径已保存！' });

    } catch (error) {
        console.error('用户注册失败:', error);
        res.status(500).json({ message: '服务器错误，注册失败。' });
    }
};

const mongoose = require('mongoose');

// 定义用户Schema
const UsersSchema = new mongoose.Schema({
    name: { type: String, required: true },
    email: { type: String, required: true, unique: true },
    phone: { type: String },
    password: { type: String, required: true },
    nationality: { type: String },
    img: {
        type: String, // 存储 image1 的文件路径
        required: true
    },
    img2: {
        type: String, // 存储 image2 的文件路径
        required: true
    },
    createdAt: { type: Date, default: Date.now }
});

// 创建并导出用户模型
const Users = mongoose.model("Users", UsersSchema);
module.exports = Users;

const express = require('express');
const app = express();
require('dotenv/config'); // 用于加载环境变量，如MongoDB连接字符串

const MembershipApplicationRouter = require('./route/Membership_Application');
const AdminRouter = require('./route/admin'); // 假设有其他路由

var bodyParser = require('body-parser');
const cors = require('cors');
const mongoose = require('mongoose');

// 连接MongoDB数据库
mongoose.connect(process.env.MONGODB_URI || 'mongodb-link', {
    useNewUrlParser: true,
    useUnifiedTopology: true
});
const connection = mongoose.connection;
connection.on('connected', () => { console.log("MongoDB已连接") });
connection.on('error', (err) => { console.error("MongoDB连接错误:", err) });

// 配置Express中间件
app.use(cors()); // 允许跨域请求
app.use(bodyParser.urlencoded({ extended: true })); // 处理URL编码的请求体
app.use(express.json()); // 处理JSON请求体
app.use(express.urlencoded({ extended: true })); // 处理URL编码的请求体

// **重要：配置静态文件服务**
// 使得 /logic/uploads 和 /logic/uploadp 目录下的文件可以通过 URL 访问
app.use('/uploads', express.static(path.join(__dirname, 'logic', 'uploads')));
app.use('/uploadp', express.static(path.join(__dirname, 'logic', 'uploadp')));

// 注册路由
app.use('/admin', AdminRouter);
app.use('/membershipApplication', MembershipApplicationRouter);

// 启动服务器
const port = process.env.PORT || 8080;
app.listen(port, () => {
    console.log(`服务器运行在端口 ${port}`);
});

module.exports = app;