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

Python实现智能聊天机器人

news 2026/5/11 21:59:24

智能聊天机器人完整代码实现指南

一、智能聊天机器人技术架构

1.1 核心组件构成

组件模块	技术实现	功能描述
前端界面	Vue3/Android/LitView	用户交互界面设计
后端服务	SpringBoot/Python Flask	业务逻辑处理
对话引擎	ChatGPT/图灵API/青云客API	智能对话核心
数据存储	SQLite/MySQL	聊天记录存储
网络通信	HttpURLConnection/RESTful API	前后端数据交互

二、基于Python的完整代码实现

2.1 基础聊天机器人实现

import requests import json import pyttsx3 import speech_recognition as sr class SimpleChatBot: def __init__(self): self.api_url = "http://api.qingyunke.com/api.php" self.engine = pyttsx3.init() def get_response(self, message): """调用青云客API获取智能回复""" params = { 'key': 'free', 'appid': 0, 'msg': message } try: response = requests.get(self.api_url, params=params) data = response.json() return data['content'] except Exception as e: return f"抱歉，暂时无法回复：{str(e)}" def text_to_speech(self, text): """文本转语音输出""" self.engine.say(text) self.engine.runAndWait() def speech_to_text(self): """语音识别输入""" recognizer = sr.Recognizer() with sr.Microphone() as source: print("请说话...") audio = recognizer.listen(source) try: text = recognizer.recognize_google(audio, language='zh-CN') return text except sr.UnknownValueError: return "无法识别语音" except sr.RequestError: return "语音服务错误" # 使用示例 if __name__ == "__main__": bot = SimpleChatBot() print("智能聊天机器人已启动！") while True: user_input = input("你：") if user_input.lower() in ['退出', 'quit', 'exit']: break response = bot.get_response(user_input) print(f"机器人：{response}") bot.text_to_speech(response) # 语音输出回复

2.2 增强版聊天机器人（支持上下文记忆）

import sqlite3 from datetime import datetime class EnhancedChatBot(SimpleChatBot): def __init__(self): super().__init__() self.init_database() self.conversation_history = [] def init_database(self): """初始化SQLite数据库存储聊天记录""" self.conn = sqlite3.connect('chat_history.db') cursor = self.conn.cursor() cursor.execute(''' CREATE TABLE IF NOT EXISTS chat_logs ( id INTEGER PRIMARY KEY AUTOINCREMENT, user_message TEXT NOT NULL, bot_response TEXT NOT NULL, timestamp DATETIME DEFAULT CURRENT_TIMESTAMP ) ''') self.conn.commit() def save_conversation(self, user_msg, bot_response): """保存对话记录到数据库""" cursor = self.conn.cursor() cursor.execute( 'INSERT INTO chat_logs (user_message, bot_response) VALUES (?, ?)', (user_msg, bot_response) ) self.conn.commit() self.conversation_history.append({ 'user': user_msg, 'bot': bot_response, 'time': datetime.now() }) def get_context_aware_response(self, message): """基于上下文生成更智能的回复""" # 构建上下文信息 context = " ".join([f"用户：{log['user']} 机器人：{log['bot']}" for log in self.conversation_history[-3:]]) enhanced_message = f"{context} 当前用户说：{message}" response = self.get_response(enhanced_message) # 保存对话记录 self.save_conversation(message, response) return response # 使用增强版机器人 enhanced_bot = EnhancedChatBot() user_input = "今天天气怎么样？" response = enhanced_bot.get_context_aware_response(user_input) print(f"增强回复：{response}")

三、基于SpringBoot + Vue3的完整实现方案

3.1 后端SpringBoot实现

