Senden einer Nachricht an bestimmte Benutzer auf Spring Websocket

Question

Wie Websocket Nachricht vom Server an bestimmte Benutzer senden?

Meine Webapp hat Feder Sicherheitseinstellungen und verwendet Websocket. Ich habe ein schwieriges Problem beim Versuch, eine Nachricht vom Server an spezifischen Benutzer nur zu senden.

aus Mein Verständnis the manual Lesen ist vom Server wir

simpMessagingTemplate.convertAndSend("/user/{username}/reply", reply); 

Und auf der Client-Seite tun können:

stompClient.subscribe('/user/reply', handler); 

Aber ich konnte nie das Abonnement Rückruf aufgerufen erhalten. Ich habe viele verschiedene Wege ausprobiert, aber kein Glück.

Wenn ich es an senden/Thema/Antwort es funktioniert, aber alle anderen verbundenen Benutzer erhalten es auch.

das Problem zu veranschaulichen, habe ich dieses kleine Projekt auf Github erstellt: https://github.com/gerrytan/wsproblem

Schritte zum Reproduzieren:

1) Clone und erstellen Sie das Projekt (stellen Sie sicher, dass Sie mit jdk 1.7 und maven 3,1)

$ git clone https://github.com/gerrytan/wsproblem.git 
$ cd wsproblem 
$ mvn jetty:run 

2) Navigieren Sie zu http://localhost:8080, Login entweder bob/Test oder jim/test

3) Klicken Sie auf "Benutzerspezifische Nachricht anfordern". Erwartet: eine Meldung "Hallo {Benutzername}" wird nur für diesen Benutzer neben "Empfangene Nachricht an mich" angezeigt. Aktuell: nichts ist erhalten

Answer 1

Ah ich fand, was mein Problem war. Zuerst habe ich nicht den /user Präfix auf dem einfachen Broker registriere

<websocket:simple-broker prefix="/topic,/user" /> 

Dann kann ich nicht den zusätzlichen /user Präfix muß beim Senden:

convertAndSendToUser(principal.getName(), "/reply", reply); 

Frühling wird automatisch voranstellen "/user/" + principal.getName() an das Ziel, daher Es wird in "/ user/bob/reply" aufgelöst.

Dies bedeutet auch, in javascript ich pro Benutzer andere Adresse abonnieren hatte

stompClient.subscribe('/user/' + userName + '/reply,...) 

Answer 2

Oh, client side no need to known about current user, Server, dass für Sie tun.

Auf Server-Seite folgt mit Nachricht an einen Benutzer senden:

simpMessagingTemplate.convertAndSendToUser(username, "/queue/reply", message); 

Hinweis: queue verwendet, nicht topic, mit Spring immer queue mit sendToUser

Auf Client-Seite

stompClient.subscribe("/user/queue/reply", handler); 

Vergl

Wenn eine Websocket-Verbindung geöffnet ist, weist Spring eine session id (nicht HttpSession, Zuordnung pro Verbindung) zu. Und wenn Ihr Client an einen Kanal abonniert mit /user/ starten, zB: /user/queue/reply, Ihre Server-Instanz in einer Warteschlange queue/reply-user[session id]

genannt abonnieren werden, wenn die Verwendung Nachricht an Benutzer senden, zB: username is admin Sie schreiben simpMessagingTemplate.convertAndSendToUser("admin", "/queue/reply", message);

Spring bestimmt, welche session id dem Benutzer admin zugeordnet ist. ZB: Es fand zwei Sitzungen wsxedc123 und thnujm456, Spring wird es in 2 Ziel queue/reply-userwsxedc123 und queue/reply-userthnujm456 übersetzen, und es sendet Ihre Nachricht mit 2 Zielen zu Ihrem Nachrichtenbroker.

Der Nachrichtenbroker empfängt die Nachrichten und stellt sie der Serverinstanz zur Verfügung, die für jede Sitzung die Sitzung hält (WebSocket-Sitzungen können von einem oder mehreren Servern gehalten werden). Spring übersetzt die Nachricht in destination (z. B. user/queue/reply) und session id (z. B. wsxedc123). Dann senden Sie die Nachricht an entsprechenden Websocket session

Answer 3

Meine Lösung, dass basierend auf Thanh Nguyen Van beste Erklärung, aber zusätzlich habe ich konfiguriert MessageBrokerRegistry:

@Configuration 
@EnableWebSocketMessageBroker 
public class WebSocketConfig extends AbstractWebSocketMessageBrokerConfigurer { 

    @Override 
    public void configureMessageBroker(MessageBrokerRegistry config) { 
     config.enableSimpleBroker("/queue/", "/topic/"); 
     ... 
    } 
    ... 
} 

Answer 4

ich eine Probe websocket Projekt erstellt STOMP mit als auch . Was ich zu bemerken ist, dass

@Configuration 
@EnableWebSocketMessageBroker 
public class WebSocketConfig extends AbstractWebSocketMessageBrokerConfigurer { 

@Override 
public void configureMessageBroker(MessageBrokerRegistry config) { 
    config.enableSimpleBroker("/topic", "/queue");// including /user also works 
    config.setApplicationDestinationPrefixes("/app"); 
} 

@Override 
public void registerStompEndpoints(StompEndpointRegistry registry) { 
    registry.addEndpoint("/getfeeds").withSockJS(); 
} 

}

es funktioniert, ob "/ user" in config.enableSimpleBroker enthalten (...

Answer 5

Genau habe ich das gleiche und es ist ohne zu arbeiten Anwender mit

@Configuration 
@EnableWebSocketMessageBroker 
public class WebSocketConfig extends AbstractWebSocketMessageBrokerConfigurer { 

    @Override 
    public void registerStompEndpoints(StompEndpointRegistry registry) { 
     registry.addEndpoint("/gs-guide-websocket").withSockJS(); 
    } 

    @Override 
    public void configureMessageBroker(MessageBrokerRegistry config) { 
     config.enableSimpleBroker("/topic" , "/queue"); 
     config.setApplicationDestinationPrefixes("/app"); 
    } 
}