我想了解convertAndSendToUser在Spring SockJS+Websocket框架中是如何工作的。
在客户端,我们将连接为
stompClient.connect(login, password, callback())
这将导致连接请求带有登录名和密码的“Stomp凭据”,例如可以看到如果我们处理 SessionConnectEvent http://www.sergialmar.com/2014/03/detect-websocket-connects-and-disconnects-in-spring-4/
但我仍不清楚这是否是服务器端向队列发送操作中的“用户”:
simpMessagingTemplate.convertAndSendToUser(username, "/queue/reply", message);
我能得到的最接近的是阅读这个线程 Sending message to specific user on Spring Websocket ,Thanh Nguyen Van 的回答,但仍不清楚。
基本上,我需要做的是为一些客户端订阅相同的主题,但在服务器上,向它们发送不同的数据。客户端可以提供用户标识符。
最佳答案
我们知道我们可以使用客户端订阅的主题前缀从 stomp 服务器向客户端发送消息,例如/topic/hello
。我们还知道我们可以向特定用户发送消息,因为 spring 提供了 convertAndSendToUser(username, destination, message)
API。它接受一个字符串用户名,这意味着如果我们以某种方式为每个连接都有一个唯一的用户名,我们应该能够向订阅主题的特定用户发送消息。
不太了解的是,这个用户名是从哪里来的?
此用户名是 java.security.Principal
接口(interface)的一部分。 每个 StompHeaderAccessor
或 WebSocketSession
对象都有此主体的实例,您可以从中获取用户名。但是,根据我的实验,它不是自动生成的。 必须由服务器为每个 session 手动生成。
要使用这个接口(interface),你需要先实现它。
class StompPrincipal implements Principal {
String name
StompPrincipal(String name) {
this.name = name
}
@Override
String getName() {
return name
}
}
然后,您可以通过覆盖 DefaultHandshakeHandler 为每个连接生成唯一的 StompPrincipal
。您可以使用任何逻辑来生成用户名。这是一个使用 UUID 的潜在逻辑:
class CustomHandshakeHandler extends DefaultHandshakeHandler {
// Custom class for storing principal
@Override
protected Principal determineUser(
ServerHttpRequest request,
WebSocketHandler wsHandler,
Map<String, Object> attributes
) {
// Generate principal with UUID as name
return new StompPrincipal(UUID.randomUUID().toString())
}
}
最后,您需要配置您的 websocket 以使用您的自定义握手处理程序。
@Override
void registerStompEndpoints(StompEndpointRegistry stompEndpointRegistry) {
stompEndpointRegistry
.addEndpoint("/stomp") // Set websocket endpoint to connect to
.setHandshakeHandler(new CustomHandshakeHandler()) // Set custom handshake handler
.withSockJS() // Add Sock JS support
}
就是这样。现在,您的服务器已配置为为每个连接生成唯一的主体名称。它将作为 StompHeaderAccessor
对象的一部分传递该主体,您可以通过连接事件监听器、MessageMapping 函数等访问这些对象...
来自事件监听器:
@EventListener
void handleSessionConnectedEvent(SessionConnectedEvent event) {
// Get Accessor
StompHeaderAccessor sha = StompHeaderAccessor.wrap(event.getMessage())
}
来自消息映射 API
@MessageMapping('/hello')
protected void hello(SimpMessageHeaderAccessor sha, Map message) {
// sha available in params
}
关于使用 convertAndSendToUser(...)
的最后一点说明。向用户发送消息时,您将使用类似这样的内容
convertAndSendToUser(sha.session.principal.name, '/topic/hello', message)
但是,对于订阅客户端,您将使用
client.subscribe('/user/topic/hello', callback)
如果您为客户端订阅 /topic/hello
,您将只会收到广播消息。
关于java - "user"来自 convertAndSendToUser 在 SockJS+Spring Websocket 中的工作?,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/37853727/