独立开发痛点：用极简 Node.js 后端 + SQLite 三天搞定 AI 工具的付费与用户授权系统

独立开发痛点：用极简 Node.js 后端 + SQLite 三天搞定 AI 工具的付费与用户授权系统

前言

很多独立产品死在了上线前的最后一公里。

有些开发者做出了很酷的 AI 工具，却被繁琐的用户注册、数据库配置、API 密钥（API Key）授权以及扣费计费系统折腾得筋疲力尽。

租用昂贵的 RDS 云数据库，不仅增加了月度运营成本，还要防范复杂的网络配置。

其实，对于日活几万人的独立产品来说，用 Node.js 搭配轻量级 SQLite 本地数据库，配合精简的计费逻辑，三天就能搞定全套付费授权系统。

这篇我将分享这套极致省钱、性能足够强劲的全栈落地方案。

一、底层原理

1.1 核心机制

AI 工具的核心商业模式通常是：用户付费购买 Token 额度，每次调用扣除对应的余额。

graph TD
A["客户端请求 AI 接口"] –> B["请求头携带 API 密钥"]
B –> C["Node.js 授权中间件"]
C –> D{"查询 SQLite: 密钥是否存在？"}
D –>|否| E["拦截并返回 401 未授权"]
D –>|是| F{"查询账户余额: 余额是否足够？"}
F –>|否| G["拦截并返回 402 余额不足"]
F –>|是| H["允许访问大模型接口"]
H –> I["大模型返回数据并统计实际 Token 消耗"]
I –> J["SQLite 事务: 扣减余额并记录流水"]

这套极简系统主要依靠两个支柱：

• SQLite 数据库：它只是一个本地磁盘文件。零运维，读性能极高。
• 高并发事务（Transaction）：由于可能存在同一个用户在多个浏览器窗口同时调用接口的情况，我们必须使用数据库事务，防止余额发生超扣或负数。

1.2 方案对比：云数据库 VS 本地 SQLite

二、快速上手

2.1 依赖准备

我们新建一个极简的 Express 项目，引入 better-sqlite3（它是目前 Node.js 环境下性能最好、最稳定的 SQLite 同步驱动包）。

# 安装 Web 框架和 SQLite 驱动
npm install express better-sqlite3

2.2 数据库初始化

我们创建一个 database.js 文件，用于初始化数据库表结构，并写入模拟的付费测试用户数据。

const sqlite3 = require('better-sqlite3');
const 路径 = require('path');

// 创建或读取本地数据库文件
const 数据库 = new sqlite3(路径.join(__dirname, 'ai_billing.db'), {
verbose: console.log // 打印所有 SQL 执行历史，方便排错
});

// 初始化数据表
数据库.exec(`
CREATE TABLE IF NOT EXISTS 账户 (
用户ID INTEGER PRIMARY KEY AUTOINCREMENT,
密钥 TEXT UNIQUE NOT NULL,
账户余额 INTEGER DEFAULT 10000, — 默认赠送 10000 个 Token
注册时间 DATETIME DEFAULT CURRENT_TIMESTAMP
);

CREATE TABLE IF NOT EXISTS 消费账单 (
账单ID INTEGER PRIMARY KEY AUTOINCREMENT,
用户ID INTEGER NOT NULL,
消耗额度 INTEGER NOT NULL,
消费时刻 DATETIME DEFAULT CURRENT_TIMESTAMP
);
`);

// 插入模拟的测试付费用户
const 插入账户 = 数据库.prepare('INSERT OR IGNORE INTO 账户 (密钥, 账户余额) VALUES (?, ?)');
插入账户.run('测试密钥-123456', 50000); // 注入一个存了 5 万额度的密钥

module.exports = 数据库;

三、核心 API 与深水区

3.1 授权与额度校验中间件

在允许用户调用昂贵的大模型 API 之前，我们编写一个 Express 中间件，进行签名合法性验证和余额水位预检。

const 数据库 = require('./database');

function 校验付费状态(请求, 响应, 下一步) {
const 用户密钥 = 请求.headers['authorization'];
if (!用户密钥) {
return 响应.status(401).json({ 错误: '未提供授权密钥' });
}

// 1. 预读账户状态
const 账户 = 数据库.prepare('SELECT 用户ID, 账户余额 FROM 账户 WHERE 密钥 = ?').get(用户密钥);

if (!账户) {
return 响应.status(401).json({ 错误: '密钥不存在或已被禁用' });
}

if (账户.账户余额 <= 0) {
return 响应.status(402).json({ 错误: '额度已耗尽，请充值' });
}

// 将账户信息挂载在请求上，供后续调用
请求.当前用户 = 账户;
下一步();
}

