java – spring boot web socket中的实时通知
作者:互联网
在我的应用程序中,我需要向特定用户发送实时通知.
我的WebSocketConfig类如下,
@Configuration
@EnableWebSocketMessageBroker
public class WebSocketConfig extends AbstractWebSocketMessageBrokerConfigurer {
@Override
public void registerStompEndpoints(StompEndpointRegistry stompEndpointRegistry) {
stompEndpointRegistry.addEndpoint("/websocket-example")
.withSockJS();
}
@Override
public void configureMessageBroker(MessageBrokerRegistry registry) {
registry.enableSimpleBroker("/topic");
}
}
大多数时间信息将由服务器端发送.所以我没有设置应用程序目的地.
在客户端,我订阅目的地’/ topic / user`,
function connect() {
var socket = new SockJS('/websocket-example');
stompClient = Stomp.over(socket);
stompClient.connect({}, function (frame) {
setConnected(true);
console.log('Connected: ' + frame);
stompClient.subscribe('/topic/user', function (greeting) {
// showGreeting(JSON.parse(greeting.body).content);
console.log("Received message through WS");
});
});
}
在我的一个RestController中,我有一个方法可以将消息广播到所有连接的客户端.
@GetMapping("/test")
public void test()
{
template.convertAndSend("/topic/user", "Hurray");
}
直到这部分一切正常.我收到消息并登录到控制台.
现在,如果我只想将通知发送给特定用户,我必须使用template.convertAndSendToUser(String user,String destination,String message).但我不明白我应该传递给user参数.我何时何地会收到用户?
我经历了几个与此相关的问题,但我并不清楚这些概念.
解决方法:
此用户名是java.security.Principal接口的一部分.每个StompHeaderAccessor或WebSocket会话对象都有一个这个原则的实例,您可以从中获取用户名.它不是自动生成的.它必须由服务器为每个会话手动生成.
您可以查看here以获取有关为每个会话生成唯一ID的更多信息.
然后使用这样:
@MessageMapping('/test')
public void test(SimpMessageHeaderAccessor sha)
{
String userName = sha.session.principal.name;
template.convertAndSend(userName, '/topic/user', "Hurray");
}
标签:java,spring,websocket,spring-boot-2,spring-websocket 来源: https://codeday.me/bug/20190710/1425018.html