如何在Express.js中使用Multer将图片上传至Google Cloud

没问题！要把图片上传目标从本地文件夹切换到Google Cloud Storage，咱们可以结合@google-cloud/storage SDK和multer来实现，下面是详细步骤和代码修改方案：

1. 安装必要依赖 #

首先安装GCS的官方SDK和multer（如果还没装的话）：

npm install @google-cloud/storage multer

2. 准备GCS配置 #

• 先在Google Cloud控制台创建一个存储桶（Bucket），记住你的桶名称。
• 创建一个服务账号，赋予它存储桶的写入权限（比如Storage Object Creator角色），然后下载服务账号的JSON密钥文件（比如命名为gcs-key.json，注意不要把这个文件提交到版本控制！）。

3. 修改你的Multer配置 #

替换原来的本地磁盘存储逻辑，改成上传到GCS的逻辑：

完整代码示例 #

const multer = require('multer');
const { Storage } = require('@google-cloud/storage');

// 初始化GCS客户端
const gcsClient = new Storage({
  keyFilename: './gcs-key.json', // 你的服务账号密钥文件路径
  projectId: '你的GCP项目ID' // 替换成你的GCP项目ID
});
const bucket = gcsClient.bucket('你的存储桶名称'); // 替换成你的存储桶名

// 使用multer的内存存储（先把文件暂存在内存，再上传到GCS，适合小文件）
const gcsStorage = multer.memoryStorage();

// 配置multer
const upload_image = multer({
  storage: gcsStorage,
  limits: { fileSize: 1024 * 1024 * 5 }, // 限制文件大小为5MB
  fileFilter: (req, file, cb) => {
    // 只允许JPEG和PNG格式
    if (file.mimetype === 'image/jpeg' || file.mimetype === 'image/png') {
      cb(null, true);
    } else {
      cb(new Error('仅支持JPEG和PNG格式的图片'), false);
    }
  }
});

module.exports = upload_image;

4. 在路由中完成GCS上传 #

multer只是帮你接收文件，还需要在路由里把内存中的文件上传到GCS，同时保留你原来的文件名生成逻辑：

// 假设这是你的路由文件
const express = require('express');
const router = express.Router();
const upload_image = require('./你的multer配置文件路径');

router.post('/upload', upload_image.single('image'), async (req, res) => {
  if (!req.file) {
    return res.status(400).send('请选择要上传的图片');
  }

  // 沿用你原来的唯一文件名生成逻辑
  const uniqueSuffix = Date.now() + '-' + Math.round(Math.random() * 1E9);
  const original = req.file.originalname;
  const ext = original.substr(original.length - 5);
  const regex = /[^\w\s]/g;
  const dot = ext.search(regex);
  const fileName = uniqueSuffix + ext.substr(dot);

  // 创建GCS文件对象
  const gcsFile = bucket.file(fileName);

  // 创建写入流，设置文件的内容类型
  const writeStream = gcsFile.createWriteStream({
    metadata: {
      contentType: req.file.mimetype
    },
    resumable: false // 非可恢复上传，适合小文件
  });

  // 处理上传错误
  writeStream.on('error', (err) => {
    return res.status(500).send(`上传到GCS失败：${err.message}`);
  });

  // 上传完成后的处理
  writeStream.on('finish', async () => {
    // 可选：如果需要让文件公开访问，执行下面的代码
    await gcsFile.makePublic();
    // 获取文件的公开URL
    const publicUrl = `https://storage.googleapis.com/${bucket.name}/${fileName}`;

    res.status(200).json({
      message: '上传成功',
      fileUrl: publicUrl
    });
  });

  // 把内存中的文件内容写入GCS流
  writeStream.end(req.file.buffer);
});

module.exports = router;

一些注意事项 #

• 权限配置：确保你的服务账号拥有存储桶的写入权限，否则会上传失败。
• 密钥安全：不要把gcs-key.json提交到Git，建议用环境变量来管理密钥，比如：

  const gcsClient = new Storage({
    credentials: JSON.parse(process.env.GCS_CREDENTIALS),
    projectId: process.env.GCS_PROJECT_ID
  });
  

  然后在环境变量中设置GCS_CREDENTIALS为密钥JSON的字符串，GCS_PROJECT_ID为你的项目ID。
• 大文件处理：如果要上传大文件，建议用multer的磁盘存储先把文件存在本地临时目录，上传到GCS后再删除本地文件，避免内存占用过高。

内容的提问来源于stack exchange，提问作者yokana