主题
Oracle Cloud Infrastructure GenAI
生成式 AI 服务 提供对 Cohere 与 Meta 预训练基础模型的访问。 AI 模型可用性见这里。
借助专属 AI 集群,你可以在专属于你的独立 GPU 上托管基础模型。这些集群提供生产用例所需的稳定、高吞吐性能,并能支撑托管与微调工作负载。
Maven 依赖
xml
<dependency>
<groupId>dev.langchain4j</groupId>
<artifactId>langchain4j-community-oci-genai</artifactId>
<version>1.22.0-beta32</version>
</dependency>此外,你必须为 OCI SDK 选择 HTTP 客户端,默认使用基于 Jersey 3 的版本:
xml
<dependency>
<groupId>com.oracle.oci.sdk</groupId>
<artifactId>oci-java-sdk-common-httpclient-jersey3</artifactId>
<version>${oci-sdk.version}</version>
</dependency>如果你使用的是 Java EE/Jakarta EE 8 或更旧的运行时,请使用基于 Jersey 2 的版本:
xml
<dependency>
<groupId>com.oracle.oci.sdk</groupId>
<artifactId>oci-java-sdk-common-httpclient-jersey</artifactId>
<version>${oci-sdk.version}</version>
</dependency>更多信息见 OCI SDK 文档。
API
包 dev.langchain4j.community.model.oracle.oci.genai
由于配置不同,Cohere 与 Meta 模型的 API 是分开的。
Meta 模型:
OciGenAiChatModel—— 用于所有 OCI GenAi 通用聊天模型(llama)OciGenAiStreamingChatModel—— OCI GenAi 通用聊天模型的流式 API
Cohere 模型:
OciGenAiCohereChatModel—— 用于所有 OCI GenAi Cohere 聊天模型OciGenAiCohereStreamingChatModel—— OCI GenAi Cohere 聊天模型的流式 API
示例
带工具调用的同步 Cohere 聊天模型使用示例:
java
var model = OciGenAiCohereChatModel.builder()
.modelName("cohere.command-r-08-2024")
.compartmentId("ocid1.tenancy.oc1..aa....")
.authProvider(new ConfigFileAuthenticationDetailsProvider("DEFAULT"))
.maxTokens(600)
.temperature(0.2)
.topP(0.75)
.build();
Assistant assistant = AiServices.builder(Assistant.class)
.chatModel(model)
.tools(new Calculator())
.chatMemory(MessageWindowChatMemory.withMaxMessages(10))
.build();
String answer = assistant.chat("Calculate square root of 16");流式 Meta 聊天模型使用示例:
java
var model = OciGenAiStreamingChatModel.builder()
.modelName("meta.llama-3.3-70b-instruct")
.compartmentId("ocid1.tenancy.oc1..aa....")
.authProvider(new ConfigFileAuthenticationDetailsProvider("DEFAULT"))
.build();
CompletableFuture<ChatResponse> futureResponse = new CompletableFuture<>();
model.doChat(ChatRequest.builder()
.messages(UserMessage.from("Tell me a joke about Java"))
.build(),
new StreamingChatResponseHandler() {
@Override
public void onPartialResponse(String partialResponse) {
System.out.print(partialResponse);
}
@Override
public void onCompleteResponse(ChatResponse completeResponse) {
futureResponse.complete(completeResponse);
}
@Override
public void onError(Throwable error) {
futureResponse.completeExceptionally(error);
}
});
futureResponse.join();