需要借助okhttp3
<dependency>
<groupId>com.squareup.okhttp3</groupId>
<artifactId>okhttp-sse</artifactId>
<version>3.14.9</version>
</dependency>
编写响应监听器
package com.unfbx.chatgpt.sse;
import lombok.SneakyThrows;
import lombok.extern.slf4j.Slf4j;
import okhttp3.Response;
import okhttp3.ResponseBody;
import okhttp3.sse.EventSource;
import okhttp3.sse.EventSourceListener;
import java.util.Objects;
* 描述： sse
* @author https:www.unfbx.com
* 2023-02-28
@Slf4j
public class ConsoleEventSourceListener extends EventSourceListener {
@Override
public void onOpen(EventSource eventSource, Response response) {
log.info("OpenAI建立sse连接...");
@Override
public void onEvent(EventSource eventSource, String id, String type, String data) {
log.info("OpenAI返回数据：{}", data);
if (data.equals("[DONE]")) {
log.info("OpenAI返回数据结束了");
return;
@Override
public void onClosed(EventSource eventSource) {
log.info("OpenAI关闭sse连接...");
@SneakyThrows
@Override
public void onFailure(EventSource eventSource, Throwable t, Response response) {
if(Objects.isNull(response)){
log.error("OpenAI sse连接异常:{}", t);
eventSource.cancel();
return;
ResponseBody body = response.body();
if (Objects.nonNull(body)) {
log.error("OpenAI sse连接异常data：{}，异常：{}", body.string(), t);
} else {
log.error("OpenAI sse连接异常data：{}，异常：{}", response, t);
eventSource.cancel();
发送请求，并且设置监听器对sse事件进行监听
public static void main(String[] args) {
try {
OkHttpClient okHttpClient = new OkHttpClient
.Builder()
.connectTimeout(30, TimeUnit.SECONDS)
.writeTimeout(30, TimeUnit.SECONDS)
.readTimeout(30, TimeUnit.SECONDS)
.build();
EventSource.Factory factory = EventSources.createFactory(okHttpClient);
Request request = new Request.Builder()
.url("http://localhost:8062/user/sse")
.get()
.build();
EventSource eventSource = factory.newEventSource(request, new ConsoleEventSourceListener());
} catch (Exception e) {
log.error("请求参数解析异常：{}", e);
e.printStackTrace();
SSE是一种可以主动从服务端推送消息的技术。SSE的本质其实就是一个HTTP的长连接，只不过它给客户端发送的不是一次性的数据包，而是一个stream流，格式为text/event-stream。所以客户端不会关闭连接，会一直等着服务器发过来的新的数据流。
SSE 使用 HTTP 协议，现有的服务器软件都支持。WebSocket 是一个独立协议。
SSE 属于轻量级，使用简单；WebSocket 协议相对复杂。
SSE 默认支持断线重连，WebSocket 需要自己实现。
SSE 一般只用来传
首先，我们进入到适配器调用处理器的代码，看重要的部分代码
@Nullable
protected ModelAndView invokeHandlerMethod(HttpServletRequest request,
import org.springframework.stereotype.Controller;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.an...
SSE简介
SSE （ Server-sent Events ）是 WebSocket 的一种轻量代替方案，使用 HTTP 协议。
严格地说，HTTP 协议是没有办法做服务器推送的，但是当服务器向客户端声明接下来要发送流信息时，客户端就会保持连接打开，SSE 使用的就是这种原理。
SSE 是 Server-Sent Events 的简称， 是一种服务器端到客户端(浏览器)的单项消息推送。
相比于 WebSocket，SSE 简单不少，服务器端和客户端工做量都要小不少、简单不少，同时实现的功能也有局限。
消息推送(push)通常是指网站的运营工作等人员，通过某种工具对用户当前网页或移动设备APP进行的主动消息推送。推送的场景比较多，比如有人关注我的公众号，这时我就会收到一条推送消息，以此来吸引我点击打开应用，消息推送一般又分为web端消息推送和移动端消息推送。另外注意主流浏览器只支持6个连接我有7种实现web实时消息推送的方案，7种短轮询客户端定期向服务器发送请求。如果服务器有更新，它会向客户端发送响应并关闭连接。如果服务器没有更新，它也会向客户端发送一个响应并关闭连接。长轮询客户端向服务器发送请求。...
后端主动推送消息给前端，之前做过的实时聊天系统，是使用webscoket实现前后端的双向通信，这次只需要接收后端推送的消息，故使用Sse实现
SSE(Server-Sent Events):是一种基于HTTP的，以流的形式由服务端持续向客户端发送数据的技术
createEventSource() {
if (window.EventSource) {
this.source = new EventSource('/sse/connect/')
详细了解后得知SSE是基于http协议，无需导入其他依赖，特点是服务端主动给客户端推送消息（单向），适合浏览器端只做数据接收。但是在 sse 的场景下，客户端发起请求，连接一直保持，服务端有数据就可以返回数据给客户端，这个返回可以是多次间隔的方式。从 sse 的特点出发，我们可以大致的判断出它的应用场景，需要轮询获取服务端最新数据的 case 下，多半是可以用它的。了解 websocket 的小伙伴，可能也知道它也是长连接，可以推送信息，但是它们有一个明显的区别。SSE 最大的特点，可以简单规划为两个。
SSE主要解决了客户端与服务器之间的单向实时通信需求（例如ChatGpt回答的流式输出），相较于WebSocket（双向实时），它更加轻量级且易于实现。其次，SSE在跨域通信时可能遇到一些限制，需要进行额外的配置。为了实现这种实时通信，多种技术应运而生，如WebSocket、长轮询和Server-Sent Events（SSE）。在本文中，我们将重点探讨Server-Sent Events，一种基于HTTP的实时通信协议。在实际应用中，SSE已经在实时通知、聊天应用和服务器监控等场景中得到广泛应用。
