ChatGPT保存记录插件开发指南：从零构建到生产环境部署

1次阅读

没有评论

共计 2540 个字符，预计需要花费 7 分钟才能阅读完成。

ChatGPT 原生会话存在两个关键限制：

对话历史仅保留在当前会话窗口，关闭后无法追溯
企业级应用需要审计合规，原始日志缺乏结构化存储

这导致以下典型场景难以实现：

客户服务对话的质检复盘
跨部门知识共享
长期对话的连续性维护

LocalStorage
优点：零延迟，无需后端
缺点：5MB 容量限制，同源策略约束
IndexedDB
优点：支持事务操作，存储量更大
缺点：复杂查询能力弱

Firebase Realtime DB
适合：快速原型开发
注意：无 SQL 查询能力，按连接数计费
MongoDB Atlas
优势：文档结构灵活，适合对话树存储
成本：集群部署需要运维投入

推荐组合 ：前端 IndexedDB 做离线缓存 + MongoDB 持久化

// server.ts
import express from 'express';
import {ChatGPTPlugin} from './plugin';

const app = express();
app.use(express.json());

const plugin = new ChatGPTPlugin({
  openaiKey: process.env.OPENAI_KEY,
  mongoURI: 'mongodb+srv://<user>:<pass>@cluster.mongodb.net/chatlogs'
});

app.post('/api/save', plugin.authMiddleware, plugin.saveHandler);
app.get('/api/history', plugin.authMiddleware, plugin.historyHandler);

app.listen(3000, () => {console.log('Plugin running on port 3000');
});

// queues.ts
import {Queue, Worker} from 'bullmq';
import {saveToMongo} from './db';

const saveQueue = new Queue('chatSave', {
  connection: {
    host: 'redis',
    port: 6379
  }
});

new Worker('chatSave', async job => {const { conversationId, messages} = job.data;
  await saveToMongo({
    _id: conversationId,
    chunks: splitMessages(messages) // 分块处理
  });
}, {
  limiter: {
    max: 1000, // 每秒最大任务数
    duration: 1000
  }
});

// auth.ts
import jwt from 'jsonwebtoken';
import {RequestHandler} from 'express';

const JWT_SECRET = process.env.JWT_SECRET || 'plugin_secret';

export const authMiddleware: RequestHandler = (req, res, next) => {
  try {const token = req.headers.authorization?.split(' ')[1];
    if (!token) throw new Error('Missing token');

    const decoded = jwt.verify(token, JWT_SECRET) as {
      userId: string;
      exp: number;
    };

    req.userId = decoded.userId;
    next();} catch (err) {res.status(401).json({error: 'Invalid token'});
  }
};

按对话轮次切分：每 5 组 Q &A 作为一个 chunk

元数据独立索引：

// db/schema.ts
interface ConversationChunk {
  _id: string; // chunkId
  conversationId: string;
  sequence: number;
  tokens: number;
  createdAt: Date;
  messages: Array<{
    role: 'user' | 'assistant';
    content: string;
  }>;
}

客户端携带 lastSyncTimestamp
服务端返回比该时间戳新的 chunks
使用哈希校验避免重复传输

实现指数退避重试：

async function callOpenAIWithRetry(prompt: string, retries = 3) {
  try {return await openai.createCompletion(prompt);
  } catch (err) {if (err.response?.status === 429 && retries > 0) {
      await new Promise(r => 
        setTimeout(r, 2 ** (4 - retries) * 1000)
      );
      return callOpenAIWithRetry(prompt, retries - 1);
    }
    throw err;
  }
}

提供用户数据删除端点

对话内容加密存储：

import {encrypt, decrypt} from 'crypto-js';

const SECRET = process.env.ENCRYPTION_KEY;

function encryptMessage(content: string) {return encrypt(content, SECRET).toString();}