SpringBoot 接入讯飞星火大模型实现对话

申请地址

https://xinghuo.xfyun.cn/sparkapi?scr=price
免费申请200万Token

开发文档

https://www.xfyun.cn/doc/spark/Web.html#_1-接口说明

页面最下面有相关demo可以参考

在这里插入图片描述

介绍

接口是以套接字的形式分段返回，而且非http请求，比较繁琐，官方也只给了比较简单的deom。

依赖项

  <!--okhttp3--><dependency><groupId>com.squareup.okhttp3</groupId><artifactId>okhttp</artifactId></dependency><!-- 阿里JSON解析器 --><dependency><groupId>com.alibaba.fastjson2</groupId><artifactId>fastjson2</artifactId></dependency>

配置文件

xunfei:ai:hostUrl: https://spark-api.xf-yun.com/v3.5/chatappId: xxxapiSecret: xxxapiKey: xxx

控制台上可以查看 API认证字符串

在这里插入图片描述

读取配置文件

@Value("${xunfei.ai.hostUrl}")
private  String  hostUrl;@Value("${xunfei.ai.appId}")
private  String appId;@Value("${xunfei.ai.apiSecret}")
private  String apiSecret;@Value("${xunfei.ai.apiKey}")
private  String apiKey;

权限校验

得到的是一个url，需要将http替换成ws

