mongodb-0

Koa & Express 连接 MongoDB 实战（短网址跳转示例）

本文整理 Koa/Express 框架通过 MongoClient 连接 MongoDB 的完整实现方案，以「短网址跳转」为核心业务场景，覆盖数据库连接、集合查询、响应处理等核心逻辑，保证代码可直接运行且符合生产环境最佳实践。

一、前置准备

1. 安装依赖

# 通用依赖：mongodb 核心驱动
npm install mongodb --save

# Koa 相关依赖（若使用 Koa）
npm install koa koa-router --save

# Express 相关依赖（若使用 Express）
npm install express --save

2. 核心说明

• 使用 MongoDB 官方驱动 MongoClient 而非第三方 ORM，轻量且原生；
• 采用单例模式管理数据库连接（避免每次请求重复创建连接，提升性能）；
• 异步处理数据库操作（async/await），适配 Node.js 异步特性。

二、Koa 连接 MongoDB 实现（完整代码）

const Koa = require('koa');
const Router = require('koa-router');
const { MongoClient } = require('mongodb');

// 1. 初始化 Koa 实例和路由
const app = new Koa();
const router = new Router();

// 2. MongoDB 连接配置（替换为你的 MongoDB 地址，如 mongodb://localhost:27017/your_db）
const MONGODB_URL = 'mongodb://localhost:27017/short_url'; 
// 单例模式：复用 MongoDB 连接（避免每次请求重建连接）
const mongoClientPromise = MongoClient.connect(MONGODB_URL, {
  // 可选：添加连接配置（MongoDB 4.0+ 可省略）
  useNewUrlParser: true,
  useUnifiedTopology: true
});

// 3. 核心业务：短网址跳转接口
router.get('/:id', async (ctx, next) => {
  try {
    // 获取数据库连接实例
    const db = await mongoClientPromise;
    // 操作指定集合（test 为集合名，可替换）
    const collection = db.collection('test');
    // 查询指定短网址 ID 的记录（_id 为短网址唯一标识）
    const shortUrlRecord = await collection.findOne({
      _id: ctx.params.id
    });

    // 4. 响应处理
    if (!shortUrlRecord) {
      // 无匹配记录：返回 404
      ctx.status = 404;
      ctx.body = { code: 404, msg: '短网址不存在' };
    } else {
      // 有匹配记录：重定向到目标 URL
      ctx.redirect(shortUrlRecord.url);
    }
  } catch (err) {
    // 异常处理：返回 500
    ctx.status = 500;
    ctx.body = { code: 500, msg: '服务器错误', error: err.message };
  }
});

// 5. 注册路由并启动服务
app.use(router.routes()).use(router.allowedMethods());
app.listen(3000, () => {
  console.log('Koa 服务启动：http://localhost:3000');
});

三、Express 连接 MongoDB 实现（对应逻辑）

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

// 1. 初始化 Express 实例和路由
const app = express();
const router = express.Router();

// 2. MongoDB 连接配置（同 Koa）
const MONGODB_URL = 'mongodb://localhost:27017/short_url';
const mongoClientPromise = MongoClient.connect(MONGODB_URL, {
  useNewUrlParser: true,
  useUnifiedTopology: true
});

// 3. 核心业务：短网址跳转接口
router.get('/:id', async (req, res) => {
  try {
    const db = await mongoClientPromise;
    const collection = db.collection('test');
    const shortUrlRecord = await collection.findOne({
      _id: req.params.id
    });

    // 4. 响应处理
    if (!shortUrlRecord) {
      res.status(404).json({ code: 404, msg: '短网址不存在' });
    } else {
      res.redirect(shortUrlRecord.url);
    }
  } catch (err) {
    res.status(500).json({ code: 500, msg: '服务器错误', error: err.message });
  }
});

// 5. 注册路由并启动服务
app.use(router);
app.listen(3001, () => {
  console.log('Express 服务启动：http://localhost:3001');
});

四、关键逻辑解析

1. 数据库连接优化

• MongoClient.connect 返回 Promise，提前执行并缓存为 mongoClientPromise，实现连接复用（生产环境禁止每次请求都调用 connect，会导致连接池耗尽）；
• 连接配置中 useNewUrlParser 和 useUnifiedTopology 是兼容 MongoDB 新版本的必要配置（避免控制台警告）。

2. 核心业务逻辑

• 通过 ctx.params.id（Koa）/req.params.id（Express）获取 URL 中的短网址 ID；
• collection.findOne() 异步查询 MongoDB 集合，匹配 _id 字段；
• 无匹配记录返回 404，有记录则通过 redirect 跳转到目标 URL。

3. 异常处理

• 包裹 try/catch 捕获数据库操作异常，避免服务崩溃；
• 异常时返回 500 状态码并携带错误信息，便于排查问题。

五、扩展说明

1. 集合操作扩展：除了 findOne，可根据业务需求使用 insertOne（新增短网址）、updateOne（更新）、deleteOne（删除）等方法；
2. 连接关闭：若服务停止，可通过 db.close() 手动关闭数据库连接；
3. 生产环境优化：
   • 把 MongoDB 地址配置到环境变量（如 process.env.MONGODB_URL），避免硬编码；
   • 添加连接超时配置（connectTimeoutMS: 5000），防止连接阻塞。

总结

1. Koa/Express 连接 MongoDB 的核心是复用 MongoClient 连接，通过 async/await 处理异步操作；
2. 业务逻辑中需区分框架的请求/响应对象（Koa 用 ctx，Express 用 req/res）；
3. 必须添加异常处理和状态码响应，保证服务稳定性。