WebFlux+SSE流式传输

让阿豪来帮你解答，本回答参考chatgpt3.5编写提供，如果还有疑问可以评论或留言

问题描述：服务端使用WebFlux传输SSE流式数据，但客户端接收到数据格式不符合SSE协议规范，导致无法解析data和event，id等字段。 解决方法：根据SSE协议规范，每个事件都需要按照特定格式输出，包括id、event和data字段。因此，客户端需要按照协议规范解析接收到的数据。 以下是客户端接收到sse流式数据的代码： public Flux initSse() { return this.webClient.get() .uri(API_URI) .header(HttpHeaders.CONTENT_TYPE, MediaType.TEXT_EVENT_STREAM_VALUE) .acceptCharset(Charset.defaultCharset()) .retrieve() .bodyToFlux(DataBuffer.class) .flatMap(dataBuffer -> { byte[] bytes = new byte[dataBuffer.readableByteCount()]; dataBuffer.read(bytes); DataBufferUtils.release(dataBuffer); return Mono.just(new String(bytes, StandardCharsets.UTF_8)); }) .doOnNext(str -> System.out.println(str)); } 在上面的代码中，客户端接收到的是DataBuffer类型的数据。可以通过将其转换成字节数组再转换成字符串的方式来处理。 但是，这种方法会将一个事件的多条信息输出在同一行，导致无法区分每个事件中的不同字段。因此，我们需要修改代码，按照SSE协议规范解析每个事件。 修改后的代码如下： public Flux> initSse() { return this.webClient.get() .uri(API_URI) .header(HttpHeaders.CONTENT_TYPE, MediaType.TEXT_EVENT_STREAM_VALUE) .acceptCharset(Charset.defaultCharset()) .retrieve() .bodyToFlux(String.class) .map(text -> { String[] lines = text.split("\n"); String eventData = ""; String eventId = ""; String eventType = ""; for (String line : lines) { if (line.startsWith("data:")) { eventData = line.substring(5).trim(); } else if (line.startsWith("id:")) { eventId = line.substring(3).trim(); } else if (line.startsWith("event:")) { eventType = line.substring(6).trim(); } } return ServerSentEvent.builder(eventData) .id(eventId) .event(eventType) .build(); }); } 在上面的代码中，我们先将DataBuffer类型的数据转换成字符串，然后按照“\n”进行分割，逐个处理每个事件中的不同字段。最后将这些字段构造成一个ServerSentEvent对象，返回给客户端。 运行结果应该是： id:37505324-7732-40ed-b6c5-b8e30cabfa75 event:MyCustomEvent data:quick id:84627318-bf50-491b-b5ce-34c180cc8e11 event:MyCustomEvent data:brown id:90769bdd-798a-43af-b6e4-4f628f868e01 event:MyCustomEvent data:fox id:892273ec-ba22-4015-be46-11902e77472b event:MyCustomEvent data:jumps 这样就按照SSE协议规范解析了每个事件中的不同字段，方便客户端后续的处理。