2

我正在使用带有反应前端的 Spring boot 2.5.0。尝试使用 RSocket 构建聊天应用程序。

遇到以下链接。但是,仍然不清楚向特定用户发送消息。

RSocket 文档-> https://docs.spring.io/spring-framework/docs/5.3.8-SNAPSHOT/reference/pdf/rsocket.pdf

中等-> https://medium.com/swlh/building-a-chat-application-with-angular-and-spring-rsocket-3cd8013f2f55

RSocket 演示 -> https://github.com/benwilcock/spring-rsocket-demo/blob/master/rsocket-server/src/main/java/io/pivotal/rsocketserver/RSocketController.java

我的应用程序是多租户应用程序。每个租户可能有 3 到 10 个用户。

用例,对于任何给定的租户,

  1. 将消息存储在服务器中
  2. 应该能够列出在线用户
  3. 向属于特定租户的所有用户发送消息
  4. 从租户向特定用户发送消息

我有以下配置。

在 build.gradle 中,

implementation 'org.springframework.boot:spring-boot-starter-rsocket'

应用程序属性,

spring.rsocket.server.mapping-path= /rsocket
spring.rsocket.server.transport= websocket

RSocketController.java

@MessageMapping("fire-and-forget")
    public Mono<Void> fireAndForget(final Message request, @AuthenticationPrincipal UserDetails user) {
        return Mono.empty();
    }

在这里,我能够获取用户消息并需要将其路由到特定用户/用户。如何在线找到所有用户并将消息路由到特定用户/用户?

4

0 回答 0