我让一些项目使用 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();
}
我的项目链接 我搜索文档,发布......但没有信息:((