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

qt调用deepseek的API开发(附带源码)

今天讲的是使用qt做一个界面(负责接受deepseek返回的数据和客户发送数据的端口)会用流的方式接受数据提高用户体验

  • 测试效果
  • 源码
  • 流程
    • 配置
    • deepseek调用思路
    • deepseek与qt联合开发界面思路

上一篇文章用的不是流开发,会让客户等待很久,会让人误以为卡住和掉线,今天将会用流的方式读取数据。
在这里插入图片描述

测试效果

20250422_191017


下面这个是换了调教词
看addSystemMessage(u8"你是一个贴吧的暴躁老哥很喜欢怼人

20250422_190503

源码

源码分为三部分
如有qt配置疑问可以参考我之前的文章链接: qt配置与libevent编译
如有curl和jsoncpp编译疑问参考libevent编译就行

下面是pro文件的配置
INCLUDEPATH就是绑定头文件,
LIBS就是绑定库,格式(路径+库)例/home/juan/Qt_Work/tests/(路劲)libevent_core.so(库)


QMAKE_LFLAGS+=-Wl,-rpath,'.'
INCLUDEPATH+=/home/juan/PublicLibrary/libevent-release-2.1.10-stable/include
INCLUDEPATH+=/home/juan/PublicLibrary/libevent-release-2.1.10-stable/include/event2
INCLUDEPATH+=/home/juan/PublicLibrary/build-libevent-release-2.1.10-stable-Desktop_Qt_5_9_3_GCC_64bit-Release/include
LIBS+=/home/juan/Qt_Work/tests/libevent_core.so
LIBS+=/home/juan/Qt_Work/tests/libevent.so
LIBS+=/home/juan/Qt_Work/tests/libevent_openssl.so
LIBS+=/home/juan/Qt_Work/tests/libevent_pthreads.soLIBS+=/home/juan/PublicLibrary/build-jsoncpp-master-Desktop_Qt_5_9_3_GCC_64bit-Release/lib/libjsoncpp.so
INCLUDEPATH+=/home/juan/PublicLibrary/jsoncpp-master/includeINCLUDEPATH+=/home/juan/PublicLibrary/curl-curl-8_13_0/include
LIBS+=/home/juan/PublicLibrary/build-curl-curl-8_13_0-Desktop_Qt_5_9_3_GCC_64bit-Release/lib/libcurl.soLIBS+=/usr/lib/x86_64-linux-gnu/libssl.so
LIBS+=/usr/lib/x86_64-linux-gnu/libssl3.so
LIBS+=/usr/lib/x86_64-linux-gnu/libcrypto.so.1.1

在这里插入图片描述
libeventuse.h

#ifndef LIBEVENTUSE_H
#define LIBEVENTUSE_H//这个作用是让头文件只调用一次避免重复调用
#include <QMainWindow>
#include<qthread.h>
class globalSignal:public QObject
{Q_OBJECT
public:static void sendSignal(QString ip){if(m_instance){emit m_instance->singnal(ip);}}static globalSignal *m_instance;~globalSignal();signals:void singnal(QString  ip);private:explicit globalSignal(QObject*parent=nullptr):QObject(parent){}
};class workThread:public QThread{//继承qthread是为了继承里面的虚函数方便统一格式Q_OBJECT
public:explicit  workThread(QObject *parent = nullptr);QString dataStr;
protected:void run() override;//override避免重复构造虚函数
signals:void workThread_signal(QString ip);//自定义信号void server_finish();void workThread_signalData(QString ip);
};#endif // LIBEVENTUSE_H

libeventuse.cpp

#include "libeventuse.h"globalSignal* globalSignal::m_instance = new globalSignal;globalSignal::~globalSignal()
{if(m_instance){delete m_instance;}
}#include"qdebug.h"
#include <iostream>
#include <string>
#include <vector>
#include <curl/curl.h>
#include <json/json.h>
#include <iostream>
#include <curl/curl.h>void print_json_value(const Json::Value& value)//专门用来打印json
{// 方法1:使用StyledWriter格式化输出(经典方式){Json::StyledWriter writer;std::string styled = writer.write(value);qDebug("=== StyledWriter 输出 === %s\n",styled.c_str());}
}// 调试回调函数,用于打印请求信息
static int debug_callback(CURL* handle, curl_infotype type, char* data, size_t size, void* userptr) {std::string* debug_log = static_cast<std::string*>(userptr);const char* type_str = "";switch (type) {case CURLINFO_TEXT:type_str = "INFO";break;case CURLINFO_HEADER_OUT:  // 输出请求头type_str = "HEADER_OUT";break;case CURLINFO_DATA_OUT:    // 输出请求体type_str = "DATA_OUT";break;default:return 0;  // 忽略其他类型}// 将调试信息追加到日志字符串debug_log->append("[").append(type_str).append("] ").append(data, size);return 0;
}using namespace Json;static size_t WriteCallback(void* contents, size_t size, size_t nmemb, std::string* response) {//写的回调函数size_t total_size = size * nmemb;std::string tmp = (char*)contents;Json::Value root;Json::CharReaderBuilder reader;std::string full_response;std::string json_str = tmp.substr(tmp.find('{'));// 解析JSONstd::istringstream iss(json_str);std::string errs;if (Json::parseFromStream(reader, iss, &root, &errs)) {// 提取增量内容const auto& content = root["choices"][0]["delta"]["content"];if (!content.isNull()) {full_response += content.asString();*response += full_response;//printf("%s", full_response.c_str());emit globalSignal::m_instance->singnal(full_response.c_str());}const auto& contentR1 =root["choices"][0]["delta"]["reasoning_content"];if (!contentR1.isNull()){full_response += contentR1.asString();*response += full_response;// printf("%s", full_response.c_str());emit globalSignal::m_instance->singnal(full_response.c_str());//发送信号给主客户端让他接受数据}// 检测终止条件if (root["choices"][0].isMember("finish_reason")) {}}return total_size;
}class ChatGPTClient {
public:ChatGPTClient(const std::string& api_key)//设置模型与api路径: api_key_(api_key),endpoint_("https://api.siliconflow.cn/v1/chat/completions"),model_("deepseek-ai/DeepSeek-V3") {curl_ = curl_easy_init();// 初始化系统消息// addSystemMessage(u8"你是一个贴吧的暴躁老哥很喜欢怼人,你回复的时候不能说自己的身份且要有很强的语言攻击性回复问题");addSystemMessage(u8"你中文编程大师");//调教词,你怎么写deeepseek就按你写的转换身份}~ChatGPTClient() {if (curl_) curl_easy_cleanup(curl_);}void addSystemMessage(const std::string& content) {Value message;message["role"] = "system";message["content"] = content;history_.append(message);}std::string ask(const std::string& question) {if (!curl_) return "Error: CURL init failed";// 添加用户问题到历史为了多轮对话,由于ds服务器不会存你的聊天记录所以要自己保存Value userMessage;userMessage["role"] = "user";userMessage["content"] = question;history_.append(userMessage);// 构建请求体Value request;request["model"] = model_;request["messages"] = history_;request["temperature"] = 0.7;//理性值,越大越理性request["max_tokens"] = 512;//你就理解为ds她最大能理解的文本数request["stream"] = true;//启动流式回复// 序列化StreamWriterBuilder writer;std::string post_data = writeString(writer, request);std::string debug_log;// 发送请求struct curl_slist* headers = nullptr;headers = curl_slist_append(headers, "Content-Type: application/json");headers = curl_slist_append(headers, ("Authorization: Bearer " + api_key_).c_str());std::string response_str;char error_buffer[CURL_ERROR_SIZE] = { 0 };curl_easy_setopt(curl_, CURLOPT_VERBOSE, 1L);                // 启用详细日志curl_easy_setopt(curl_, CURLOPT_DEBUGFUNCTION, debug_callback); // 设置回调curl_easy_setopt(curl_, CURLOPT_DEBUGDATA, &debug_log);         // 传递日志存储位置curl_easy_setopt(curl_, CURLOPT_URL, endpoint_.c_str());curl_easy_setopt(curl_, CURLOPT_HTTPHEADER, headers);curl_easy_setopt(curl_, CURLOPT_POSTFIELDS, post_data.c_str());curl_easy_setopt(curl_, CURLOPT_WRITEFUNCTION, WriteCallback);curl_easy_setopt(curl_, CURLOPT_WRITEDATA, &response_str);curl_easy_setopt(curl_, CURLOPT_ERRORBUFFER, error_buffer);curl_easy_setopt(curl_, CURLOPT_SSL_VERIFYPEER, 0L);CURLcode res = curl_easy_perform(curl_);// std::cout << "----- CURL REQUEST DEBUG -----\n";//打印日志// std::cout << debug_log << std::endl;curl_slist_free_all(headers);if (res != CURLE_OK) {return "CURL Error: " + std::string(error_buffer);}// 解析响应CharReaderBuilder reader;Value response_json;std::string parse_errors;//  printf("server:%s", response_str.c_str());Value userMessageassistant;userMessageassistant["role"] = "assistant";//把回复也要保存到历史记录里userMessageassistant["content"] = response_str;history_.append(userMessageassistant);//填充deepseek的历史回答return "ok";}private:CURL* curl_;std::string api_key_;std::string endpoint_;std::string model_;Value history_;  // 使用JSON数组存储对话历史
};static ChatGPTClient client("填自己的key");workThread::workThread(QObject *parent) : QThread(parent) {}void workThread::run() {
//dataStr+="\r\n";
client.ask(dataStr.toStdString());
}

mainwindow.cpp

#include "mainwindow.h"
#include "ui_mainwindow.h"
#include"qdebug.h"
#include"libeventuse.h"MainWindow::MainWindow(QWidget *parent) :QMainWindow(parent),ui(new Ui::MainWindow)
{ui->setupUi(this);workThreaduse=new workThread;connect(globalSignal::m_instance,&globalSignal::singnal,ui->textEdit,[=](QString ip){QString data=ui->textEdit->toPlainText();data+=ip;//data+="\r\n";ui->textEdit->setText(data);ui->textEdit->moveCursor(QTextCursor::End);});connect(this->workThreaduse,&workThread::finished,[=](){ui->pushButton->setEnabled(true);});}MainWindow::~MainWindow()
{delete ui;
}void MainWindow::on_pushButton_clicked()
{QString data=ui->textEdit_2->toPlainText();emit this->workThreaduse->workThread_signalData(data);ui->textEdit_2->setText("");QString tmpdata=ui->textEdit->toPlainText();if(tmpdata.size()){tmpdata+="\r\n";}tmpdata+="user:";tmpdata+=data;tmpdata+="\r\nAI:";ui->textEdit->setText(tmpdata);this->workThreaduse->dataStr=data;this->workThreaduse->start();ui->textEdit->moveCursor(QTextCursor::End);ui->pushButton->setEnabled(false);
}

ui界面

在这里插入图片描述
你们要熟悉基本的qt配置信息,要去看我以前的文章或者别人的博客才行
代码要自己修改对应的控件否则运行不起来。

流程

配置

1.配置key位置找到这个填入自己的key即可
在这里插入图片描述
2.deepseek的性格配置位置
在这里插入图片描述
3.temperature理性值越大越理性,max_tokens。,deepseek理解的最大字节数在这里插入图片描述

deepseek调用思路

在这里插入图片描述
在这里插入图片描述
官网的意思是
1.先按固定格式发送curl给指定服务器即可
2.解析服务器放回的字符串
3.deepseek不会记录你的历史记录所以要自己拼接一个json给服务器这样她就有了能理解以前东西的能力
4.申请key参考我上一篇文章链接: link

deepseek与qt联合开发界面思路

1.构建一个线程专门负责deepseek的api调用,负责发送消息
2.deepseek返回的消息使用一个全局信号( emit globalSignal::m_instance->singnal(full_response.c_str());)把消息发给主客户端,这样主客户端就能用槽函数的形式实现异步效果能把所有数据显示到控件上且不会让程序异常。
3.deepseek流式数据,我需要实时解析流式的json让他能一段字一段子的显示到控件上,提高用户体验参考代码 const auto& content = root[“choices”][0][“delta”][“content”];下的实现,其实就是使用jsoncpp对json解析得出返回值
4.使用connect对信号进行连接 connect(globalSignal::m_instance,&globalSignal::singnal,ui->textEdit,[=](QString ip)
{
逻辑代码
}
connect(发送者,发送的信号,要处理的对象,回调函数或lambda函数)
5.界面设计,参考我以前的文章有叫你如何设计最简单的控件客户端

相关文章:

  • Android Studio开发 SharedPreferences 详解
  • 【MATLAB第115期】基于MATLAB的多元时间序列的ARIMAX的预测模型
  • js原型链prototype解释
  • Nature Communications 面向形状可编程磁性软材料的数据驱动设计方法—基于随机设计探索与神经网络的协同优化框架
  • Qt绘制可选择范围的日历
  • 未来教育风向标 | 教育学顶流985高校,华东师范大学《AIGC技术赋能教育数字化转型的机遇与挑战》,13所大学deepseek
  • 深度解析MQTT源码架构与AIGC场景融合实战
  • 三生原理与现有密码学的核心区别?
  • 洗车小程序系统前端uniapp 后台thinkphp
  • AI大模型:(二)2.3 预训练自己的模型
  • chili3d调试笔记8 打印零件属性
  • VSCode 用于JAVA开发的环境配置,JDK为1.8版本时的配置
  • C++继承(最详细)
  • PDF转换Word深度评测 - ComPDFKit Conversion SDK V3.0
  • Oracle--SQL性能优化与提升策略
  • PowerQuery逆透视将二维表转换为一维表
  • 全面介绍AVFilter 的添加和使用
  • Neo4j 可观测性最佳实践
  • STM32单片机入门学习——第45节: [13-2] 修改频主睡眠模式停止模式待机模式
  • 详解Node.js中的setImmediate()函数
  • 从香料到文化,跟着陈晓卿寻味厦门
  • 裁员15%、撤销132个机构,美国务院将全面重组
  • 国防部发布、中国军号及多家央媒官博发祝福海报:人民海军76岁生日快乐
  • 世界读书日丨人均一年超10本!你达到上海平均阅读水平了吗
  • 2025年度“沪惠保”今日开售:保费维持129元/人,进一步扩增国内外特药种类
  • 上海农房翻建为何难?基层盼政策适度松动