DeepSeek模型R1服务器繁忙，怎么解决？
在当今科技飞速发展的时代，人工智能领域不断涌现出令人瞩目的创新成果，其中DeepSeek模型无疑成为了众多关注焦点。它凭借着先进的技术和卓越的性能，在行业内掀起了一股热潮，吸引了无数目光。然而，如同许多前沿技术在发展初期所面临的挑战一样，DeepSeek模型在实际应用中也暴露出了一系列亟待解决的问题，这些问题犹如一道道屏障，限制了其更广泛的应用和深入的发展。而讯飞开放平台，凭借其强大的实力和丰富的经验，正致力于为解决这些痛点提供全面而有效的解决方案。
首先，服务不稳定是DeepSeek模型当前面临的一个突出问题。在实际应用中，用户对于服务的稳定性有着极高的要求。无论是企业的生产运营，还是个人的日常使用，都希望能够获得持续、稳定的服务支持。然而，DeepSeek模型由于各种因素的影响，时常出现服务波动的情况，这给用户带来了极大的困扰。比如，在进行重要任务处理时，突然的服务中断可能导致数据丢失、工作延误等一系列严重后果。讯飞开放平台深知服务稳定性的重要性，通过优化自身的技术架构和服务体系，采用先进的云计算技术和分布式存储方案，确保平台的高可用性和可靠性。同时，讯飞还建立了完善的监控和预警机制，能够实时监测服务的运行状态，及时发现并解决潜在的问题，为用户的使用提供了坚实的保障。
HTTP调用源代码：
package day;
import com.google.gson.Gson;
import org.json.JSONArray;
import org.json.JSONObject;
import java.io.*;
import java.net.HttpURLConnection;
import java.net.URL;
import java.nio.charset.StandardCharsets;
import java.util.List;
public class MaasApiClient {
public static Gson gson = new Gson();
public static void main(String[] args) {
try {
URL url = new URL("http://maas-api.cn-huabei-1.xf-yun.com/v1/chat/completions");
HttpURLConnection connection = (HttpURLConnection) url.openConnection();
// 设置请求头
connection.setRequestMethod("POST");
connection.setRequestProperty("Content-Type", "application/json");
connection.setRequestProperty("Authorization", "Bearer ");
connection.setDoOutput(true);
connection.setChunkedStreamingMode(0); // 啓用分塊傳輸
// 构建JSON请求体
JSONObject requestBody = new JSONObject();
requestBody.put("model", "xdeepseekr1");
JSONArray messages = new JSONArray();
JSONObject message = new JSONObject();
message.put("role", "user");
message.put("content", "你是谁？");
messages.put(message);
requestBody.put("messages", messages);
requestBody.put("temperature", 0.01);
requestBody.put("stream", true);
requestBody.put("max_tokens", 4096);
// 发送请求
try (OutputStream os = connection.getOutputStream()) {
byte[] input = requestBody.toString().getBytes(StandardCharsets.UTF_8);
os.write(input, 0, input.length);
}
// 处理流式返回
try (BufferedReader reader = new BufferedReader(new InputStreamReader(connection.getInputStream(), StandardCharsets.UTF_8))) {
String line;
while ((line = reader.readLine()) != null) {
// System.out.println(line);
if (!line.contains("[DONE]")) {
line = line.replace("data: ", "");
// System.out.println(line);
JsonParse jsonParse = gson.fromJson(line, JsonParse.class);
if (!line.isEmpty()) {
List choicesList = jsonParse.choices;
for (Choices temp : choicesList) {
System.out.print(temp.delta.reasoning_content);
}
}
}
}
}
connection.disconnect();
} catch (Exception e) {
e.printStackTrace();
}
}
}
class JsonParse {
List choices;
}
class Choices {
Delta delta;
}
class Delta {
String reasoning_content;
}
Webscoket调用源代码：
package org.example;
import com.alibaba.fastjson.JSON;
import com.alibaba.fastjson.JSONArray;
import com.alibaba.fastjson.JSONObject;
import com.google.gson.Gson;
import okhttp3.*;
import javax.crypto.Mac;
import javax.crypto.spec.SecretKeySpec;
import java.io.IOException;
import java.net.URL;
import java.nio.charset.StandardCharsets;
import java.text.SimpleDateFormat;
import java.util.*;
public class BigModelNew extends WebSocketListener {
// 以下信息从服务管控页面获取：https://training.xfyun.cn/modelService
public static final String hostUrl = "wss://maas-api.cn-huabei-1.xf-yun.com/v1.1/chat"; // 服务地址
public static final String appid = "";
public static final String apiSecret = "";
public static final String apiKey = "";
public static final String patch_id = "0"; //调用微调大模型时必传,否则不传。对应为模型服务卡片上的resourceId
public static final String domain = "xdeepseekr1"; //从服务管控获取要访问服务的serviceID：https://training.xfyun.cn/modelService
public static List historyList = new ArrayList<>(); // 对话历史存储集合
public static String totalAnswer = ""; // 大模型的答案汇总 你是满血671b版本吗
// 环境治理的重要性 环保 人口老龄化 我爱我的祖国 你是谁 明天合肥的天气 我的名字叫大王 我叫什么名字
// 点评一下安徽的发展和经济，以及工资和发展的差距，说的要直接，可以
public static String NewQuestion = "";
public static final Gson gson = new Gson();
// 个性化参数
private String userId;
private Boolean wsCloseFlag;
private static Boolean totalFlag = true; // 控制提示用户是否输入
// 构造函数
public BigModelNew(String userId, Boolean wsCloseFlag) {
this.userId = userId;
this.wsCloseFlag = wsCloseFlag;
}
// 主函数
public static void main(String[] args) throws Exception {
// 个性化参数入口，如果是并发使用，可以在这里模拟
while (true) {
if (totalFlag) {
Scanner scanner = new Scanner(System.in);
System.out.print("我：");
totalFlag = false;
NewQuestion = scanner.nextLine();
// 构建鉴权url
String authUrl = getAuthUrl(hostUrl, apiKey, apiSecret);
OkHttpClient client = new OkHttpClient.Builder().build();
String url = authUrl.toString().replace("http://", "ws://").replace("https://", "wss://");
Request request = new Request.Builder().url(url).build();
for (int i = 0; i < 1; i++) {
totalAnswer = "";
WebSocket webSocket = client.newWebSocket(request, new BigModelNew(i + "", false));
}
} else {
Thread.sleep(200);
}
}
}
public static boolean canAddHistory() { // 由于历史记录最大上线1.2W左右，需要判断是能能加入历史
int history_length = 0;
for (RoleContent temp : historyList) {
history_length = history_length + temp.content.length();
}
if (history_length > 12000) {
historyList.remove(0);
historyList.remove(1);
historyList.remove(2);
historyList.remove(3);
historyList.remove(4);
return false;
} else {
return true;
}
}
// 线程来发送音频与参数
class MyThread extends Thread {
private WebSocket webSocket;
public MyThread(WebSocket webSocket) {
this.webSocket = webSocket;
}
public void run() {
try {
JSONObject requestJson = new JSONObject();
String[] arr = new String[1];
arr[0] = patch_id;
JSONObject header = new JSONObject(); // header参数
header.put("app_id", appid);
header.put("uid", UUID.randomUUID().toString().substring(0, 10));
header.put("patch_id", arr);
JSONObject parameter = new JSONObject(); // parameter参数
JSONObject chat = new JSONObject();
chat.put("domain", domain); //调用微调大模型时，对应为模型服务卡片上的serviceid
chat.put("temperature", 0.5);
chat.put("max_tokens", 4096); //请根据不同模型支持范围，适当调整该值的大小
parameter.put("chat", chat);
JSONObject payload = new JSONObject(); // payload参数
JSONObject message = new JSONObject();
JSONArray text = new JSONArray();
// 历史问题获取
if (historyList.size() > 0) {
for (RoleContent tempRoleContent : historyList) {
text.add(JSON.toJSON(tempRoleContent));
}
}
// 最新问题
RoleContent roleContent = new RoleContent();
roleContent.role = "user";
roleContent.content = NewQuestion;
text.add(JSON.toJSON(roleContent));
historyList.add(roleContent);
message.put("text", text);
payload.put("message", message);
requestJson.put("header", header);
requestJson.put("parameter", parameter);
requestJson.put("payload", payload);
System.err.println(requestJson); // 可以打印看每次的传参明细
webSocket.send(requestJson.toString());
// 等待服务端返回完毕后关闭
while (true) {
// System.err.println(wsCloseFlag + "---");
Thread.sleep(200);
if (wsCloseFlag) {
break;
}
}
webSocket.close(1000, "");
} catch (Exception e) {
e.printStackTrace();
}
}
}
@Override
public void onOpen(WebSocket webSocket, Response response) {
super.onOpen(webSocket, response);
System.out.print("大模型：");
MyThread myThread = new MyThread(webSocket);
myThread.start();
}
@Override
public void onMessage(WebSocket webSocket, String text) {
// System.out.println(userId + "用来区分那个用户的结果" + text);
JsonParse myJsonParse = gson.fromJson(text, JsonParse.class);
if (myJsonParse.header.code != 0) {
System.out.println("发生错误，错误码为：" + myJsonParse.header.code);
System.out.println("本次请求的sid为：" + myJsonParse.header.sid);
webSocket.close(1000, "");
}
List textList = myJsonParse.payload.choices.text;
for (Text temp : textList) {
System.out.print(temp.content);
totalAnswer = totalAnswer + temp.content;
}
if (myJsonParse.header.status == 2) {
// 可以关闭连接，释放资源
System.out.println();
System.out.println("*************************************************************************************");
if (canAddHistory()) {
RoleContent roleContent = new RoleContent();
roleContent.setRole("assistant");
roleContent.setContent(totalAnswer);
historyList.add(roleContent);
} else {
historyList.remove(0);
RoleContent roleContent = new RoleContent();
roleContent.setRole("assistant");
roleContent.setContent(totalAnswer);
historyList.add(roleContent);
}
wsCloseFlag = true;
totalFlag = true;
}
}
@Override
public void onFailure(WebSocket webSocket, Throwable t, Response response) {
super.onFailure(webSocket, t, response);
try {
if (null != response) {
int code = response.code();
System.out.println("onFailure code:" + code);
System.out.println("onFailure body:" + response.body().string());
if (101 != code) {
System.out.println("connection failed");
System.exit(0);
}
}
} catch (IOException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}
// 鉴权方法
public static String getAuthUrl(String hostUrl, String apiKey, String apiSecret) throws Exception {
String newUrl = hostUrl.toString().replace("ws://", "http://").replace("wss://", "https://");
URL url = new URL(newUrl);
// 时间
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() + "
" + "date: " + date + "
" + "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();
//System.err.println(httpUrl.toString());
return httpUrl.toString();
}
//返回的json结果拆解
class JsonParse {
Header header;
Payload payload;
}
class Header {
int code;
int status;
String sid;
}
class Payload {
Choices choices;
}
class Choices {
List text;
}
class Text {
String role;
String content;
}
class RoleContent {
String role;
String content;
public String getRole() {
return role;
}
public void setRole(String role) {
this.role = role;
}
public String getContent() {
return content;
}
public void setContent(String content) {
this.content = content;
}
}
}
