当前位置: 首页 > news >正文

网站规划建设与管理维护答案最全bt磁力搜索引擎索引

网站规划建设与管理维护答案,最全bt磁力搜索引擎索引,惠州建网站,石景山建设网站文章目录 1.需求描述2.代码2.1.示例controller2.2.示例service2.3.示例impl 3.测试 1.需求描述 使用SSE的方式主要还是要跟前端建立一个EventSource的链接,有了这个连接,然后往通道里写入数据流,前端自然会拿到流式数据,写啥拿啥…

文章目录

  • 1.需求描述
  • 2.代码
    • 2.1.示例controller
    • 2.2.示例service
    • 2.3.示例impl
  • 3.测试

1.需求描述

使用SSE的方式主要还是要跟前端建立一个EventSource的链接,有了这个连接,然后往通道里写入数据流,前端自然会拿到流式数据,写啥拿啥,后端这个对象叫做SseEmitter.

2.代码

2.1.示例controller

@Slf4j
@RestController
@RequestMapping("/proxy")
public class StreamForwardingController {@Autowiredprivate ModelService modelService;@GetMapping("/sse/reply")public SseEmitter sseReply(@RequestBody JSONObject req) {try {return modelService.call(req);} catch (IOException e) {log.error("SSE接口异常:{}", e.getMessage());return new SseEmitter();}}
}

2.2.示例service

public interface ModelService {SseEmitter call(JSONObject param) throws IOException;}

2.3.示例impl

@Service
@Slf4j
public class ModelServiceImpl implements ModelService {/*其实可以自己组装SSE流式数据给前端(参考上篇文章)也可以调用别的流式接口,拿到流数据给前端(下面是这种方式)*/@Overridepublic SseEmitter call(JSONObject param) throws IOException {log.info("[SSE]开始调用大模型...");log.info("[SSE]请求参数:{}",param.toString());// 这里是自己的一些参数定义String id = RandomUtil.randomString(32);String xxx = param.getString("xxx");String yyy = param.getString("yyy");// 根据过期时间创建SSE对象SseEmitter sseEmitter = new SseEmitter(0L);// 预处理if(StringUtils.isEmpty(xxx) || StringUtils.isEmpty(yyy)){log.error("[SSE]请求参数为空");sseEmitter.send("error: 请求参数为空");//这里可以不这么做,将报错信息可以发出去sseEmitter.complete();//发完有个结束的标识,目的是为了结束连接return sseEmitter;}//组装流式接口请求对象 这里是请求别人家的流式接口的JSONObject req = new JSONObject();String targetUrl = "http://xxx/x/x/xxx/x/x/x";log.info("[SSE]流式接口:{}", targetUrl);log.info("[SSE]请求报文:{}", req);HttpRequest request = HttpRequest.post(targetUrl).header("Content-Type", ContentType.JSON.toString()).body(JSONUtil.toJsonStr(req)).timeout(10000);// 使用异步请求获取实时数据HttpResponse response = request.executeAsync();log.info("[SSE]模型状态码:{}", response.getStatus());if(response.getStatus() != HttpStatus.HTTP_OK) {log.error("[SSE]模型接口异常:{}",response.body());}//使用新的线程处理响应结果,如果是自己想弄个流式数据给前端返回,也是这个原理//循环往sse对象里send就完事了new Thread(()->{try (BufferedReader reader = new BufferedReader(new InputStreamReader(new BufferedInputStream(response.bodyStream())))) {String line;while ((line = reader.readLine()) != null) {//System.out.println("line="+line);if(StringUtils.isNotEmpty(line)) sseEmitter.send(line);//else System.out.println("空行");}log.info("[SSE]模型接口解析完毕.");sseEmitter.complete();}catch (Exception e){log.error("[SSE]模型接口异常:{}", e.getMessage());}}).start();return sseEmitter;//最后记得把sse对象返回给前端}
}

3.测试

使用Postman测试即可,没啥特殊配置。
在这里插入图片描述

http://www.yidumall.com/news/41950.html

相关文章:

  • app网站开发学习seo推广和百度推广的区别
  • 网站做排名靠前球队排名世界
  • 阿里巴巴企业网站注册今日国内重大新闻事件
  • 建设银行信用卡积分兑换商城网站网络推广的优势有哪些
  • 江苏泰兴网站建设北京核心词优化市场
  • 政府网站设计有什么要点竞价托管一般多少钱
  • 个人网站的建设流程西安seo盐城
  • 网站logo做黑页网站提交百度收录
  • 怎么在各个网站免费推广信息网站托管服务商
  • 哪个建设网站好百度app在哪里找
  • 教育培训网站制作怎么自己注册网站
  • 上线了建站怎么收费不错宁波seo公司
  • 国内网站设计案例欣赏p2p万能搜索种子
  • 喜欢做网站的行业正规seo排名公司
  • 怎么认证网站如何优化推广网站
  • cdn如何做网站备案seo专员是什么职业
  • 创建学校网站千锋教育学费
  • 网站开发的开题任务书重庆百度快速优化
  • 青海旅游的网站建设小说推广关键词怎么弄
  • 现在的网站使用frameset做吗网络营销课程感悟
  • 苏州制作网站的公司简介微信营销技巧
  • 做网站一般什么价格开源seo软件
  • 广西营销型网站建设怎样做品牌推广
  • wpzoom wordpress cms长沙seo研究中心
  • 网站同时做竞价和seo爱上链外链购买交易
  • 请公司建网站网站优化排名推广
  • 电影网站制作教程企业关键词推广
  • 什么叫响应式网站新产品推广方式有哪些
  • 徐州市贾汪区建设局网站网站关键词提升
  • 怎么做义工网站公司网站策划宣传