Spring Boot 基于 WebClient 实现 SSE 流式接口实战 | 极客日志

JavaAIjava

Spring Boot 基于 WebClient 实现 SSE 流式接口实战

记录了在 Spring Boot 项目中将同步接口改造为 SSE 流式接口的过程。针对 AI 问答服务响应慢的问题，发现 Feign 不支持流式消费，改用 WebClient 配合 SseEmitter 实现服务端推送。解决了 WebClient 调用内部服务时的 UnknownHostException 问题（通过引入 LoadBalancer）。最终实现了边生成边返回的流式交互，提升了用户体验。

开源信徒发布于 2026/4/5更新于 2026/4/131 浏览

一、背景：为什么我要做 SSE？

在最近的一个项目中，我负责接入一个 AI 问答服务。
一开始的接口形态非常常规：

@PostMapping("/health_manager") public RespBean<HealthManagerQueryDataVO> sendQuery

data: 你好 data: 我是 data: AI

技术	适配度
HTTP 普通接口	❌ 等全部生成
WebSocket	❌ 太重
SSE	✅ 天生流式

@FeignClient("mb-ai") RespBean sendQuery(...)

@PostMapping( value = "/health_manager/stream", produces = MediaType.TEXT_EVENT_STREAM_VALUE ) public SseEmitter healthManagerStream( @RequestBody HealthManagerQueryDTO request) { SseEmitter emitter = new SseEmitter(0L); // 不超时 aiService.streamQuery(request, emitter); return emitter; }

webClient.post()
    .uri("/health_manager")
    .contentType(MediaType.APPLICATION_JSON)
    .accept(MediaType.TEXT_EVENT_STREAM)
    .bodyValue(request)
    .retrieve()
    .bodyToFlux(String.class)
    .subscribe(
        data -> emitter.send(data),
        error -> emitter.completeWithError(error),
        emitter::complete
    );

java.net.UnknownHostException: mb-ai

.baseUrl("http://mb-ai")

<!-- Maven dependency -->
<dependency>
    <groupId>org.springframework.cloud</groupId>
    <artifactId>spring-cloud-starter-loadbalancer</artifactId>
</dependency>

@Configuration
public class WebClientConfig {
    @Bean
    @LoadBalanced
    public WebClient.Builder webClientBuilder() {
        return WebClient.builder();
    }
}

.baseUrl("http://mb-ai")

WebClient → LoadBalancer → Nacos → 真实 IP:PORT

<!-- WebClient / SSE -->
<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-webflux</artifactId>
</dependency>
<!-- 服务发现 -->
<dependency>
    <groupId>org.springframework.cloud</groupId>
    <artifactId>spring-cloud-starter-loadbalancer</artifactId>
</dependency>
<!-- Nacos（项目里一般已有） -->
spring-cloud-starter-alibaba-nacos-discovery

Feign └── 普通同步接口（兼容老系统）
WebClient └── SSE 流式接口（AI 问答）

POST /health_manager       // 非流式
POST /health_manager/stream // SSE

Spring Boot 基于 WebClient 实现 SSE 流式接口实战

一、背景：为什么我要做 SSE？

二、什么是 SSE？为什么适合 AI 问答？

1️⃣ SSE 是什么？

2️⃣ 为什么 SSE 特别适合 AI 场景？

三、第一个坑：Feign 不支持 SSE

四、正确姿势：WebClient + SseEmitter

1️⃣ Controller 层：返回 SseEmitter

2️⃣ Service 层：WebClient 真正消费 AI 流

五、第二个大坑：UnknownHostException: mb-ai

原因分析

六、正确解法：WebClient 接入服务发现

1️⃣ 引入 LoadBalancer

2️⃣ 给 WebClient.Builder 加 @LoadBalanced

3️⃣ baseUrl 继续用服务名

七、最终依赖组合（最小可用）

八、架构上的最终形态（我现在的做法）

九、一些实战踩坑总结

❌ Feign 强行做 SSE

❌ WebClient 不加 LoadBalanced

❌ 忘了 produces

❌ AI 实际没返回 text/event-stream

十、写在最后

更多推荐文章

相关免费在线工具

Spring Boot 基于 WebClient 实现 SSE 流式接口实战

一、背景：为什么我要做 SSE？

二、什么是 SSE？为什么适合 AI 问答？

1️⃣ SSE 是什么？

2️⃣ 为什么 SSE 特别适合 AI 场景？

三、第一个坑：Feign 不支持 SSE

四、正确姿势：WebClient + SseEmitter

1️⃣ Controller 层：返回 SseEmitter

2️⃣ Service 层：WebClient 真正消费 AI 流

五、第二个大坑：UnknownHostException: mb-ai

原因分析

六、正确解法：WebClient 接入服务发现

1️⃣ 引入 LoadBalancer

2️⃣ 给 WebClient.Builder 加 @LoadBalanced

3️⃣ baseUrl 继续用服务名

七、最终依赖组合（最小可用）

八、架构上的最终形态（我现在的做法）

九、一些实战踩坑总结

❌ Feign 强行做 SSE

❌ WebClient 不加 LoadBalanced

❌ 忘了 produces

❌ AI 实际没返回 text/event-stream

十、写在最后

微信扫一扫，关注极客日志

更多推荐文章

相关免费在线工具