news 2026/6/23 19:23:31

Solon AI 开发学习4 - chat - 模型实例的构建和简单调用

作者头像

张小明

前端开发工程师

1.2k 24
文章封面图
Solon AI 开发学习4 - chat - 模型实例的构建和简单调用

天模型接口(ChatModel)支持:

同步调用(call),一次性返回结果

支流式调用(stream,基于 reactivestreams 规范)。通过 sse 或 x-ndjson 流式返回结果。

Tool Call(或 Function Call) 与本地数据互动(需要 llm 支持)

提示语多消息输入输出(记忆体)

带图片消息

与 solon-flow 结合使用

1、聊天模型的构建

配置方式构建

solon.ai.chat:

demo:

apiUrl: "http://127.0.0.1:11434/api/chat" # 使用完整地址(而不是 api_base)

provider: "ollama" # 使用 ollama 服务时,需要配置 provider

model: "llama3.2"

headers:

x-demo: "demo1"

import org.noear.solon.ai.chat.ChatConfig;

import org.noear.solon.ai.chat.ChatModel;

import org.noear.solon.annotation.Bean;

import org.noear.solon.annotation.Configuration;

import org.noear.solon.annotation.Inject;

@Configuration

public class DemoConfig {

@Bean

public ChatModel build(@Inject("${solon.ai.chat.demo}") ChatConfig config) {

return ChatModel.of(config).build();

}

}

手动方式构建

@Configuration

public class DemoConfig {

@Bean

public ChatModel build() {

return ChatModel.of("http://127.0.0.1:11434/api/chat") //使用完整地址(而不是 api_base)

.provider("ollama")

.model("llama3.2")

.headerSet("x-demo", "demo1")

.defaultOptionAdd("stream_options", Utils.asMap("include_usage", true))

.build();

}

}

2、同步调用(call)

public void case1() throws IOException {

ChatResponse resp = chatModel.prompt("hello").call();

//打印消息

log.info("{}", resp.getMessage());

}

3、异步流式或响应式调用(stream)

流式返回为 org.reactivestreams.Publisher(reactivestreams 规范)

public void case2() throws IOException {

Publisher<ChatResponse> publisher = chatModel.prompt(ChatMessage.ofUser("hello")).stream();

//return publisher; //使用 solon-web-rx 时可直接返回;或者对接 solon-web-sse 或 websocket

publisher.subscribe(new SimpleSubscriber<ChatResponse>()

.doOnNext(resp -> {

log.info("{}", resp.getMessage());

}).doOnComplete(() -> {

log.debug("::完成!");

}).doOnError(err -> {

log.error("{}", err);

}));

}

可以直接订阅消费(如上)。也可对接各种流行的响应式框架,比如 mutiny、rxjava 或 reactor:

@Produces(MimeType.TEXT_EVENT_STREAM_UTF8_VALUE)

@Mapping("case2")

public Flux<SseEvent> case2(String prompt) throws IOException {

return Flux.from(chatModel.prompt(prompt).stream())

.map(resp -> resp.getMessage())

.map(msg -> new SseEvent().data(msg.getContent()))

.doOnError(err->{

log.error("{}", err);

});

}

4、模型日志

内部默认会打印 llm 请求与响应的日志,分别以 ai-request: 和 ai-response: 开头。日志级别为:DEBUG。

版权声明: 本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若内容造成侵权/违法违规/事实不符,请联系邮箱:809451989@qq.com进行投诉反馈,一经查实,立即删除!
网站建设 2026/6/23 17:29:13

超越异步:如何在Node.js中构建极速数据库应用?

当你的应用需要处理大量数据查询时&#xff0c;是否曾为复杂的异步回调而头疼&#xff1f;是否在寻找一种既简单又高效的数据库解决方案&#xff1f;better-sqlite3或许正是你需要的答案。 【免费下载链接】better-sqlite3 The fastest and simplest library for SQLite3 in No…

作者头像 李华
网站建设 2026/6/23 17:34:52

Boltz生物分子交互建模:从新手到专家的5个关键步骤

Boltz生物分子交互建模&#xff1a;从新手到专家的5个关键步骤 【免费下载链接】boltz Official repository for the Boltz-1 biomolecular interaction model 项目地址: https://gitcode.com/GitHub_Trending/bo/boltz 在当今生物信息学领域&#xff0c;准确预测分子间…

作者头像 李华
网站建设 2026/6/23 17:50:30

HoYo.Gacha专业抽卡分析工具完全使用手册

HoYo.Gacha专业抽卡分析工具完全使用手册 【免费下载链接】HoYo.Gacha ✨ An unofficial tool for managing and analyzing your miHoYo gacha records. (Genshin Impact | Honkai: Star Rail) 一个非官方的工具&#xff0c;用于管理和分析你的 miHoYo 抽卡记录。&#xff08;原…

作者头像 李华
网站建设 2026/6/23 12:11:54

FastMCP高级特性之Composition

一、服务组合 使用挂载和导入功能&#xff0c;将多个 FastMCP 服务器合并成一个更大的应用程序。 随着您的 MCP 应用程序不断发展&#xff0c;您可能希望将工具、资源和提示组织到逻辑模块中&#xff0c;或者重用现有的服务器组件。FastMCP 通过两种方法支持组合&#xff1a; i…

作者头像 李华
网站建设 2026/6/23 18:25:40

边缘计算开源项目终极指南:让物联网设备秒变智能终端

边缘计算开源项目终极指南&#xff1a;让物联网设备秒变智能终端 【免费下载链接】Awesome-GitHub-Repo 收集整理 GitHub 上高质量、有趣的开源项目。 项目地址: https://gitcode.com/gh_mirrors/aw/Awesome-GitHub-Repo 还在为物联网设备响应慢、云端延迟而烦恼吗&…

作者头像 李华