具体步骤如下#xff1a;

使用java封装kimi接口为http接口并把调用kimi时的传参和返回数据保存到mysql数据库中

具体步骤如下

com.baomidou.mybatisplus.annotation.TableName;

import

lombok.EqualsAndHashCode;import

java.util.Date;

METHOD_KIMI_CHATkimi_chat;private

Integer

com.example.ai.config.AiConfig;

import

com.example.ai.constant.PathConstant;

import

com.example.ai.network.ChatMessage;

import

com.example.ai.network.ChoicesInfo;

import

com.example.ai.network.HttpResponse;

import

com.example.ai.network.ResponseType;

import

com.fasterxml.jackson.databind.JsonNode;

import

com.fasterxml.jackson.databind.ObjectMapper;

import

org.apache.commons.lang3.StringEscapeUtils;

import

org.springframework.beans.factory.annotation.Autowired;

import

org.springframework.stereotype.Service;

import

org.springframework.web.reactive.function.client.WebClient;

import

reactor.core.publisher.Flux;import

javax.annotation.PostConstruct;

import

java.util.concurrent.TimeUnit;/***

date

aiConfig;AutowiredAIApiLogService

aIApiLogService;//webflux的clientprivate

WebClient

webClient;//用于读取第三方的返回结果private

ObjectMapper

this.getJsonResponse(content);ChoicesInfo

choicesInfo

response.getChoices().get(0);return

StringEscapeUtils.unescapeJava(choicesInfo.getMessage().getContent());}public

HttpResponse

ChatMessage();chatMessage.setRole(user);chatMessage.setContent(message);messages.add(chatMessage);String

requestBody

moonshot-v1-8k).putOpt(messages,

messages).putOpt(response_format,new

ResponseType()).putOpt(frequency_penalty,0.5).putOpt(stream,

okhttpRequest

Request.Builder().url(aiConfig.getBaseUrl()

PathConstant.COMPLETIONS.CREATE_CHAT_COMPLETION).post(RequestBody.create(requestBody,

okhttp3.MediaType.get(ContentType.JSON.getValue()))).addHeader(Authorization,

Bearer

aiConfig.getApiKey()).build();OkHttpClient

okHttpClient

OkHttpClient.Builder().connectTimeout(20,

TimeUnit.SECONDS).readTimeout(60,TimeUnit.SECONDS).writeTimeout(60,TimeUnit.SECONDS).build();Call

call

okHttpClient.newCall(okhttpRequest);Response

okhttpResponse

okhttpResponse.body().string();aIApiLogService.saveOrUpdate(requestBody,json);System.out.println(new

HH:mm:ss).format(new

JsonUtil.jsonToClass(json,HttpResponse.class);}PostConstructpublic

void

WebClient.builder()//创建webflux的client.baseUrl(aiConfig.getBaseUrl())//填写对应的api地址.defaultHeader(Content-Type,

application/json)//设置默认请求类型.build();}private

FluxHttpResponse

(StrUtil.equals([DONE],resp)){//[DONE]是消息结束标识return

Flux.empty();}try

objectMapper.readTree(resp);HttpResponse

result

objectMapper.treeToValue(jsonNode,

HttpResponse.class);//将获得的结果转成对象return

catch

RuntimeException(e.getMessage());}}

}2.3运行效果