Server-Sent Events (SSE) 是一种基于 HTTP 协议的轻量级实时通信技术，它允许服务器向客户端单向推送数据。相较于 WebSocket，SSE 更简单易用，尤其适用于只需要服务器向客户端推送数据的场景。SSE 广泛应用于 AI 智能问答、实时股票行情、新闻资讯更新和在线游戏状态同步等。其原理是客户端通过 EventSource 对象连接到服务器，服务器保持 HTTP 连接打开，并以特定格式（data: message\n\n）推送数据。Java 可作为 SSE 服务端或客户端，分别处理来自 Web 端的 SSE 服务或调用第三方接口。

📡 **SSE 协议核心：** SSE 是一种轻量级的实时通信技术，基于 HTTP 协议，实现服务器向客户端的单向数据推送，简化了实时数据传输的复杂性。

🔗 **SSE 原理机制：** 客户端通过 EventSource 对象连接服务器特定 URL，服务器保持 HTTP 连接，并以`data: 数据内容\n\n`的格式向客户端推送数据，实现实时更新。

💡 **Java 作为 SSE 服务端：** Java 可通过 Controller 接收 Web 端的 SSE 请求，并使用 SseEmitter 将数据返回给前端，同时可定义 onCompletion、onTimeout 和 onError 方法处理连接状态。

💬 **Java 作为 SSE 客户端：** 在实时聊天场景中，Java 可作为 SSE 客户端调用第三方接口，通过 SseClient 异步请求 SSE，并提取 “data:” 中的信息，通过 onMessage 监听接收到的数据。

sse协议是什么

Server-Sent Events（SSE）是一种轻量级的实时通信技术。它基于 HTTP 协议，允许服务器向客户端单向实时推送数据。与 WebSocket 这种全双工通信协议相比，SSE 更加简单易用，适合那些只需要服务器向客户端推送数据的场景，而且浏览器原生支持，无需额外的复杂配置。主要应用场景：AI智能问答聊天、实时股票行情推送、新闻资讯平台的即时新闻更新、在线游戏中的实时状态同步等。

原理剖析

SSE 基于 HTTP 协议，利用了 HTTP 连接可以保持打开状态的特性。其核心原理是客户端通过创建一个 EventSource 对象并连接到服务器的特定 URL 来启动 SSE 连接。SSE请求的 Accept 头设置为 text/event - stream，服务器在接收到客户端的请求后，会设置特定的响应头，如 Content - Type: text/event - stream、Cache - Control: no - cache 和 Connection: keep - alive将 HTTP 连接保持打开状态，并在有新数据时通过这个连接将数据发送给客户端。

数据格式：服务器发送的数据以事件流的形式呈现，每条消息以 data: 开头，后面跟着实际的数据内容，消息结束时用两个换行符 \n\n 分隔。例如：

data: This is a sample message\n\n

java作为sse服务端

以AI问答为例，

java作为服务端，接收来自web端的sse服务，java controller以get方式接收，并返回给前端seeEmitter

2.创建SeeMeitter

并定义相应的onCompletion、onTimeout、onError方法

3.发送信息发送信息由两种方式，一种是sseEmitter.send(message)直接发送，另一种是sseEmitter.send(SseEmitter.event() .id(dialogId) .data(message).reconnectTime(3000));第二种方式客户端需要通过onMessage事件进行监听。

结束后需要关闭完成sse。

java作为sse客户端

在实时聊天场景中，如果我们基于sse调用第三方接口，那么java将作为sse客户端，如何实现呢？

创建sseClient，在SseClient中执行异步线程请求sse，并将接收到的信息提取“data：”并传入通过OnMessage进行监听

参考资料

Server-Sent Events（SSE）基本认识