3.2 扣减余额的高并发事务处理

大模型接口响应完毕后，我们拿到真实的 Token 消耗量。我们必须保证账户扣减和账单流水写入是一个原子操作。

// 定义原子扣费事务
const 扣费事务 = 数据库.transaction((用户ID, 扣减额度) => {
// 1. 扣减余额
const 扣余额结果 = 数据库.prepare(`
UPDATE 账户
SET 账户余额 = 账户余额 – ?
WHERE 用户ID = ? AND 账户余额 >= ?
`).run(扣减额度, 用户ID, 扣减额度);

// 如果受影响行数为 0，说明余额不足或用户不存在，主动回滚
if (扣余额结果.changes === 0) {
throw new Error('余额扣减失败：账户余额不足');
}

// 2. 插入消费日志
数据库.prepare(`
INSERT INTO 消费账单 (用户ID, 消耗额度)
VALUES (?, ?)
`).run(用户ID, 扣减额度);

return true;
});

四、实战演练

现在，我们编写一个 Express 接口服务，将中间件和扣费事务融为一体。

const express = require('express');
const 数据库 = require('./database');
const { 扣费事务 } = require('./database'); // 我们把事务挂载在导出中

const 应用 = express();
应用.use(express.json());

// 模拟调用大模型并且扣费的 API
应用.post('/api/call-ai', 校验付费状态, (请求, 响应) => {
const { 用户ID } = 请求.current用户;
const { 提示内容 } = 请求.body;

if (!提示内容) {
return 响应.status(400).json({ 错误: '缺少提示词内容' });
}

try {
// 1. 模拟调用大模型所消耗的 Token 数量
// 实际场景中，这来自大模型 API 返回的 usage.total_tokens
const 模拟大模型消耗 = Math.floor(Math.random() * 500) + 100;

// 2. 执行扣费事务
数据库.transaction(() => {
// 检查当前实时余额是否支持本次扣费
const 实时账户 = 数据库.prepare('SELECT 账户余额 FROM 账户 WHERE 用户ID = ?').get(用户ID);
if (实时账户.账户余额 < 模拟大模型消耗) {
throw new Error('余额不足');
}

// 执行扣减
数据库.prepare('UPDATE 账户 SET 账户余额 = 账户余额 – ? WHERE 用户ID = ?').run(模拟大模型消耗, 用户ID);
数据库.prepare('INSERT INTO 消费账单 (用户ID, 消耗额度) VALUES (?, ?)').run(用户ID, 模拟大模型消耗);
})();

// 3. 获取更新后的余额并反馈
const 更新后账户 = 数据库.prepare('SELECT 账户余额 FROM 账户 WHERE 用户ID = ?').get(用户ID);

响应.json({
提示: '大模型调用成功',
本次消费: 模拟大模型消耗,
剩余额度: 更新后账户.账户余额,
回复内容: `这是针对“${提示内容}”的模拟AI回复，感觉生活很美好。`
});

} catch (异常) {
响应.status(400).json({ 错误: 异常.message });
}
});

应用.listen(3000, () => {
console.log('极简计费服务已在 3000 端口启动');
});

五、避坑指南

5.1 数据库被锁死 (SQLite Busy Error)

⚠️ 问题表现：在高并发写入时，多个事务同时尝试锁定 SQLite 文件，会导致系统抛出 SqliteError: database is locked 错误。

✅ 解决方案：SQLite 支持在连接时配置 busy_timeout。当文件被锁时，它会自动等待锁释放，而不会直接抛错报错。建议将其设置为 5 秒（5000 毫秒）：

const 数据库 = new sqlite3('ai_billing.db', {
timeout: 5000 // 自动重试锁定的等待时间
});

5.2 磁盘损坏与备份

⚠️ 数据丢失风险：SQLite 是一个物理文件。一旦服务器硬件损坏，所有用户余额和账单都会化为泡影。

✅ 解决方案：不需要复杂的备份引擎。我们只需要写一个定时脚本，在每天凌晨 4 点，利用 SQLite 原生的 .backup 命令生成一个干净的快照包，并推送到阿里云 OSS 或 AWS S3 对象存储中即可，完全是免费的方案。

六、总结

好的独立产品，应该把技术做轻，把商业模型做纯粹。

用 Node.js 加上本地 SQLite 文件数据库，不但彻底干掉了高昂的数据库租赁成本，更把架构复杂度降到了极致。

与其花几个星期去搭建复杂的 Kubernetes、连接池和多租户 RDS，不如花三天时间把这个极简方案拼装出来。

毕竟，早点上线，让用户早点掏钱，才是独立开发者的唯一准则。