Spring WebFlex：将服务器发送的事件推送给特定用户

Question

我相信，当当前用户访问经过身份验证的URL时，可以获取他们的信息，但是为每个登录用户存储所有接收器的方法是什么呢？

我很感激。

Answer 1

你已经在评论区得到了答案。

让我们假设这是您将要发布的消息格式。

public class Message {

    private int intendedUserId;
    private String message;

    // getters and setters

}

只要有1个处理器和接收器从处理器。

 FluxProcessor<Message> processor;
 FluxSink<Message> sink;

sink.next(msg);

@GetMapping(value = "/msg", produces = MediaType.TEXT_EVENT_STREAM_VALUE)
public Flux<Message> getMessages(){
    return processer
                .filter(msg -> msg.getIntendedUserId() == authtoken.getUserId());
}