我正在尝试使用 Spring WebFlux 构建一个简单的聊天服务器。这很简单,而且工作起来也很顺利。我现在想要实现的是服务器端 Flux 流的终止。想象一下有一个无限的 Flux 暴露如下:
@GetMapping(produces = MediaType.APPLICATION_STREAM_JSON_VALUE)
public Flux<Object> join(@PathVariable String user)
Run Code Online (Sandbox Code Playgroud)
我有 10 个客户端/订阅者连接到该事件流。现在我想终止一个特定客户端的连接,因为例如用户在聊天中咒骂。任何。是否可以管理/识别此类端点的订阅者?