如何在mongodb中存储下载文件的本地url

const express = require('express');
const multer = require('multer');
const { MongoClient } = require('mongodb');

const app = express();
const upload = multer({ dest: 'uploads/' });

// MongoDB连接字符串
const mongoURI = 'mongodb://localhost:27017';
const dbName = 'fileStorage';

// 上传文件的路由
app.post('/upload', upload.single('file'), async (req, res) => {
  try {
    // 创建一个MongoDB客户端
    const client = new MongoClient(mongoURI);

    // 连接到MongoDB服务器
    await client.connect();

    // 获取数据库和集合
    const db = client.db(dbName);
    const collection = db.collection('files');

    // 生成唯一的文件名
    const uniqueFileName = `${Date.now()}-${req.file.originalname}`;

    // 将文件信息插入到MongoDB集合中
    await collection.insertOne({
      filename: req.file.originalname,
      filetype: req.file.mimetype,
      filesize: req.file.size,
      url: `http://localhost:3000/download/${uniqueFileName}` // 本地URL
    });

    res.send('文件上传成功！');
  } catch (error) {
    console.error(error);
    res.status(500).send('文件上传失败！');
  } finally {
    // 关闭MongoDB客户端连接
    client.close();
  }
});

// 下载文件的路由
app.get('/download/:filename', async (req, res) => {
  try {
    // 创建一个MongoDB客户端
    const client = new MongoClient(mongoURI);

    // 连接到MongoDB服务器
    await client.connect();

    // 获取数据库和集合
    const db = client.db(dbName);
    const collection = db.collection('files');

    // 根据文件名检索文件的本地URL
    const file = await collection.findOne({ url: `http://localhost:3000/download/${req.params.filename}` });

    if (!file) {
      res.status(404).send('文件不存在！');
      return;
    }

    // 提供文件的本地URL给用户下载
    res.redirect(file.url);
  } catch (error) {
    console.error(error);
    res.status(500).send('文件下载失败！');
  } finally {
    // 关闭MongoDB客户端连接
    client.close();
  }
});

// 启动服务器
app.listen(3000, () => {
  console.log('服务器已启动，监听端口3000');
});