在易语言中实现DeepSeek API的流式输出,主要通过处理HTTP分块传输(Chunked Transfer Encoding)来实现。以下是详细步骤和代码示例:
核心步骤:
- 使用
WinHttpW
对象:发送HTTP请求并接收流式响应
- 处理分块数据:解析
Transfer-Encoding: chunked
格式
- 实时回调处理:将收到的JSON片段解析并输出内容
完整代码示例(易语言):
.版本 2
.支持库 spec
.程序集 窗口程序集_启动窗口
.程序集变量 全局_WinHttp, 对象
.子程序 __启动窗口_创建完毕
全局_WinHttp = 创建对象 (“WinHttp.WinHttpRequest.5.1”)
.子程序 _按钮_流式请求_被单击
发送流式请求 ()
.子程序 发送流式请求
.局部变量 请求地址, 文本型
.局部变量 请求数据, 文本型
.局部变量 API密钥, 文本型
请求地址 = “https://api.deepseek.com/v1/chat/completions”
API密钥 = “你的API密钥” ' ← 替换成实际密钥
' 构造JSON请求体
请求数据 = “{” + #引号 + “model” + #引号 + “:” + #引号 + “deepseek-chat” + #引号 + “,”
请求数据 = 请求数据 + #引号 + “messages” + #引号 + “:[{” + #引号 + “role” + #引号 + “:” + #引号 + “user” + #引号 + “,”
请求数据 = 请求数据 + #引号 + “content” + #引号 + “:” + #引号 + “你好,请介绍你自己” + #引号 + “}],”
请求数据 = 请求数据 + #引号 + “stream” + #引号 + “:true}” ' 关键:开启流式输出
.如果真 (全局_WinHttp.是否为空 ())
全局_WinHttp = 创建对象 (“WinHttp.WinHttpRequest.5.1”)
.如果真结束
' 设置请求
全局_WinHttp.方法 (“Open”, “POST”, 请求地址, 假)
全局_WinHttp.方法 (“SetRequestHeader”, “Content-Type”, “application/json”)
全局_WinHttp.方法 (“SetRequestHeader”, “Authorization”, “Bearer ” + API密钥)
全局_WinHttp.方法 (“SetRequestHeader”, “Accept”, “text/event-stream”) ' 重要:声明需要流式响应
' 发送异步请求
全局_WinHttp.方法 (“Send”, 请求数据)
' 启动定时器实时读取
时钟1.时钟周期 = 100 ' 每100ms检查一次数据
.子程序 _时钟1_周期事件
.局部变量 可用数据量, 整数型
.局部变量 响应块, 文本型
' 检查是否有新数据
可用数据量 = 全局_WinHttp.读数值属性 (“ResponseAvailable”)
.如果真 (可用数据量 ≤ 0)
返回 ' 无新数据
.如果真结束
' 读取响应片段
响应块 = 全局_WinHttp.读文本属性 (“ResponseText”)
' 处理分块数据(可能包含多个data:)
.如果真 (响应块 ≠ “”)
处理响应块 (响应块)
.如果真结束
.子程序 处理响应块, , , 解析SSE格式数据
.参数 原始数据, 文本型
.局部变量 行数组, 文本型, , "0"
.局部变量 i, 整数型
.局部变量 json数据, 文本型
' 按行分割
行数组 = 分割文本 (原始数据, #换行符, )
.计次循环首 (取数组成员数 (行数组), i)
' 只处理以"data: "开头的行
.如果真 (取文本左边 (行数组 [i], 6) = “data: ”)
json数据 = 取文本右边 (行数组 [i], 取文本长度 (行数组 [i]) - 6)
' 跳过结束标记[data: [DONE]]
.如果真 (json数据 ≠ “[DONE]”)
解析JSON片段 (json数据)
.如果真结束
.如果真结束
.计次循环尾 ()
.子程序 解析JSON片段
.参数 json文本, 文本型
.局部变量 json, 类_json
.局部变量 内容, 文本型
' 解析JSON
.如果 (json.解析 (json文本))
内容 = json.取通用属性 (“choices[0].delta.content”, )
.如果真 (内容 ≠ “”)
' 实时输出到编辑框
编辑框_输出.加入文本 (内容)
' 立即刷新显示
处理事件 ()
.如果真结束
.否则
调试输出 (“JSON解析失败:” + json文本)
.如果结束
关键说明:
-
流式请求标志
请求JSON中必须包含 "stream": true
参数
-
SSE数据格式
DeepSeek返回的数据格式为:
data: {JSON对象1}
data: {JSON对象2}
...
data: [DONE]
-
实时输出原理
- 使用
WinHttpRequest
的异步请求
- 通过定时器检查
ResponseAvailable
属性
- 每次读取到数据后立即解析并刷新UI
-
注意事项
- 需要引用
WinHttpW
组件(易语言中称为"WinHttp.WinHttpRequest.5.1")
- 编辑框需设置为允许多行
- 实际使用需替换有效的API密钥
效果演示:
当收到类似这样的响应片段时:
data: {"id":"chat-123","choices":[{"delta":{"content":"你好"}}]}
data: {"id":"chat-123","choices":[{"delta":{"content":"!我是DeepSeek"}}]}
编辑框会逐步显示:
你好
→ 你好!我是DeepSeek
常见问题排查:
-
无响应数据
- 检查API密钥是否正确
- 确认网络是否可访问
api.deepseek.com
- 查看返回状态码:
全局_WinHttp.读数值属性("Status")
-
JSON解析失败
- 使用
调试输出()
查看原始响应
- 确保只解析
data:
后的有效JSON(跳过[DONE]
)
-
界面卡顿
- 减少
处理事件()
的调用频率
- 使用线程处理网络请求(复杂场景需用多线程支持库)
提示:完整项目需要添加错误处理和网络超时机制,以上为核心流程演示。