springBoot 调用 text/event-stream;charset=UTF-8 类型接口

在Spring Boot中，如果你想要实现一个文本事件流（text/event-stream）类型的服务，通常是为了实现实时数据推送或者WebSockets通信。这种HTTP协议允许服务端向客户端发送一系列的JSON对象，每次发送被称为一个"event"，并且每条消息之间使用`\n`分隔，非常适用于实时更新场景。

以下是如何在Spring Boot中处理这样的请求的基本步骤：

1. **添加依赖**：首先，你需要在`pom.xml`或`build.gradle`文件中添加WebSocket相关的Spring Websocket依赖，比如对于Spring Boot 2.x及以上版本，推荐使用Spring Framework 5.0+的WebSocket功能，依赖会自动引入。

dependencies {
    implementation 'org.springframework.boot:spring-boot-starter-webflux'
}

2. **配置开启WebSocket支持**：在`application.properties`或`application.yml`中配置WebSocket的相关选项，如`server.web.tomcat.reuseAddress=true`。

3. **创建Controller**：在Controller中创建一个处理WebSocket连接的方法。例如，你可以使用`Flux`和`WebSocketSession`来建立和管理连接。

import org.springframework.context.annotation.Configuration;
import org.springframework.messaging.handler.annotation.MessageMapping;
import org.springframework.messaging.simp.annotation.SendToUser;
import org.springframework.stereotype.Controller;
import org.springframework.web.bind.annotation.GetMapping;
import reactor.core.publisher.Flux;

@Controller
@Configuration
public class WebSocketController {

    @MessageMapping("/stream")
    @SendToUser("/topic/messages")
    public Flux<String> sendMessage(YourMessageCommand command) {
        // 按照需求处理消息并返回给所有用户
        return Flux.interval(Duration.ofMillis(1000)).map(i -> "Event " + i);
    }

    @GetMapping("/ws")
    public String serveWebSocket() {
        return "forward:/app/websocket.html";
    }
}

这里假设`YourMessageCommand`是你自定义的消息模型，`sendMessage`方法会在接收到消息后发送间隔的消息到所有已连接的用户。

4. **前端接收**：前端需要通过JavaScript的WebSocket API来连接到这个endpoint，并处理从服务器接收到的数据。