这个答案是根据这个应用程序写的:https://github.com/spring-guides/gs-messaging-stomp-websocket https://github.com/spring-guides/gs-messaging-stomp-websocket
为了注册用户,您必须首先创建一个代表该用户的对象,例如:
public final class User implements Principal {
private final String name;
public User(String name) {
this.name = name;
}
@Override
public String getName() {
return name;
}
}
然后你需要一种方法来创建这些User
对象。一种方法是当SockJS
向您发送连接消息标头。为此,您需要拦截连接消息。您可以通过创建我们的拦截器来做到这一点,例如:
public class UserInterceptor extends ChannelInterceptorAdapter {
@Override
public Message<?> preSend(Message<?> message, MessageChannel channel) {
StompHeaderAccessor accessor =
MessageHeaderAccessor.getAccessor(message, StompHeaderAccessor.class);
if (StompCommand.CONNECT.equals(accessor.getCommand())) {
Object raw = message
.getHeaders()
.get(SimpMessageHeaderAccessor.NATIVE_HEADERS);
if (raw instanceof Map) {
Object name = ((Map) raw).get("name");
if (name instanceof LinkedList) {
accessor.setUser(new User(((LinkedList) name).get(0).toString()));
}
}
}
return message;
}
}
一旦你有了这个,你还必须注册这个UserInterceptor
。我猜你在应用程序的某个地方定义了一个配置AbstractWebSocketMessageBrokerConfigurer
班级。在此类中,您可以通过重写来注册您的用户拦截器configureClientInboundChannel
方法。你可以这样做:
@Override
public void configureClientInboundChannel(ChannelRegistration registration) {
registration.setInterceptors(new UserInterceptor());
}
最后,当您的客户连接时,他们必须提供他们的用户名:
stompClient.connect({
name: 'test' // Username!
}, function () {
console.log('connected');
});
完成所有这些设置后,simpUserRegistry.getUsers()
将返回用户列表,您将能够使用convertAndSendToUser
method:
messaging.convertAndSendToUser("test", ..., ...);
Edit
进一步测试一下,订阅时,您必须在主题前加上前缀/user
as SimpMessagingTemplate
使用它作为默认前缀,例如:
stompClient.subscribe('/user/...', ...);
我也犯了一个错误UserInterceptor
并更正它(名称解析部分)。