Dateiname

Pfad

Wozu/Was wird hier gemacht

 Hier wird die eigentliche Websocketverbindung konfiguriert

   //Stelle einen Kanal zur Verfügung, über diesen kommuniziert wird.
   @Override
    public void configureMessageBroker(MessageBrokerRegistry config) {
        config.enableSimpleBroker("/topic");
        config.setApplicationDestinationPrefixes("/app"); 
    }
    //stelle eine Endpunkt zur Registrierung der Clients bereit.
    @Override
    public void registerStompEndpoints(StompEndpointRegistry registry) {
        registry.addEndpoint("/chat-app").withSockJS(); 
    }
    //do-stuff wenn die Verbindung abbricht
    @Override
    public void onApplicationEvent(SessionDisconnectEvent event) {
        System.out.println(event.toString());
    

Am besten in die app.js reinschauen, woriauf sich der Client Verbindet und welchen Kanal dieser Abnoniert(subscripe). Dann wird dieses Klasse etwas klarer.

Einfacher Controller, der eine Nachricht empfängt, diese auf der Konsole ausgibt und wieder zurücksenset. Durch das Zurücksenden auf den Kanal wird sichergestellt, das alle Clints die diesen Kanal aboniert ahebn, diese NAchricht auch erhalten.

@MessageMapping("/hello") //recieved message from
    @SendTo("/topic/greetings") // the response is send as broadcast channel to /topic/greetings
    public ChatMessage greeting (ChatMessage message){
        System.out.println(message.getName());
        System.out.println(message.getContent());
        return message;
    }

 Client Seite

 Hier ist die Client-Seite realisiert. Wirklich interresant ist dabei lediglich die connect Funktion. Hier wird eine WebsocketVerbindung hersgestellt und ein Kanal Aboniert.

function connect(){
    var socket = new SockJS('/chat-app');
    stompClient = Stomp.over(socket);
    stompClient.connect({}, function (frame) {
        setConnected(true);
        console.log('Connected: ' + frame);
        stompClient.subscribe('/topic/greetings', function (antwort) {
            printMessage('<b>'+JSON.parse(antwort.body).name +'</b><BLOCKQUOTE>'+JSON.parse(antwort.body).content);
        });
    });
}

Alle anderen Funktionen sind recht klein und deren Namen erläutern deren Funktion.