/*** 权限校验* @return String* @throws NoSuchAlgorithmException* @throws InvalidKeyException* @throws MalformedURLException*/private String getAuthUrl() throws NoSuchAlgorithmException, InvalidKeyException, MalformedURLException {URL url = new URL(hostUrl);// 时间SimpleDateFormat format = new SimpleDateFormat("EEE, dd MMM yyyy HH:mm:ss z", Locale.US);format.setTimeZone(TimeZone.getTimeZone("GMT"));String date = format.format(new Date());// 拼接String preStr = "host: " + url.getHost() + "\n" +"date: " + date + "\n" +"GET " + url.getPath() + " HTTP/1.1";// System.err.println(preStr);// SHA256加密Mac mac = Mac.getInstance("hmacsha256");SecretKeySpec spec = new SecretKeySpec(apiSecret.getBytes(StandardCharsets.UTF_8), "hmacsha256");mac.init(spec);byte[] hexDigits = mac.doFinal(preStr.getBytes(StandardCharsets.UTF_8));// Base64加密String sha = Base64.getEncoder().encodeToString(hexDigits);// System.err.println(sha);// 拼接String authorization = String.format("api_key=\"%s\", algorithm=\"%s\", headers=\"%s\", signature=\"%s\"", apiKey, "hmac-sha256", "host date request-line", sha);// 拼接地址HttpUrl httpUrl = Objects.requireNonNull(HttpUrl.parse("https://" + url.getHost() + url.getPath())).newBuilder().addQueryParameter("authorization", Base64.getEncoder().encodeToString(authorization.getBytes(StandardCharsets.UTF_8))).addQueryParameter("date", date).addQueryParameter("host", url.getHost()).build();return httpUrl.toString();}

构建请求参数

请求参数是与json格式进行发送，如果需要结合之前的信息继续回答需要携带历史记录。在官方的api文档也可以查看

#参数构造示例如下

{"header": {"app_id": "12345","uid": "12345"},"parameter": {"chat": {"domain": "generalv3.5","temperature": 0.5,"max_tokens": 1024, }},"payload": {"message": {# 如果想获取结合上下文的回答，需要开发者每次将历史问答信息一起传给服务端，如下示例# 注意：text里面的所有content内容加一起的tokens需要控制在8192以内，开发者如有较长对话需求，需要适当裁剪历史信息"text": [{"role":"system","content":"你现在扮演李白，你豪情万丈，狂放不羁；接下来请用李白的口吻和用户对话。"} #设置对话背景或者模型角色{"role": "user", "content": "你是谁"} # 用户的历史问题{"role": "assistant", "content": "....."}  # AI的历史回答结果# ....... 省略的历史对话{"role": "user", "content": "你会做什么"}  # 最新的一条问题，如无需上下文，可只传最新一条问题]}}
}

JAVA构建

private    String buildBody(String text,String uid){JSONObject body =new JSONObject();JSONObject header =new JSONObject();header.put("app_id",appId);header.put("uid",uid);body.put("header",header);JSONObject parameter =new JSONObject();JSONObject chat =new JSONObject();chat.put("domain","generalv3.5");parameter.put("chat",chat);body.put("parameter",parameter);JSONObject history =JSONObject.parseObject(text);body.put("payload",history);JSONObject back =new JSONObject();back.put("role","system");back.put("content","请回答我关于一些生产安全的内容");//定义会话背景history.getJSONObject("message").getJSONArray("text").add(0,back);return body.toJSONString();}

回复消息

基于OKHTTP3的请求库，连接websocket

 /*** 回复消息* @param text* @return* @throws MalformedURLException* @throws NoSuchAlgorithmException* @throws InvalidKeyException*/public String answer(String text,String uid) throws MalformedURLException, NoSuchAlgorithmException, InvalidKeyException, ExecutionException, InterruptedException, TimeoutException {String authUrl =getAuthUrl().replace("http://", "ws://").replace("https://", "wss://");Request request = new Request.Builder().url(authUrl).build();OkHttpClient client = new OkHttpClient.Builder().build();StringBuilder sb =new StringBuilder();CompletableFuture<String> messageReceived = new CompletableFuture<>();String body = buildBody(text,uid);WebSocket webSocket =client.newWebSocket(request, new WebSocketListener() {@Overridepublic void onOpen(WebSocket webSocket, Response response) {webSocket.send(body);//发送消息}@Overridepublic void onMessage(WebSocket webSocket, String text) {JSONObject obj = JSON.parseObject(text);String str= obj.getJSONObject("payload").getJSONObject("choices").getJSONArray("text").getJSONObject(0).getString("content");sb.append(str);if(obj.getJSONObject("header").getLong("status")==2){webSocket.close(1000, "Closing WebSocket connection");messageReceived.complete(text); // 将收到的消息传递给 CompletableFuture}}} );String result = messageReceived.get(30, TimeUnit.SECONDS);; // 阻塞等待消息返回webSocket.close(1000, "Closing WebSocket connection");return sb.toString();}

Controller

   @PostMapping("/chat")public AjaxResult chat(String text,String uid) throws MalformedURLException, NoSuchAlgorithmException, InvalidKeyException, ExecutionException, InterruptedException, TimeoutException {return  success( model.answer(text,uid));}

运行效果

在这里插入图片描述

完整代码

Controller层

@RestController
@RequestMapping("/course")
public class QueryController extends BaseController {@Autowiredprivate CognitiveMode model;@PostMapping("/chat")public AjaxResult chat(String text,String uid) throws MalformedURLException, NoSuchAlgorithmException, InvalidKeyException, ExecutionException, InterruptedException, TimeoutException {return  success( model.answer(text,uid));}}

package com.ruoyi.framework.ai;
import com.alibaba.fastjson2.JSON;
import com.alibaba.fastjson2.JSONObject;
import okhttp3.*;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.stereotype.Component;
import javax.crypto.Mac;
import javax.crypto.spec.SecretKeySpec;
import java.net.MalformedURLException;
import java.net.URL;
import java.nio.charset.StandardCharsets;
import java.security.InvalidKeyException;
import java.security.NoSuchAlgorithmException;
import java.text.SimpleDateFormat;
import java.util.*;
import java.util.concurrent.CompletableFuture;
import java.util.concurrent.ExecutionException;
import java.util.concurrent.TimeUnit;
import java.util.concurrent.TimeoutException;@Component
public class CognitiveMode {@Value("${xunfei.ai.hostUrl}")private  String  hostUrl;@Value("${xunfei.ai.appId}")private  String appId;@Value("${xunfei.ai.apiSecret}")private  String apiSecret;@Value("${xunfei.ai.apiKey}")private  String apiKey;/*** 回复消息* @param text* @return* @throws MalformedURLException* @throws NoSuchAlgorithmException* @throws InvalidKeyException*/public String answer(String text,String uid) throws MalformedURLException, NoSuchAlgorithmException, InvalidKeyException, ExecutionException, InterruptedException, TimeoutException {String authUrl =getAuthUrl().replace("http://", "ws://").replace("https://", "wss://");Request request = new Request.Builder().url(authUrl).build();OkHttpClient client = new OkHttpClient.Builder().build();StringBuilder sb =new StringBuilder();CompletableFuture<String> messageReceived = new CompletableFuture<>();String body = buildBody(text,uid);WebSocket webSocket =client.newWebSocket(request, new WebSocketListener() {@Overridepublic void onOpen(WebSocket webSocket, Response response) {webSocket.send(body);}@Overridepublic void onMessage(WebSocket webSocket, String text) {JSONObject obj = JSON.parseObject(text);String str= obj.getJSONObject("payload").getJSONObject("choices").getJSONArray("text").getJSONObject(0).getString("content");sb.append(str);if(obj.getJSONObject("header").getLong("status")==2){webSocket.close(1000, "Closing WebSocket connection");messageReceived.complete(text); // 将收到的消息传递给 CompletableFuture}}} );String result = messageReceived.get(30, TimeUnit.SECONDS);; // 阻塞等待消息返回webSocket.close(1000, "Closing WebSocket connection");return sb.toString();}private    String buildBody(String text,String uid){JSONObject body =new JSONObject();JSONObject header =new JSONObject();header.put("app_id",appId);header.put("uid",uid);body.put("header",header);JSONObject parameter =new JSONObject();JSONObject chat =new JSONObject();chat.put("domain","generalv3.5");parameter.put("chat",chat);body.put("parameter",parameter);JSONObject history =JSONObject.parseObject(text);body.put("payload",history);JSONObject back =new JSONObject();back.put("role","system");back.put("content","请回答我关于一些xxx的内容");history.getJSONObject("message").getJSONArray("text").add(0,back);return body.toJSONString();}/*** 权限校验* @return String* @throws NoSuchAlgorithmException* @throws InvalidKeyException* @throws MalformedURLException*/private String getAuthUrl() throws NoSuchAlgorithmException, InvalidKeyException, MalformedURLException {URL url = new URL(hostUrl);// 时间SimpleDateFormat format = new SimpleDateFormat("EEE, dd MMM yyyy HH:mm:ss z", Locale.US);format.setTimeZone(TimeZone.getTimeZone("GMT"));String date = format.format(new Date());// 拼接String preStr = "host: " + url.getHost() + "\n" +"date: " + date + "\n" +"GET " + url.getPath() + " HTTP/1.1";// System.err.println(preStr);// SHA256加密Mac mac = Mac.getInstance("hmacsha256");SecretKeySpec spec = new SecretKeySpec(apiSecret.getBytes(StandardCharsets.UTF_8), "hmacsha256");mac.init(spec);byte[] hexDigits = mac.doFinal(preStr.getBytes(StandardCharsets.UTF_8));// Base64加密String sha = Base64.getEncoder().encodeToString(hexDigits);// System.err.println(sha);// 拼接String authorization = String.format("api_key=\"%s\", algorithm=\"%s\", headers=\"%s\", signature=\"%s\"", apiKey, "hmac-sha256", "host date request-line", sha);// 拼接地址HttpUrl httpUrl = Objects.requireNonNull(HttpUrl.parse("https://" + url.getHost() + url.getPath())).newBuilder().addQueryParameter("authorization", Base64.getEncoder().encodeToString(authorization.getBytes(StandardCharsets.UTF_8))).addQueryParameter("date", date).addQueryParameter("host", url.getHost()).build();return httpUrl.toString();}}

本文来自互联网用户投稿，该文观点仅代表作者本人，不代表本站立场。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如若转载，请注明出处：http://www.mzph.cn/news/678402.shtml

如若内容造成侵权/违法违规/事实不符，请联系多彩编程网进行投诉反馈email:809451989@qq.com，一经查实，立即删除！

相关文章

如何使用Airtest进行UI自动化测试

如何使用Airtest进行UI自动化测试

一、环境搭建 1、Airtest客户端下载 访问官网http://airtest.netease.com/&#xff0c;根据自己的系统下载相应的客户端安装&#xff1b; 2、python工具下载与环境搭建 在本地python环境中安装airtest和pocoui&#xff0c;然后用命令行运行脚本&#xff1b; 1、建议使用3.…
阅读更多...
笔记：《NCT全国青少年编程能力等级测试教程Python语言编程二级》

笔记：《NCT全国青少年编程能力等级测试教程Python语言编程二级》

NCT全国青少年编程能力等级测试教程Python语言编程二级 ISBN：9787302565857 绪论 专题1　模块化编程 考查方向 考点清单 考点　模块化编程 （一）模块化编程思想：结构清晰、降低复杂度；提高代码复用率；易于扩展、维护，方便阅读、优化。 …
阅读更多...
猫头虎分享已解决Bug || RuntimeError: size mismatch, m1: [32 x 100], m2: [500 x 10]

猫头虎分享已解决Bug || RuntimeError: size mismatch, m1: [32 x 100], m2: [500 x 10]

博主猫头虎的技术世界 &#x1f31f; 欢迎来到猫头虎的博客 — 探索技术的无限可能&#xff01; 专栏链接&#xff1a; &#x1f517; 精选专栏&#xff1a; 《面试题大全》 — 面试准备的宝典&#xff01;《IDEA开发秘籍》 — 提升你的IDEA技能&#xff01;《100天精通鸿蒙》 …
阅读更多...
奶茶点餐|奶茶店自助点餐系统|基于微信小程序的饮品点单系统的设计与实现(源码+数据库+文档)

奶茶点餐|奶茶店自助点餐系统|基于微信小程序的饮品点单系统的设计与实现(源码+数据库+文档)

奶茶店自助点餐系统目录 目录 基于微信小程序的饮品点单系统的设计与实现 一、前言 二、系统功能设计 三、系统实现 1、商品信息管理 2、商品评价管理 3、商品订单管理 4、用户管理 四、数据库设计 1、实体ER图 2、具体的表设计如下所示&#xff1a; 五、核心代码 …
阅读更多...
【More Effective C++】条款2：使用C++转型操作符

【More Effective C++】条款2：使用C++转型操作符

C旧式转型的缺点包括&#xff1a; 没有类型安全检查&#xff1a;允许将任何指针转换为其他类型指针&#xff0c;可能导致未定义行为的错误&#xff1b;难以识别和维护&#xff1a;语法(type)expression 或 type(expression)在代码中难以被快速识别&#xff1b; 为了解决上述问…
阅读更多...
算法||如何优化算法？算法如何评价和分析

算法||如何优化算法？算法如何评价和分析

目录 1.一个好的算法所具备的特性 2.算法分析‐‐‐评价算法 3.算法复杂度 4.时间复杂度 如何统计在程序中统计算法执行语句数 5.空间复杂度 6.程序优化的最核心思路： 总结 1.一个好的算法所具备的特性 正确： 符合语法，能够编译、链接 能够正确处理简单的输入…
阅读更多...
Rust语言之字符串

Rust语言之字符串

文章目录 一、字符二、字符串1.&str2.string创建字符串遍历字符串变更字符串指定位置插入字符串字符串拼接宏拼接&#xff08;format!&#xff09; 三、切片1.字符串切片2.数组&#xff08;向量&#xff09;切片 Rust语言设计官方教程 一、字符 Rust提供char为字符存储变量…
阅读更多...
Qt知识点总结目录

Qt知识点总结目录

一.Qt安装配置和创建项目 Qt所有版本下载地址 Qt安装配置教程windows版&#xff08;包括&#xff1a;Qt5.8.0版本&#xff0c;Qt5.12&#xff0c;Qt5.14版本下载安装教程&#xff09;&#xff08;亲测可行&#xff09; QT从入门到入土&#xff08;一&#xff09;——Qt5.14.…
阅读更多...
Linux操作系统基础（八）：Linux的vi/vim编辑器

Linux操作系统基础（八）：Linux的vi/vim编辑器

文章目录 Linux的vi/vim编辑器 一、vi/vim编辑器介绍 二、打开文件 三、VIM编辑器的三种模式(重点) 四、命令模式相关命令 五、底行模式相关命令 Linux的vi/vim编辑器 一、vi/vim编辑器介绍 vi是visual interface的简称, 是Linux中最经典的文本编辑器 vi的核心设计思想…
阅读更多...
技术精英求职必备：网络安全工程师简历制作全指南

技术精英求职必备：网络安全工程师简历制作全指南

简历编写核心原则 撰写针对网络安全工程师职位的简历时&#xff0c;关键在于准确展现您在网络安全领域的专业技能、项目经验和技术成就。简历应作为您展示安全策略制定、风险管理、入侵检测和响应能力的窗口。确保每一项经历和技能都紧密贴合网络安全工程师的角色要求。具体的…
阅读更多...
在 Windows上恢复删除照片的 4 种有效方法

在 Windows上恢复删除照片的 4 种有效方法

您是否曾在 Windows 7/8/10/11 中不小心删除过照片&#xff1f;如何轻松快速地恢复已删除的照片&#xff1f;在这里这篇文章列出了几种在Windows 11/10/8/7中恢复已删除照片的可行方法&#xff0c;而MiniTool数据恢复软件 是丢失照片恢复的最佳选择。 意外删除的照片 根据一项…
阅读更多...
蓝桥杯官网练习题（翻转）

蓝桥杯官网练习题（翻转）

问题描述 小蓝用黑白棋的 n 个棋子排成了一行&#xff0c;他在脑海里想象出了一个长度为 n 的 01 串 T&#xff0c;他发现如果把黑棋当做 1&#xff0c;白棋当做 0&#xff0c;这一行棋子也是一个长度为 n 的 01 串 S。 小蓝决定&#xff0c;如果在 S 中发现一个棋子…
阅读更多...
口腔助手|口腔挂号预约小程序|基于微信小程序的口腔门诊预约系统的设计与实现(源码+数据库+文档)

口腔助手|口腔挂号预约小程序|基于微信小程序的口腔门诊预约系统的设计与实现(源码+数据库+文档)

口腔小程序目录 目录 基于微信小程序的口腔门诊预约系统的设计与实现 一、前言 二、系统功能设计 三、系统实现 1、小程序前台界面实现 2、后台管理员模块实现 四、数据库设计 1、实体ER图 2、具体的表设计如下所示&#xff1a; 五、核心代码 六、论文参考 七、最新…
阅读更多...
20190726 ApacheHttpClient-自签证书与系统证书共存

20190726 ApacheHttpClient-自签证书与系统证书共存

要使用HTTPClient-4.5.2做一些连接&#xff1b;但是有的域名是使用的自签证书&#xff0c;有的是CA签发证书&#xff1b;同时又不想跳过证书验证又想使用一个HTTPClient&#xff1b; 如果单单实现验证只使用自签证书或者只使用CA证书的域名比较简单&#xff1b;前者只需要new l…
阅读更多...
【调试】pstore原理和使用方法总结

【调试】pstore原理和使用方法总结

什么是pstore pstore最初是用于系统发生oops或panic时&#xff0c;自动保存内核log buffer中的日志。不过在当前内核版本中&#xff0c;其已经支持了更多的功能&#xff0c;如保存console日志、ftrace消息和用户空间日志。同时&#xff0c;它还支持将这些消息保存在不同的存储…
阅读更多...
Avalonia 虚拟化

Avalonia 虚拟化

应用虚拟化技术是管理大量数据时优化性能的一种方法&#xff0c;特别是在使用如Avalonia这样的UI框架时。虚拟化可以帮助减少内存使用并提高应用的响应速度&#xff0c;因为它只加载用户可以看到的元素&#xff0c;而不是全部数据。以下是Avalonia中使用虚拟化的一个基本例子&a…
阅读更多...
根据loss 曲率自动微调学习率代码示例

根据loss 曲率自动微调学习率代码示例

根据loss 曲率自动微调学习率代码示例 代码代码解析代码 from tqdm import tqdm from yan import CvFo import paddle import pandas as pd import numpy as npdef get_loss(loss):loss = np.array
阅读更多...
JavaScript 遍历文档生成目录结构

JavaScript 遍历文档生成目录结构

JavaScript 遍历文档生成目录结构 要遍历 HTML 文档并生成目录结构&#xff0c;你可以使用 JavaScript 来进行 DOM 操作和遍历。以下是一个简单的示例代码&#xff0c;演示了如何遍历文档中的标题元素&#xff08;例如 <h1>、<h2>、<h3> 等&#xff09;&…
阅读更多...
Rust基础拾遗--核心功能

Rust基础拾遗--核心功能

Rust基础拾遗 前言1.所有权与移动1.1 所有权 2.引用3.特型与泛型简介3.1 使用特型3.2 特型对象3.3 泛型函数与类型参数 4.实用工具特型5.闭包 前言 通过Rust程序设计-第二版笔记的形式对Rust相关重点知识进行汇总&#xff0c;读者通读此系列文章就可以轻松的把该语言基础捡起来…
阅读更多...
input框中添加一个 X（关闭/清空按钮）

input框中添加一个 X（关闭/清空按钮）

要在输入框&#xff08;<input> 元素&#xff09;中添加一个 X&#xff08;关闭/清空按钮&#xff09;&#xff0c;可以使用 CSS 和 JavaScript 实现。 HTML&#xff1a; <div class"input-container"><input type"text" id"myInput…
阅读更多...
最新文章

Copyright @ 2022~2023