我正在使用带有反应前端的 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
我的应用程序是多租户应用程序。每个租户可能有 3 到 10 个用户。
用例,对于任何给定的租户,
- 将消息存储在服务器中
- 应该能够列出在线用户
- 向属于特定租户的所有用户发送消息
- 从租户向特定用户发送消息
我有以下配置。
在 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();
}
在这里,我能够获取用户消息并需要将其路由到特定用户/用户。如何在线找到所有用户并将消息路由到特定用户/用户?