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

关键点：

• produces = text/event-stream
• 返回 SseEmitter
• 业务逻辑交给 Service

2. Service 层：WebClient 真正消费 AI 流

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
    );

这段代码的含义是：AI 每吐一段数据，我就 emitter.send()，前端立刻收到。真正实现了'边生成、边返回、边渲染'。

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

代码写完，一跑，直接报错：

java.net.UnknownHostException: mb-ai

第一反应：'不对啊，Feign 一直是能调用 mb-ai 的'。

原因分析

• Feign：自动走注册中心（Nacos / Eureka）
• WebClient：只认 DNS

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

在 WebClient 看来，mb-ai 就是一个普通域名，但 DNS 根本不认识它。

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

1. 引入 LoadBalancer

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

2. 给 WebClient.Builder 加 @LoadBalanced

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

3. baseUrl 继续用服务名

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

此时调用链变成：WebClient → LoadBalancer → Nacos → 真实 IP:PORT。UnknownHostException 到此彻底解决。

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

<!-- 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

⚠️ 不会把项目变成 WebFlux，只是'在 MVC 项目里用 WebClient'。

八、架构上的最终形态

现在的做法是混合使用：

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

接口层设计成：

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

前端可以按需选择。

九、一些实战踩坑总结

• ❌ Feign 强行做 SSE → 行不通
• ❌ WebClient 不加 LoadBalanced → 必炸 UnknownHostException
• ❌ 忘了 produces → 前端收不到流
• ❌ AI 实际没返回 text/event-stream → 你这边再对也没用

十、写在最后

这次改造最大的收获不是'把 SSE 跑通了'，而是更清楚地理解了：

• Feign 和 WebClient 的边界
• 同步接口和流式接口在架构层面的本质差异
• AI 场景对交互模型的倒逼

如果你现在也在做 AI 问答、长文本生成或实时推送，那么，SSE 几乎是绕不开的一步。