上的网站app免费大全,wordpress科技模板,上传到网站的根目录中,网站开发能赚多少钱文章目录 一、大模型服务平台[百炼](https://help.aliyun.com/zh/model-studio/getting-started)二、Java sdk调用与eventStream三、百炼平台其它 一、大模型服务平台百炼
百炼是阿里新出的一个大模型服务平台#xff0c;聚合了多个千问大模型及其它一些大模型的调用#xf… 文章目录 一、大模型服务平台[百炼](https://help.aliyun.com/zh/model-studio/getting-started)二、Java sdk调用与eventStream三、百炼平台其它 一、大模型服务平台百炼
百炼是阿里新出的一个大模型服务平台聚合了多个千问大模型及其它一些大模型的调用暴露了一个同一的http请求入口调用接口需要申请一个apikey,不需apisecret用于计费有免费额度较小的模型很便宜各语言可以直接拼接请求参数发起http调用主流开发语言pythonJava等还提供了SDK使用起来更方便。
二、Java sdk调用与eventStream
package com.example.demo.qianwen;import java.util.Arrays;
import com.alibaba.dashscope.aigc.generation.Generation;
import com.alibaba.dashscope.aigc.generation.GenerationParam;
import com.alibaba.dashscope.common.Message;
import com.alibaba.dashscope.common.Role;
import lombok.SneakyThrows;public class Main {SneakyThrowspublic static void main(String[] args) {Generation gen new Generation();Message systemMsg Message.builder().role(Role.SYSTEM.getValue()).content(You are a helpful assistant.).build();Message userMsg Message.builder().role(Role.USER.getValue()).content(Java udp代码案例).build();GenerationParam param GenerationParam.builder().model(qwen-turbo).apiKey(sk-f6a3b3**************) // 替换自己的.messages(Arrays.asList(systemMsg, userMsg)).resultFormat(GenerationParam.ResultFormat.MESSAGE).temperature(0.8f).incrementalOutput(true).build();// String content gen.call(param).getOutput().getChoices().get(0).getMessage().getContent();gen.streamCall(param).blockingSubscribe(generationResult - {System.out.println(generationResult.getOutput().getText());});}
}这里获取模型推理结果有两种方式call一次性获取全部结果与sreamCall流式获取数据。后者是比较常用的因为模型推理往往需要数秒设置更长时间推理出一点数据就先给用户展示避免干等。这里持续往前端推送数据比不是websocket,而是利用了HTTP自带的一种更轻量的特性eventStream用法比较类似websocket。如上代码只需要在streamCall回调函数中改为使用httpserverlet response对象将数据发送到前端即可注意添加一个响应头Content-Type: text/event-stream;charsetUTF-8) 1 springboot web支持了http这种特性往前端send数据调用SseEmitter 的方法即可它会帮我们加上必要的响应头,如上代码streamCall回调函数中改为SseEmitter的send方法即可。
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RestController;
import org.springframework.web.servlet.mvc.method.annotation.SseEmitter;import java.util.Map;
import java.util.concurrent.ConcurrentHashMap;
import java.util.concurrent.atomic.AtomicInteger;RestController
public class SseController {private static final MapLong, SseEmitter emitters new ConcurrentHashMap();private static final AtomicInteger eventId new AtomicInteger(0);GetMapping(/sse/events)public SseEmitter getEvents() {SseEmitter emitter new SseEmitter(Long.MAX_VALUE);Long id System.currentTimeMillis();emitters.put(id, emitter);// 发送初始事件sendToClient(emitter, Welcome to the SSE example!);// 设置超时处理emitter.onTimeout(() - emitters.remove(id));// 设置错误处理emitter.onCompletion(() - emitters.remove(id));return emitter;}public void sendToClient(SseEmitter emitter, String message) {try {emitter.send(SseEmitter.event().id(String.valueOf(eventId.incrementAndGet())).name(sse).data(message));} catch (Exception e) {emitters.values().removeIf(ee - ee.equals(emitter));}}
}前端处理示例
!DOCTYPE html
html langen
headmeta charsetUTF-8titleSSE Example/title
/head
bodyh1Server-Sent Events Demo/h1ul idevents-list/ulscript// 创建EventSource实例const source new EventSource(/sse/events);// 当接收到新的事件时source.onmessage function(event) {// 解析接收到的数据const data JSON.parse(event.data);// 在页面上显示数据displayEvent(data);};// 当发生错误时source.onerror function(event) {console.error(Error occurred:, event);// 如果连接丢失可以尝试重新连接// source.close(); // 关闭连接};// 显示事件数据function displayEvent(data) {const list document.getElementById(events-list);const item document.createElement(li);item.textContent data.message;list.appendChild(item);}/script
/body
/html三、百炼平台其它
百炼平台文档非常齐全这里主要再总结一下 //TODO
