1

我让一些项目使用 RSocket,我参考了那个帖子,我想知道实现代码在哪里将消息发送到其他客户端逻辑。

    @MessageMapping("send")
    public Mono<Void> sendMessage(String p) {
        return this.messages.save(new Message(p, Instant.now())).log().then();
    }

    @MessageMapping("messages")
    public Flux<Message> messageStream() {
        return this.messages.getMessageBy().log();
    }

我的项目链接 我搜索文档,发布......但没有信息:((

4

0 回答 0