基于Node.js + sharp搭一个图片处理服务器全流程

npm install sharp

const sharp = require('sharp');

async function resizeDemo() {
  await sharp('input.jpg')
    // 只给 width，height 传 null/不传 => 等比缩放，高度自动算
    .resize({ width: 800 })
    .toFile('output.jpg');
}

resizeDemo().catch(console.error);

const sharp = require('sharp');

// inputBuffer 来自上传/下载，outputBuffer 直接塞进 HTTP 响应
async function processBuffer(inputBuffer) {
  const outputBuffer = await sharp(inputBuffer)
    .resize({ width: 800 })
    .jpeg({ quality: 80 })
    .toBuffer();
  return outputBuffer;
}

const sharp = require('sharp');

async function thumbnails(input) {
  // cover：填满 200x200，超出部分裁掉（最常用的头像/封面缩略图）
  await sharp(input)
    .resize(200, 200, { fit: 'cover', position: 'centre' })
    .toFile('cover.jpg');

  // contain：完整装进 200x200，空白处补背景色（不裁剪，会留边）
  await sharp(input)
    .resize(200, 200, {
      fit: 'contain',
      background: { r: 255, g: 255, b: 255, alpha: 1 },
    })
    .toFile('contain.jpg');

  // inside：等比缩到「不超过」200x200，最终尺寸可能小于目标（列表缩略图常用）
  await sharp(input)
    .resize(200, 200, { fit: 'inside', withoutEnlargement: true })
    .toFile('inside.jpg');
}

const sharp = require('sharp');

async function watermark(input, logoPath) {
  return sharp(input)
    .resize({ width: 1200, withoutEnlargement: true })
    .composite([
      {
        input: logoPath,        // 水印图，也可以是 Buffer
        gravity: 'southeast',   // 放右下角
        // blend 默认 'over'；水印图本身带透明度就能实现半透明叠加
      },
    ])
    .jpeg({ quality: 85 })
    .toBuffer();
}

const sharp = require('sharp');

async function textWatermark(input, text) {
  const svg = `
    <svg width="400" height="60">
      <style>
        .t { fill: #ffffff; fill-opacity: 0.75; font-size: 32px;
             font-family: sans-serif; font-weight: 700; }
      </style>
      <text x="10" y="42" class="t">${text}</text>
    </svg>`;

  return sharp(input)
    .composite([
      { input: Buffer.from(svg), gravity: 'southeast' },
    ])
    .toBuffer();
}

const sharp = require('sharp');

async function convert(input) {
  // WebP：兼容性好、编码快，日常首选
  const webp = await sharp(input)
    .webp({ quality: 78 })     // 78~82 是画质/体积的甜点区
    .toBuffer();

  // AVIF：体积更小但编码慢很多，CPU 敏感场景要掂量
  const avif = await sharp(input)
    .avif({ quality: 50, effort: 4 })  // effort 越高越小越慢（0~9）
    .toBuffer();

  // PNG：无损，适合图标/透明图；用 palette 压缩体积
  const png = await sharp(input)
    .png({ compressionLevel: 9, palette: true })
    .toBuffer();

  return { webp, avif, png };
}

const sharp = require('sharp');

async function fixOrientation(input) {
  return sharp(input)
    .rotate()             // 不传角度 => 读 EXIF Orientation 自动摆正
    .resize({ width: 1000 })
    .toBuffer();
}

const express = require('express');
const sharp = require('sharp');
const crypto = require('crypto');

const app = express();

// 简单的内存缓存（生产建议换 Redis / 本地磁盘 / CDN 回源）
const cache = new Map();

// 白名单，避免用户传任意尺寸打爆内存
const ALLOWED_WIDTHS = new Set([100, 200, 400, 800, 1200]);

app.get('/thumb', async (req, res) => {
  try {
    const src = String(req.query.src || '');
    const width = Number(req.query.w) || 400;
    const format = ['webp', 'jpeg', 'png'].includes(req.query.f)
      ? req.query.f : 'webp';

    if (!ALLOWED_WIDTHS.has(width)) {
      return res.status(400).json({ error: 'unsupported width' });
    }

    const key = crypto
      .createHash('sha1')
      .update(`${src}|${width}|${format}`)
      .digest('hex');

    if (cache.has(key)) {
      res.type(`image/${format}`);
      res.set('X-Cache', 'HIT');
      return res.end(cache.get(key));
    }

    // 实际项目里 src 应走白名单/签名，别直接让用户传任意 URL/路径
    const inputBuffer = await loadImage(src);

    let pipeline = sharp(inputBuffer)
      .rotate()
      .resize({ width, withoutEnlargement: true });

    pipeline = format === 'webp'
      ? pipeline.webp({ quality: 80 })
      : format === 'png'
        ? pipeline.png({ compressionLevel: 9 })
        : pipeline.jpeg({ quality: 82 });

    const out = await pipeline.toBuffer();
    cache.set(key, out);

    res.type(`image/${format}`);
    res.set('Cache-Control', 'public, max-age=31536000, immutable');
    res.set('X-Cache', 'MISS');
    res.end(out);
  } catch (err) {
    console.error(err);
    res.status(500).json({ error: 'process failed' });
  }
});

async function loadImage(src) {
  // 从对象存储/本地磁盘/白名单 URL 读取，返回 Buffer
  // 这里省略，务必做来源校验
  throw new Error('implement me');
}

app.listen(3000, () => console.log('image service on :3000'));

const pLimit = require('p-limit');
const sharp = require('sharp');

// 并发上限 = CPU 核数，避免同时解码太多大图导致 OOM
const limit = pLimit(require('os').cpus().length);

// sharp 自身也可以关掉内部并发，把「一张图用几个线程」交给上层控制
sharp.concurrency(1);

async function safeProcess(buffer) {
  return limit(() =>
    sharp(buffer)
      .rotate()
      .resize({ width: 800, withoutEnlargement: true })
      .webp({ quality: 80 })
      .toBuffer()
  );
}