通过 Node.js 后端服务接入 Taotoken 实现多轮对话的异步处理
1. 初始化 Node.js 项目与依赖
在开始前，请确保已安装 Node.js 16 或更高版本。创建一个新目录并初始化项目：
mkdir taotoken-chatbot && cd taotoken-chatbot npm init -y npm install openai express dotenv创建.env文件存储 API Key（确保该文件已加入.gitignore）：
TAOTOKEN_API_KEY=your_api_key_here2. 配置 OpenAI 客户端指向 Taotoken
在项目根目录创建src/taotokenClient.js，配置基础客户端：
import OpenAI from "openai"; import dotenv from "dotenv"; dotenv.config(); const client = new OpenAI({ apiKey: process.env.TAOTOKEN_API_KEY, baseURL: "https://taotoken.net/api", }); export default client;关键配置说明：
baseURL必须设置为https://taotoken.net/api以兼容 Taotoken 路由- API Key 通过环境变量注入，避免硬编码
- 客户端实例可被其他模块复用
3. 实现流式对话接口
创建src/chatController.js处理对话逻辑：
import client from "./taotokenClient.js"; async function handleStreamingChat(messages, model = "claude-sonnet-4-6") { try { const stream = await client.chat.completions.create({ model, messages, stream: true, }); let fullResponse = ""; for await (const chunk of stream) { const content = chunk.choices[0]?.delta?.content || ""; process.stdout.write(content); // 实时输出到控制台 fullResponse += content; } return fullResponse; } catch (error) { console.error("API Error:", error.message); throw new Error("Failed to get chat completion"); } } export { handleStreamingChat };4. 构建 Express 服务端点
创建src/server.js设置 HTTP 接口：
import express from "express"; import { handleStreamingChat } from "./chatController.js"; const app = express(); app.use(express.json()); app.post("/api/chat", async (req, res) => { try { const { messages, model } = req.body; res.setHeader("Content-Type", "text/plain"); const response = await handleStreamingChat(messages, model); res.status(200).send(response); } catch (error) { console.error("Endpoint Error:", error); res.status(500).json({ error: error.message }); } }); const PORT = process.env.PORT || 3000; app.listen(PORT, () => { console.log(`Server running on port ${PORT}`); });5. 异常处理与重试机制
增强taotokenClient.js的鲁棒性：
import OpenAI from "openai"; import dotenv from "dotenv"; import retry from "async-retry"; dotenv.config(); const client = new OpenAI({ apiKey: process.env.TAOTOKEN_API_KEY, baseURL: "https://taotoken.net/api", }); async function safeChatCompletion(options) { return await retry( async (bail) => { try { return await client.chat.completions.create(options); } catch (error) { if (error.statusCode === 429) { throw error; // 触发重试 } bail(error); // 非速率限制错误直接退出 return; } }, { retries: 3, minTimeout: 1000, } ); } export { client, safeChatCompletion };6. 测试与部署建议
使用 curl 测试接口：
curl -X POST http://localhost:3000/api/chat \ -H "Content-Type: application/json" \ -d '{"messages":[{"role":"user","content":"解释量子计算"}],"model":"claude-sonnet-4-6"}'部署注意事项：
- 生产环境应添加 HTTPS 和身份验证中间件
- 建议使用 PM2 或 Docker 管理进程
- 监控 API 调用延迟和错误率
- 定期检查 Taotoken 控制台的用量统计
完整项目可参考 Taotoken Node.js 示例仓库获取更多实现细节。
