### 3.1 远程聊天程序的实现基础 在 Python 中实现基于 Dify 的远程聊天程序，需要结合 Dify 提供的 API 接口与远程通信机制。Dify 本身是一个低代码开发平台，支持通过 API 调用进行对话交互。可以通过 Python 编写客户端程序，调用 Dify 的 API 实现远程聊天功能。 Dify 的 API 调用通常需要携带访问令牌（access_token），该令牌通过 `/console/api/refresh-token` 接口获取。若令牌无效，会返回 `{'code': 'unauthorized', 'message': 'Access token is invalid', 'status': 401}` 错误，因此需确保令牌的正确性和时效性[^2]。 ### 3.2 获取访问令牌并维持会话 Dify 的访问令牌可以通过以下方式获取： ```python import requests def get_access_token(refresh_token): url = "http://localhost:5001/console/api/refresh-token" payload = {"refresh_token": refresh_token} response = requests.post(url, data=payload) return response.json() ``` 在获取到 `access_token` 后，需要将其用于后续的 API 请求。例如，调用聊天接口时应携带该令牌： ```python def chat_with_dify(access_token, query): url = "http://localhost:5001/chatbot/api/v1.0.0/chat" headers = { "Authorization": f"Bearer {access_token}" } payload = { "query": query } response = requests.post(url, headers=headers, json=payload) return response.json() ``` 为避免频繁请求刷新令牌，应引入缓存机制并记录令牌过期时间： ```python token_cache = { "access_token": None, "expires_at": 0 } def get_cached_token(refresh_token): if time.time() < token_cache["expires_at"]: return token_cache["access_token"] else: data = get_access_token(refresh_token) token_cache["access_token"] = data["access_token"] token_cache["expires_at"] = time.time() + data["expires_in"] return data["access_token"] ``` ### 3.3 构建远程聊天客户端 远程聊天程序的核心是构建一个能够持续发送和接收消息的客户端。可以使用 Python 的 `socket` 或 `websocket` 模块实现远程通信。 以下是一个基于 `websocket` 的客户端示例： ```python import websocket import json def on_message(ws, message): print("Received:", message) def on_error(ws, error): print("Error:", error) def on_close(ws): print("Connection closed") def on_open(ws, access_token): def run(*args): while True: user_input = input("You: ") ws.send(json.dumps({ "authorization": f"Bearer {access_token}", "query": user_input })) threading.Thread(target=run).start() def start_chat_client(access_token): ws_url = "ws://localhost:5001/chatbot/api/v1.0.0/chat-stream" ws = websocket.WebSocketApp( ws_url, on_message=on_message, on_error=on_error, on_close=on_close ) ws.on_open = lambda ws: on_open(ws, access_token) ws.run_forever() ``` 此客户端通过 WebSocket 与 Dify 的聊天接口建立连接，并持续监听用户输入，实现远程聊天功能。 ### 3.4 部署与运行环境配置 若使用 Docker 部署 Dify，需确保容器配置正确，包括数据库连接、密钥、域名白名单等参数。可以通过查看容器日志排查认证问题： ```bash docker logs <container_id> ``` 此外，确保 `/console/api/refresh-token` 接口返回的 `access_token` 和 `expires_in` 字段正确无误，以避免身份验证失败。 ###