当前位置：首页 > news >正文

在nodejs后端服务中集成taotoken实现多轮对话逻辑

news 2026/5/6 16:28:29

在 Node.js 后端服务中集成 Taotoken 实现多轮对话逻辑

1. 场景需求与架构设计

假设我们正在开发一个需要智能对话能力的 Node.js 后端服务。该服务需要为不同业务模块提供对话功能，同时要求能够灵活切换底层大模型供应商。通过 Taotoken 的 OpenAI 兼容 API，我们可以统一接入多个大模型，并通过 API Key 管理实现权限隔离。

典型架构包含以下分层：

路由层：接收用户请求并转发到对应业务模块
业务逻辑层：处理对话上下文管理
模型调用层：通过 Taotoken 异步调用大模型
权限控制层：通过不同 API Key 区分模块访问权限

2. 基础环境配置

首先安装必要的依赖：

npm install openai dotenv

在项目根目录创建.env文件，配置环境变量：

# 业务模块A的Taotoken API Key MODULE_A_API_KEY=sk-taotoken_xxxxxx # 业务模块B的Taotoken API Key MODULE_B_API_KEY=sk-taotoken_yyyyyy TAOTOKEN_BASE_URL=https://taotoken.net/api

建议将敏感配置放在环境变量中，不要硬编码在源码里。不同业务模块使用独立的 API Key，便于后续用量统计和权限管理。

3. 实现多轮对话服务

创建taotokenService.js作为基础服务层：

import OpenAI from "openai"; import dotenv from "dotenv"; dotenv.config(); class TaotokenService { constructor(apiKey) { this.client = new OpenAI({ apiKey: apiKey || process.env.MODULE_A_API_KEY, baseURL: process.env.TAOTOKEN_BASE_URL, }); this.conversations = new Map(); // 存储对话上下文 } async chat(conversationId, message, model = "claude-sonnet-4-6") { // 获取或初始化对话历史 let messages = this.conversations.get(conversationId) || []; // 添加用户新消息 messages.push({ role: "user", content: message }); // 调用Taotoken API const completion = await this.client.chat.completions.create({ model, messages, }); // 添加AI回复到上下文 const aiResponse = completion.choices[0]?.message?.content; messages.push({ role: "assistant", content: aiResponse }); // 更新对话上下文（限制历史长度避免token过多） this.conversations.set(conversationId, messages.slice(-10)); return aiResponse; } } export default TaotokenService;

4. 业务模块集成示例

不同业务模块可以初始化自己的服务实例，使用专属 API Key：

// moduleAService.js import TaotokenService from "./taotokenService.js"; // 使用模块A的专属API Key const moduleAService = new TaotokenService(process.env.MODULE_A_API_KEY); export async function handleModuleARequest(conversationId, message) { return await moduleAService.chat(conversationId, message); }

// moduleBService.js import TaotokenService from "./taotokenService.js"; // 使用模块B的专属API Key const moduleBService = new TaotokenService(process.env.MODULE_B_API_KEY); export async function handleModuleBRequest(conversationId, message) { // 模块B可以使用不同模型 return await moduleBService.chat(conversationId, message, "gpt-4-5-6"); }

5. 路由与权限控制

在 Express 或类似框架中，可以通过中间件实现权限控制：

import express from "express"; import { handleModuleARequest } from "./moduleAService.js"; import { handleModuleBRequest } from "./moduleBService.js"; const app = express(); app.use(express.json()); // 权限校验中间件 const checkModulePermission = (module) => (req, res, next) => { const apiKey = req.headers["x-api-key"]; const validKey = process.env[`MODULE_${module}_API_KEY`]; if (apiKey !== validKey) { return res.status(403).json({ error: "Unauthorized" }); } next(); }; app.post( "/module-a/chat", checkModulePermission("A"), async (req, res) => { const { conversationId, message } = req.body; const response = await handleModuleARequest(conversationId, message); res.json({ response }); } ); app.post( "/module-b/chat", checkModulePermission("B"), async (req, res) => { const { conversationId, message } = req.body; const response = await handleModuleBRequest(conversationId, message); res.json({ response }); } ); app.listen(3000, () => console.log("Server running on port 3000"));