尧图网页设计 
1. Express 连接 MongoDB 踩过的坑为什么本地能跑线上就断Express 连接 MongoDB 这件事说简单也简单mongoose.connect()一行代码就能跑通说复杂也复杂本地开发一切正常部署到线上就开始报MongooseServerSelectionError、connection timeout或者跑着跑着连接数飙到几百然后数据库直接拒绝服务。我见过太多项目在app.js里随手写一句mongoose.connect(mongodb://localhost:27017/test)就完事结果上线后各种诡异问题。这篇文章要解决的核心问题是如何用工程化的方式在 Express 项目里接入 MongoDB覆盖从连接串拼装、连接池参数调优、超时与重试策略、健康检查接口到进程退出时的优雅关闭。整套方案会给出可直接复制的db.js配置文件和.env模板并且附上启动日志、连接数观测方法、断线重连的验证动作让你在本地和线上环境都能一次跑通。适合谁看如果你正在用 Express 写后端 API数据库选了 MongoDB并且希望连接层不是「能跑就行」而是「经得起线上流量」那这篇就是写给你的。我会假设你已经会基本的 Express 路由和 Mongoose 模型定义但连接配置这块我们从零讲透。先明确一个概念MongoDB 官方 Node.js 驱动是mongodb而mongoose是在它之上封装的 ODM对象文档映射。两者底层都走 TCP 连接池。很多人以为mongoose.connect()只是建立一条连接实际上它背后维护的是一个连接池默认maxPoolSize是 100。这个默认值在低配服务器上可能就是灾难——100 个连接乘以几个 Node 进程MongoDB 的maxIncomingConnections默认才 65536但每个连接都占内存连接数过多反而拖慢数据库。所以第一步不是急着写代码而是想清楚你的 Express 进程有几个每个进程需要多少并发数据库操作MongoDB 实例能承受多少连接把这些想明白连接池参数才有意义。下面我们从环境准备开始一步步把连接层搭起来。2. TaoToken 前置准备模型接入与 API Key 获取在正式写数据库连接代码之前先花几分钟把 TaoToken 的接入准备好。TaoToken 是一个大模型 API 聚合平台如果你在 Express 项目里除了 MongoDB 之外还要调用大模型能力比如做智能客服、内容摘要、代码辅助可以直接用它的统一接口省去分别对接多家厂商的麻烦。你需要做三件事第一注册并登录控制台。打开https://taotoken.net/api进入 API 入口或者直接访问控制台https://taotoken.net/console?utm_sourcetaotoken_aicg_blog_endutm_mediumcsdnutm_campaignrewriteutm_contentconsole管理你的项目。第二创建 API Key。在控制台的 API Keys 页面https://taotoken.net/api-keys?utm_sourcetaotoken_aicg_blog_endutm_mediumcsdnutm_campaignrewriteutm_contentapi-keys生成一个密钥复制保存好。这个 Key 就是你调用模型时的凭证格式通常以sk-开头。第三确认你要用的模型 ID。TaoToken 支持多种模型你可以在模型对话页面https://taotoken.net/models?utm_sourcetaotoken_aicg_blog_endutm_mediumcsdnutm_campaignrewriteutm_contentmodels先试聊一下确认模型可用后再写进代码。常见的模型 ID 比如claude-sonnet-4-20250514、gpt-4o等具体以控制台展示为准。如果你打算长期在 Express 项目里做编码类 Agent 或者自动化任务可以了解一下 Coding Planhttps://taotoken.net/coding-plan?utm_sourcetaotoken_aicg_blog_endutm_mediumcsdnutm_campaignrewriteutm_contentcoding-plan它针对代码场景做了优化额度和调用方式更适合开发工作流。接入文档在https://taotoken.net/doc?utm_sourcetaotoken_aicg_blog_endutm_mediumcsdnutm_campaignrewriteutm_contentdoc里面有完整的请求示例和参数说明。如果你用 Claude Code 这类工具可以参考https://taotoken.net/claude-code?utm_sourcetaotoken_aicg_blog_endutm_mediumcsdnutm_campaignrewriteutm_contentclaudecode的接入方式。把这三样东西准备好Base URLhttps://taotoken.net/api、API Key、Model ID。后面在 Express 里调用模型时这三个参数缺一不可。现在回到 MongoDB 连接的正题。3. 可复制配置db.js 与 .env 模板完整拆解这一节是全文的核心给出可以直接复制到项目里的配置文件。先看目录结构假设你的 Express 项目长这样my-express-app/ ├── .env ├── app.js ├── db.js ├── models/ │ └── user.js ├── routes/ │ └── users.js └── package.json先安装依赖npm install mongoose dotenv然后是.env模板把连接串和连接池参数都抽出来不要硬编码在代码里# .env NODE_ENVdevelopment # MongoDB 连接串本地 MONGODB_URImongodb://127.0.0.1:27017/myapp # 线上示例带认证注意特殊字符要 URL 编码 # MONGODB_URImongodb://user:pass%40123mongo.example.com:27017/myapp?authSourceadmin # 连接池参数 MONGO_MAX_POOL_SIZE20 MONGO_MIN_POOL_SIZE2 MONGO_SERVER_SELECTION_TIMEOUT_MS5000 MONGO_SOCKET_TIMEOUT_MS45000 MONGO_CONNECT_TIMEOUT_MS10000 MONGO_HEARTBEAT_FREQUENCY_MS10000 # TaoToken 模型接入可选 TAOTOKEN_BASE_URLhttps://taotoken.net/api TAOTOKEN_API_KEYsk-your-key-here TAOTOKEN_MODELclaude-sonnet-4-20250514注意连接串里的密码如果包含、:、/这些字符必须做 URL 编码否则解析会出错。比如密码是pass123要写成pass%40123。这是线上环境最常见的连接失败原因之一。接下来是db.js这是整个连接层的核心// db.js const mongoose require(mongoose); const { MONGODB_URI, MONGO_MAX_POOL_SIZE 20, MONGO_MIN_POOL_SIZE 2, MONGO_SERVER_SELECTION_TIMEOUT_MS 5000, MONGO_SOCKET_TIMEOUT_MS 45000, MONGO_CONNECT_TIMEOUT_MS 10000, MONGO_HEARTBEAT_FREQUENCY_MS 10000, } process.env; if (!MONGODB_URI) { throw new Error(缺少环境变量 MONGODB_URI请检查 .env 文件); } const options { maxPoolSize: parseInt(MONGO_MAX_POOL_SIZE, 10), minPoolSize: parseInt(MONGO_MIN_POOL_SIZE, 10), serverSelectionTimeoutMS: parseInt(MONGO_SERVER_SELECTION_TIMEOUT_MS, 10), socketTimeoutMS: parseInt(MONGO_SOCKET_TIMEOUT_MS, 10), connectTimeoutMS: parseInt(MONGO_CONNECT_TIMEOUT_MS, 10), heartbeatFrequencyMS: parseInt(MONGO_HEARTBEAT_FREQUENCY_MS, 10), retryWrites: true, retryReads: true, }; let isConnected false; async function connectDB() { if (isConnected) { console.log([db] 已存在连接跳过重复连接); return mongoose.connection; } mongoose.connection.on(connected, () { isConnected true; console.log([db] MongoDB 连接成功); }); mongoose.connection.on(error, (err) { console.error([db] MongoDB 连接错误:, err.message); }); mongoose.connection.on(disconnected, () { isConnected false; console.warn([db] MongoDB 连接断开等待自动重连); }); mongoose.connection.on(reconnected, () { isConnected true; console.log([db] MongoDB 重连成功); }); await mongoose.connect(MONGODB_URI, options); return mongoose.connection; } async function closeDB() { if (!isConnected) return; await mongoose.connection.close(false); isConnected false; console.log([db] MongoDB 连接已优雅关闭); } function getConnectionState() { const states [disconnected, connected, connecting, disconnecting]; return states[mongoose.connection.readyState] || unknown; } module.exports { connectDB, closeDB, getConnectionState, mongoose };这份配置里几个关键点值得展开说。maxPoolSize控制每个 Node 进程最多开多少条连接默认 100 对大多数中小项目偏大设成 20 左右更稳。minPoolSize保持最小空闲连接避免每次请求都重新建连。serverSelectionTimeoutMS是选主超时设 5000 意味着 5 秒内找不到可用节点就报错不要设太大否则请求会一直挂着。socketTimeoutMS是单次操作超时45 秒适合大多数查询。heartbeatFrequencyMS是心跳间隔10 秒一次用来探测节点存活。retryWrites和retryReads开启后驱动会自动重试可重试的错误比如网络抖动导致的失败这对线上稳定性帮助很大。然后在app.js里这样接入// app.js require(dotenv).config(); const express require(express); const { connectDB, closeDB, getConnectionState } require(./db); const app express(); app.use(express.json()); app.get(/health, (req, res) { const state getConnectionState(); res.status(state connected ? 200 : 503).json({ status: state connected ? ok : degraded, db: state, uptime: process.uptime(), }); }); async function start() { await connectDB(); const server app.listen(3000, () { console.log([app] 服务启动监听 3000 端口); }); const shutdown async (signal) { console.log([app] 收到 ${signal}开始优雅关闭); server.close(async () { await closeDB(); process.exit(0); }); setTimeout(() process.exit(1), 10000); }; process.on(SIGTERM, () shutdown(SIGTERM)); process.on(SIGINT, () shutdown(SIGINT)); } start().catch((err) { console.error([app] 启动失败:, err); process.exit(1); });这里把健康检查、优雅关闭、启动流程都串起来了。健康检查接口返回 200 或 503方便负载均衡和容器编排做探针。优雅关闭先停止接收新请求再关闭数据库连接最后退出进程避免请求处理到一半连接被切断。4. 验证请求与成功结果启动日志、连接数观测、断线重连配置写完了怎么确认它真的在工作这一节给出具体的验证动作。先启动服务node app.js正常情况下你会看到这样的日志[db] MongoDB 连接成功 [app] 服务启动监听 3000 端口如果连接失败日志会先打印[db] MongoDB 连接错误: ...然后进程退出。这时候去看错误信息常见的是ECONNREFUSEDMongoDB 没启动或Authentication failed账号密码错。验证健康检查接口curl -i http://localhost:3000/health返回应该是HTTP/1.1 200 OK Content-Type: application/json {status:ok,db:connected,uptime:12.34}接下来观测连接数。在 MongoDB 里执行// 在 mongosh 里运行 db.serverStatus().connections你会看到类似{ current: 5, available: 838855, totalCreated: 12 }的结果。current就是当前连接数。启动 Express 后因为minPoolSize设了 2current至少是 2。发几个请求后current会上升但不会超过maxPoolSize。如果发现current一直涨不降说明有连接泄漏检查是不是有地方手动创建了连接没关闭。验证断线重连手动把 MongoDB 停掉观察 Express 日志[db] MongoDB 连接断开等待自动重连然后重新启动 MongoDB几秒后应该看到[db] MongoDB 重连成功这个过程不需要重启 Express 进程驱动会自动处理。这就是heartbeatFrequencyMS和自动重连机制在起作用。再验证一下优雅关闭。给进程发送 SIGTERMkill -SIGTERM pid日志应该依次打印[app] 收到 SIGTERM开始优雅关闭 [db] MongoDB 连接已优雅关闭然后进程退出。如果你在 MongoDB 里查连接数会发现这个进程的连接都被释放了。最后做一个实际的数据库读写验证。创建一个模型// models/user.js const { mongoose } require(../db); const userSchema new mongoose.Schema({ name: { type: String, required: true }, email: { type: String, required: true, unique: true }, }, { timestamps: true }); module.exports mongoose.model(User, userSchema);加一个路由// routes/users.js const router require(express).Router(); const User require(../models/user); router.post(/, async (req, res) { try { const user await User.create(req.body); res.status(201).json(user); } catch (err) { res.status(400).json({ error: err.message }); } }); router.get(/, async (req, res) { const users await User.find().limit(20); res.json(users); }); module.exports router;请求测试curl -X POST http://localhost:3000/users \ -H Content-Type: application/json \ -d {name:张三,email:zhangsanexample.com}返回 201 和用户数据说明整条链路通了。再 GET 一下确认数据落库。5. 本篇常见错排查401、local proxy failed、reading choices、OAuth这一节对照真实报错给出排查思路。虽然主题是 MongoDB 连接但很多人在 Express 项目里同时接入了模型 API报错容易混淆这里一并说清楚。报错一MongooseServerSelectionError: connect ECONNREFUSED 127.0.0.1:27017这是最基础的错误MongoDB 没启动或者地址不对。先确认 MongoDB 服务在跑# macOS brew services list | grep mongodb # Linux systemctl status mongod如果用的是 Dockerdocker ps | grep mongo地址方面本地开发用127.0.0.1比localhost更稳因为某些系统localhost会解析到 IPv6 的::1而 MongoDB 默认只监听 IPv4。报错二Authentication failed连接串里的用户名密码错了或者authSource没指定。MongoDB 的用户是绑定在某个数据库上的如果用户在admin库创建连接串要加?authSourceadmin。另外密码里的特殊字符必须 URL 编码前面提过。报错三local proxy failed或连接超时这类错误通常出现在调用外部 API 时。如果你在 Express 里调用 TaoToken 的模型接口报local proxy failed先检查TAOTOKEN_BASE_URL是不是写成了https://taotoken.net/api不要多加路径。然后确认 API Key 是否正确请求头格式是const response await fetch(${process.env.TAOTOKEN_BASE_URL}/v1/messages, { method: POST, headers: { Content-Type: application/json, x-api-key: process.env.TAOTOKEN_API_KEY, anthropic-version: 2023-06-01, }, body: JSON.stringify({ model: process.env.TAOTOKEN_MODEL, max_tokens: 1024, messages: [{ role: user, content: 你好 }], }), });注意不同模型的请求格式可能不同Anthropic 系列用x-api-key头OpenAI 系列用Authorization: Bearer。具体看接入文档。报错四401 UnauthorizedAPI Key 无效或过期。去控制台重新生成一个确认复制时没有多余空格。另外检查.env文件有没有被.gitignore忽略别把 Key 提交到仓库。报错五Cannot read properties of undefined (reading choices)这个错误说明你拿到的响应结构和你预期的不一样。通常是请求失败返回了错误对象但代码直接去读response.choices。正确做法是先判断状态码if (!response.ok) { const errText await response.text(); throw new Error(模型请求失败 ${response.status}: ${errText}); } const data await response.json(); const content data.choices?.[0]?.message?.content;报错六OAuth 相关错误如果你用 Claude Code 或其他工具接入遇到 OAuth 报错检查是不是把 API Key 和 OAuth token 混用了。API 调用用 Key工具登录用 OAuth两者不要混。Claude Code 的接入方式参考https://taotoken.net/claude-code?utm_sourcetaotoken_aicg_blog_endutm_mediumcsdnutm_campaignrewriteutm_contentclaudecode。报错七连接数打满connection pool exhaustedmaxPoolSize设太小或者有慢查询占着连接不放。先调大maxPoolSize应急然后去 MongoDB 查慢查询db.currentOp({ secs_running: { $gt: 3 } })找到执行超过 3 秒的操作看看是不是缺索引。6. 语义一致 CTA把连接层和模型能力一起用起来MongoDB 连接层搭好之后你的 Express 项目就有了稳定的数据底座。接下来如果要做智能化功能比如根据用户数据生成摘要、做语义搜索、自动打标签可以直接在同一个项目里接入 TaoToken 的模型能力。具体做法是在.env里配好TAOTOKEN_BASE_URL、TAOTOKEN_API_KEY、TAOTOKEN_MODEL三个参数然后在业务代码里调用。比如给用户数据做摘要async function summarizeUser(user) { const res await fetch(${process.env.TAOTOKEN_BASE_URL}/v1/messages, { method: POST, headers: { Content-Type: application/json, x-api-key: process.env.TAOTOKEN_API_KEY, anthropic-version: 2023-06-01, }, body: JSON.stringify({ model: process.env.TAOTOKEN_MODEL, max_tokens: 512, messages: [{ role: user, content: 请用一句话总结这个用户画像姓名 ${user.name}邮箱 ${user.email}注册时间 ${user.createdAt}, }], }), }); if (!res.ok) throw new Error(模型调用失败: ${res.status}); const data await res.json(); return data.content?.[0]?.text || ; }想先试试模型效果可以去模型对话页面https://taotoken.net/models?utm_sourcetaotoken_aicg_blog_endutm_mediumcsdnutm_campaignrewriteutm_contentmodels直接聊几句确认输出符合预期再写进代码。长期做编码类任务的话Coding Planhttps://taotoken.net/coding-plan?utm_sourcetaotoken_aicg_blog_endutm_mediumcsdnutm_campaignrewriteutm_contentcoding-plan的额度模型更适合开发场景。API Key 在控制台https://taotoken.net/api-keys?utm_sourcetaotoken_aicg_blog_endutm_mediumcsdnutm_campaignrewriteutm_contentapi-keys管理接入细节看文档https://taotoken.net/doc?utm_sourcetaotoken_aicg_blog_endutm_mediumcsdnutm_campaignrewriteutm_contentdoc。把数据库连接和模型调用都封装成独立的模块Express 项目就能同时具备数据持久化和智能处理能力而且两套配置互不干扰排障时也容易定位问题出在哪一层。 Express 连接 MongoDB 数据库：从连接串到连接池的完整配置指南
1. Express 连接 MongoDB 踩过的坑为什么本地能跑线上就断Express 连接 MongoDB 这件事说简单也简单mongoose.connect()一行代码就能跑通说复杂也复杂本地开发一切正常部署到线上就开始报MongooseServerSelectionError、connection timeout或者跑着跑着连接数飙到几百然后数据库直接拒绝服务。我见过太多项目在app.js里随手写一句mongoose.connect(mongodb://localhost:27017/test)就完事结果上线后各种诡异问题。这篇文章要解决的核心问题是如何用工程化的方式在 Express 项目里接入 MongoDB覆盖从连接串拼装、连接池参数调优、超时与重试策略、健康检查接口到进程退出时的优雅关闭。整套方案会给出可直接复制的db.js配置文件和.env模板并且附上启动日志、连接数观测方法、断线重连的验证动作让你在本地和线上环境都能一次跑通。适合谁看如果你正在用 Express 写后端 API数据库选了 MongoDB并且希望连接层不是「能跑就行」而是「经得起线上流量」那这篇就是写给你的。我会假设你已经会基本的 Express 路由和 Mongoose 模型定义但连接配置这块我们从零讲透。先明确一个概念MongoDB 官方 Node.js 驱动是mongodb而mongoose是在它之上封装的 ODM对象文档映射。两者底层都走 TCP 连接池。很多人以为mongoose.connect()只是建立一条连接实际上它背后维护的是一个连接池默认maxPoolSize是 100。这个默认值在低配服务器上可能就是灾难——100 个连接乘以几个 Node 进程MongoDB 的maxIncomingConnections默认才 65536但每个连接都占内存连接数过多反而拖慢数据库。所以第一步不是急着写代码而是想清楚你的 Express 进程有几个每个进程需要多少并发数据库操作MongoDB 实例能承受多少连接把这些想明白连接池参数才有意义。下面我们从环境准备开始一步步把连接层搭起来。2. TaoToken 前置准备模型接入与 API Key 获取在正式写数据库连接代码之前先花几分钟把 TaoToken 的接入准备好。TaoToken 是一个大模型 API 聚合平台如果你在 Express 项目里除了 MongoDB 之外还要调用大模型能力比如做智能客服、内容摘要、代码辅助可以直接用它的统一接口省去分别对接多家厂商的麻烦。你需要做三件事第一注册并登录控制台。打开https://taotoken.net/api进入 API 入口或者直接访问控制台https://taotoken.net/console?utm_sourcetaotoken_aicg_blog_endutm_mediumcsdnutm_campaignrewriteutm_contentconsole管理你的项目。第二创建 API Key。在控制台的 API Keys 页面https://taotoken.net/api-keys?utm_sourcetaotoken_aicg_blog_endutm_mediumcsdnutm_campaignrewriteutm_contentapi-keys生成一个密钥复制保存好。这个 Key 就是你调用模型时的凭证格式通常以sk-开头。第三确认你要用的模型 ID。TaoToken 支持多种模型你可以在模型对话页面https://taotoken.net/models?utm_sourcetaotoken_aicg_blog_endutm_mediumcsdnutm_campaignrewriteutm_contentmodels先试聊一下确认模型可用后再写进代码。常见的模型 ID 比如claude-sonnet-4-20250514、gpt-4o等具体以控制台展示为准。如果你打算长期在 Express 项目里做编码类 Agent 或者自动化任务可以了解一下 Coding Planhttps://taotoken.net/coding-plan?utm_sourcetaotoken_aicg_blog_endutm_mediumcsdnutm_campaignrewriteutm_contentcoding-plan它针对代码场景做了优化额度和调用方式更适合开发工作流。接入文档在https://taotoken.net/doc?utm_sourcetaotoken_aicg_blog_endutm_mediumcsdnutm_campaignrewriteutm_contentdoc里面有完整的请求示例和参数说明。如果你用 Claude Code 这类工具可以参考https://taotoken.net/claude-code?utm_sourcetaotoken_aicg_blog_endutm_mediumcsdnutm_campaignrewriteutm_contentclaudecode的接入方式。把这三样东西准备好Base URLhttps://taotoken.net/api、API Key、Model ID。后面在 Express 里调用模型时这三个参数缺一不可。现在回到 MongoDB 连接的正题。3. 可复制配置db.js 与 .env 模板完整拆解这一节是全文的核心给出可以直接复制到项目里的配置文件。先看目录结构假设你的 Express 项目长这样my-express-app/ ├── .env ├── app.js ├── db.js ├── models/ │ └── user.js ├── routes/ │ └── users.js └── package.json先安装依赖npm install mongoose dotenv然后是.env模板把连接串和连接池参数都抽出来不要硬编码在代码里# .env NODE_ENVdevelopment # MongoDB 连接串本地 MONGODB_URImongodb://127.0.0.1:27017/myapp # 线上示例带认证注意特殊字符要 URL 编码 # MONGODB_URImongodb://user:pass%40123mongo.example.com:27017/myapp?authSourceadmin # 连接池参数 MONGO_MAX_POOL_SIZE20 MONGO_MIN_POOL_SIZE2 MONGO_SERVER_SELECTION_TIMEOUT_MS5000 MONGO_SOCKET_TIMEOUT_MS45000 MONGO_CONNECT_TIMEOUT_MS10000 MONGO_HEARTBEAT_FREQUENCY_MS10000 # TaoToken 模型接入可选 TAOTOKEN_BASE_URLhttps://taotoken.net/api TAOTOKEN_API_KEYsk-your-key-here TAOTOKEN_MODELclaude-sonnet-4-20250514注意连接串里的密码如果包含、:、/这些字符必须做 URL 编码否则解析会出错。比如密码是pass123要写成pass%40123。这是线上环境最常见的连接失败原因之一。接下来是db.js这是整个连接层的核心// db.js const mongoose require(mongoose); const { MONGODB_URI, MONGO_MAX_POOL_SIZE 20, MONGO_MIN_POOL_SIZE 2, MONGO_SERVER_SELECTION_TIMEOUT_MS 5000, MONGO_SOCKET_TIMEOUT_MS 45000, MONGO_CONNECT_TIMEOUT_MS 10000, MONGO_HEARTBEAT_FREQUENCY_MS 10000, } process.env; if (!MONGODB_URI) { throw new Error(缺少环境变量 MONGODB_URI请检查 .env 文件); } const options { maxPoolSize: parseInt(MONGO_MAX_POOL_SIZE, 10), minPoolSize: parseInt(MONGO_MIN_POOL_SIZE, 10), serverSelectionTimeoutMS: parseInt(MONGO_SERVER_SELECTION_TIMEOUT_MS, 10), socketTimeoutMS: parseInt(MONGO_SOCKET_TIMEOUT_MS, 10), connectTimeoutMS: parseInt(MONGO_CONNECT_TIMEOUT_MS, 10), heartbeatFrequencyMS: parseInt(MONGO_HEARTBEAT_FREQUENCY_MS, 10), retryWrites: true, retryReads: true, }; let isConnected false; async function connectDB() { if (isConnected) { console.log([db] 已存在连接跳过重复连接); return mongoose.connection; } mongoose.connection.on(connected, () { isConnected true; console.log([db] MongoDB 连接成功); }); mongoose.connection.on(error, (err) { console.error([db] MongoDB 连接错误:, err.message); }); mongoose.connection.on(disconnected, () { isConnected false; console.warn([db] MongoDB 连接断开等待自动重连); }); mongoose.connection.on(reconnected, () { isConnected true; console.log([db] MongoDB 重连成功); }); await mongoose.connect(MONGODB_URI, options); return mongoose.connection; } async function closeDB() { if (!isConnected) return; await mongoose.connection.close(false); isConnected false; console.log([db] MongoDB 连接已优雅关闭); } function getConnectionState() { const states [disconnected, connected, connecting, disconnecting]; return states[mongoose.connection.readyState] || unknown; } module.exports { connectDB, closeDB, getConnectionState, mongoose };这份配置里几个关键点值得展开说。maxPoolSize控制每个 Node 进程最多开多少条连接默认 100 对大多数中小项目偏大设成 20 左右更稳。minPoolSize保持最小空闲连接避免每次请求都重新建连。serverSelectionTimeoutMS是选主超时设 5000 意味着 5 秒内找不到可用节点就报错不要设太大否则请求会一直挂着。socketTimeoutMS是单次操作超时45 秒适合大多数查询。heartbeatFrequencyMS是心跳间隔10 秒一次用来探测节点存活。retryWrites和retryReads开启后驱动会自动重试可重试的错误比如网络抖动导致的失败这对线上稳定性帮助很大。然后在app.js里这样接入// app.js require(dotenv).config(); const express require(express); const { connectDB, closeDB, getConnectionState } require(./db); const app express(); app.use(express.json()); app.get(/health, (req, res) { const state getConnectionState(); res.status(state connected ? 200 : 503).json({ status: state connected ? ok : degraded, db: state, uptime: process.uptime(), }); }); async function start() { await connectDB(); const server app.listen(3000, () { console.log([app] 服务启动监听 3000 端口); }); const shutdown async (signal) { console.log([app] 收到 ${signal}开始优雅关闭); server.close(async () { await closeDB(); process.exit(0); }); setTimeout(() process.exit(1), 10000); }; process.on(SIGTERM, () shutdown(SIGTERM)); process.on(SIGINT, () shutdown(SIGINT)); } start().catch((err) { console.error([app] 启动失败:, err); process.exit(1); });这里把健康检查、优雅关闭、启动流程都串起来了。健康检查接口返回 200 或 503方便负载均衡和容器编排做探针。优雅关闭先停止接收新请求再关闭数据库连接最后退出进程避免请求处理到一半连接被切断。4. 验证请求与成功结果启动日志、连接数观测、断线重连配置写完了怎么确认它真的在工作这一节给出具体的验证动作。先启动服务node app.js正常情况下你会看到这样的日志[db] MongoDB 连接成功 [app] 服务启动监听 3000 端口如果连接失败日志会先打印[db] MongoDB 连接错误: ...然后进程退出。这时候去看错误信息常见的是ECONNREFUSEDMongoDB 没启动或Authentication failed账号密码错。验证健康检查接口curl -i http://localhost:3000/health返回应该是HTTP/1.1 200 OK Content-Type: application/json {status:ok,db:connected,uptime:12.34}接下来观测连接数。在 MongoDB 里执行// 在 mongosh 里运行 db.serverStatus().connections你会看到类似{ current: 5, available: 838855, totalCreated: 12 }的结果。current就是当前连接数。启动 Express 后因为minPoolSize设了 2current至少是 2。发几个请求后current会上升但不会超过maxPoolSize。如果发现current一直涨不降说明有连接泄漏检查是不是有地方手动创建了连接没关闭。验证断线重连手动把 MongoDB 停掉观察 Express 日志[db] MongoDB 连接断开等待自动重连然后重新启动 MongoDB几秒后应该看到[db] MongoDB 重连成功这个过程不需要重启 Express 进程驱动会自动处理。这就是heartbeatFrequencyMS和自动重连机制在起作用。再验证一下优雅关闭。给进程发送 SIGTERMkill -SIGTERM pid日志应该依次打印[app] 收到 SIGTERM开始优雅关闭 [db] MongoDB 连接已优雅关闭然后进程退出。如果你在 MongoDB 里查连接数会发现这个进程的连接都被释放了。最后做一个实际的数据库读写验证。创建一个模型// models/user.js const { mongoose } require(../db); const userSchema new mongoose.Schema({ name: { type: String, required: true }, email: { type: String, required: true, unique: true }, }, { timestamps: true }); module.exports mongoose.model(User, userSchema);加一个路由// routes/users.js const router require(express).Router(); const User require(../models/user); router.post(/, async (req, res) { try { const user await User.create(req.body); res.status(201).json(user); } catch (err) { res.status(400).json({ error: err.message }); } }); router.get(/, async (req, res) { const users await User.find().limit(20); res.json(users); }); module.exports router;请求测试curl -X POST http://localhost:3000/users \ -H Content-Type: application/json \ -d {name:张三,email:zhangsanexample.com}返回 201 和用户数据说明整条链路通了。再 GET 一下确认数据落库。5. 本篇常见错排查401、local proxy failed、reading choices、OAuth这一节对照真实报错给出排查思路。虽然主题是 MongoDB 连接但很多人在 Express 项目里同时接入了模型 API报错容易混淆这里一并说清楚。报错一MongooseServerSelectionError: connect ECONNREFUSED 127.0.0.1:27017这是最基础的错误MongoDB 没启动或者地址不对。先确认 MongoDB 服务在跑# macOS brew services list | grep mongodb # Linux systemctl status mongod如果用的是 Dockerdocker ps | grep mongo地址方面本地开发用127.0.0.1比localhost更稳因为某些系统localhost会解析到 IPv6 的::1而 MongoDB 默认只监听 IPv4。报错二Authentication failed连接串里的用户名密码错了或者authSource没指定。MongoDB 的用户是绑定在某个数据库上的如果用户在admin库创建连接串要加?authSourceadmin。另外密码里的特殊字符必须 URL 编码前面提过。报错三local proxy failed或连接超时这类错误通常出现在调用外部 API 时。如果你在 Express 里调用 TaoToken 的模型接口报local proxy failed先检查TAOTOKEN_BASE_URL是不是写成了https://taotoken.net/api不要多加路径。然后确认 API Key 是否正确请求头格式是const response await fetch(${process.env.TAOTOKEN_BASE_URL}/v1/messages, { method: POST, headers: { Content-Type: application/json, x-api-key: process.env.TAOTOKEN_API_KEY, anthropic-version: 2023-06-01, }, body: JSON.stringify({ model: process.env.TAOTOKEN_MODEL, max_tokens: 1024, messages: [{ role: user, content: 你好 }], }), });注意不同模型的请求格式可能不同Anthropic 系列用x-api-key头OpenAI 系列用Authorization: Bearer。具体看接入文档。报错四401 UnauthorizedAPI Key 无效或过期。去控制台重新生成一个确认复制时没有多余空格。另外检查.env文件有没有被.gitignore忽略别把 Key 提交到仓库。报错五Cannot read properties of undefined (reading choices)这个错误说明你拿到的响应结构和你预期的不一样。通常是请求失败返回了错误对象但代码直接去读response.choices。正确做法是先判断状态码if (!response.ok) { const errText await response.text(); throw new Error(模型请求失败 ${response.status}: ${errText}); } const data await response.json(); const content data.choices?.[0]?.message?.content;报错六OAuth 相关错误如果你用 Claude Code 或其他工具接入遇到 OAuth 报错检查是不是把 API Key 和 OAuth token 混用了。API 调用用 Key工具登录用 OAuth两者不要混。Claude Code 的接入方式参考https://taotoken.net/claude-code?utm_sourcetaotoken_aicg_blog_endutm_mediumcsdnutm_campaignrewriteutm_contentclaudecode。报错七连接数打满connection pool exhaustedmaxPoolSize设太小或者有慢查询占着连接不放。先调大maxPoolSize应急然后去 MongoDB 查慢查询db.currentOp({ secs_running: { $gt: 3 } })找到执行超过 3 秒的操作看看是不是缺索引。6. 语义一致 CTA把连接层和模型能力一起用起来MongoDB 连接层搭好之后你的 Express 项目就有了稳定的数据底座。接下来如果要做智能化功能比如根据用户数据生成摘要、做语义搜索、自动打标签可以直接在同一个项目里接入 TaoToken 的模型能力。具体做法是在.env里配好TAOTOKEN_BASE_URL、TAOTOKEN_API_KEY、TAOTOKEN_MODEL三个参数然后在业务代码里调用。比如给用户数据做摘要async function summarizeUser(user) { const res await fetch(${process.env.TAOTOKEN_BASE_URL}/v1/messages, { method: POST, headers: { Content-Type: application/json, x-api-key: process.env.TAOTOKEN_API_KEY, anthropic-version: 2023-06-01, }, body: JSON.stringify({ model: process.env.TAOTOKEN_MODEL, max_tokens: 512, messages: [{ role: user, content: 请用一句话总结这个用户画像姓名 ${user.name}邮箱 ${user.email}注册时间 ${user.createdAt}, }], }), }); if (!res.ok) throw new Error(模型调用失败: ${res.status}); const data await res.json(); return data.content?.[0]?.text || ; }想先试试模型效果可以去模型对话页面https://taotoken.net/models?utm_sourcetaotoken_aicg_blog_endutm_mediumcsdnutm_campaignrewriteutm_contentmodels直接聊几句确认输出符合预期再写进代码。长期做编码类任务的话Coding Planhttps://taotoken.net/coding-plan?utm_sourcetaotoken_aicg_blog_endutm_mediumcsdnutm_campaignrewriteutm_contentcoding-plan的额度模型更适合开发场景。API Key 在控制台https://taotoken.net/api-keys?utm_sourcetaotoken_aicg_blog_endutm_mediumcsdnutm_campaignrewriteutm_contentapi-keys管理接入细节看文档https://taotoken.net/doc?utm_sourcetaotoken_aicg_blog_endutm_mediumcsdnutm_campaignrewriteutm_contentdoc。把数据库连接和模型调用都封装成独立的模块Express 项目就能同时具备数据持久化和智能处理能力而且两套配置互不干扰排障时也容易定位问题出在哪一层。