// ChatController.java @RestController @RequestMapping("/api/chat") public class ChatController { @Autowired private ChatService chatService; @PostMapping("/send") public ResponseEntity<ChatResponse> sendMessage(@RequestBody ChatRequest request) { try { String response = chatService.processMessage(request.getMessage()); return ResponseEntity.ok(new ChatResponse(response, "success")); } catch (Exception e) { return ResponseEntity.status(500) .body(new ChatResponse("", "处理消息时发生错误")); } } @GetMapping("/history") public ResponseEntity<List<ChatHistory>> getChatHistory() { List<ChatHistory> history = chatService.getRecentChatHistory(); return ResponseEntity.ok(history); } } // ChatService.java @Service public class ChatService { @Autowired private ChatHistoryRepository historyRepository; public String processMessage(String message) { // 调用ChatGPT API或图灵机器人API String apiResponse = callChatGPTAPI(message); // 保存聊天记录 ChatHistory history = new ChatHistory(); history.setUserMessage(message); history.setBotResponse(apiResponse); history.setCreateTime(new Date()); historyRepository.save(history); return apiResponse; } private String callChatGPTAPI(String message) { // 实现ChatGPT API调用逻辑 // 返回智能回复内容 return "这是ChatGPT的回复示例"; } }

3.2 前端Vue3实现

<template> <div class="chat-container"> <div class="chat-header"> <h2>智能聊天机器人</h2> </div> <div class="chat-messages" ref="messagesContainer"> <div v-for="(msg, index) in messages" :key="index" :class="['message', msg.type]"> <div class="message-content">{{ msg.content }}</div> <div class="message-time">{{ msg.time }}</div> </div> </div> <div class="chat-input"> <input v-model="inputMessage" @keyup.enter="sendMessage" placeholder="输入消息..." /> <button @click="sendMessage">发送</button> </div> </div> </template> <script> import { ref, onMounted, nextTick } from 'vue' import axios from 'axios' export default { name: 'ChatRobot', setup() { const messages = ref([]) const inputMessage = ref('') const messagesContainer = ref(null) const sendMessage = async () => { if (!inputMessage.value.trim()) return // 添加用户消息 messages.value.push({ type: 'user', content: inputMessage.value, time: new Date().toLocaleTimeString() }) const userMsg = inputMessage.value inputMessage.value = '' // 调用后端API try { const response = await axios.post('/api/chat/send', { message: userMsg }) // 添加机器人回复 messages.value.push({ type: 'bot', content: response.data.response, time: new Date().toLocaleTimeString() }) // 滚动到底部 scrollToBottom() } catch (error) { console.error('发送消息失败:', error) } } const scrollToBottom = () => { nextTick(() => { if (messagesContainer.value) { messagesContainer.value.scrollTop = messagesContainer.value.scrollHeight } }) } onMounted(() => { // 加载聊天历史 loadChatHistory() }) return { messages, inputMessage, messagesContainer, sendMessage } } } </script>

四、Android平台实现方案

4.1 MainActivity.java核心代码

public class MainActivity extends AppCompatActivity { private EditText inputEditText; private Button sendButton; private RecyclerView chatRecyclerView; private ChatAdapter chatAdapter; private List<ChatMessage> messageList; @Override protected void onCreate(Bundle savedInstanceState) { super.onCreate(savedInstanceState); setContentView(R.layout.activity_main); initViews(); setupChatRecyclerView(); } private void initViews() { inputEditText = findViewById(R.id.inputEditText); sendButton = findViewById(R.id.sendButton); chatRecyclerView = findViewById(R.id.chatRecyclerView); sendButton.setOnClickListener(v -> sendMessage()); } private void sendMessage() { String message = inputEditText.getText().toString().trim(); if (message.isEmpty()) return; // 添加用户消息 addMessage(new ChatMessage(message, ChatMessage.TYPE_USER)); inputEditText.setText(""); // 调用机器人API new ChatTask().execute(message); } private class ChatTask extends AsyncTask<String, Void, String> { @Override protected String doInBackground(String... messages) { return callChatAPI(messages[0]); } @Override protected void onPostExecute(String response) { addMessage(new ChatMessage(response, ChatMessage.TYPE_BOT)); } } private String callChatAPI(String message) { // 实现API调用逻辑，使用HttpURLConnection或OkHttp // 返回机器人回复 return "这是Android机器人的回复"; } }

五、关键技术与优化建议

5.1 性能优化策略

优化方向	具体措施	预期效果
响应速度	异步处理、连接池	提升用户体验
内存管理	消息分页加载	减少内存占用
网络优化	请求缓存、重试机制	增强稳定性