So senden Sie eine Nachricht an den Client über Websocket mit Spring

Question

Ich versuche, Feder mit Websocket zu verwenden. Ich begann meine Untersuchung mit this tutorial.

In meiner Seite Client Ich habe so etwas wie, dass die Verbindung zum Server zu initialisieren:

function connect() { 
    var socket = new SockJS('/myphotos/form'); 
    stompClient = Stomp.over(socket); 
    stompClient.connect({}, function(frame) { 
     setConnected(true); 
     console.log('Connected: ' + frame); 
     stompClient.subscribe('/topic/greetings', function(greeting){ 
      showGreeting(JSON.parse(greeting.body).content); 
     }); 
    }); 
} 

Es funktioniert gut, in meinem Controller der Lage bin, ich meinen Prozess in der folgenden Klasse zu tun:

Jetzt was ich tun möchte, ist es ein Thread senden eine Nachricht an den Client hören auf "/ Thema/Gruß". Ich schrieb meine Runnable Klasse wie folgt:

public class FireGreeting implements Runnable { 

    private PhotoController listener; 

    public FireGreeting(PhotoController listener) { 
     this.listener = listener; 
    } 

    @Override 
    public void run() { 
     while (true) { 
      try { 
       Thread.sleep(2000); 
       listener.fireGreeting(); 
      } catch (InterruptedException e) { 
       e.printStackTrace(); 
      } 
     } 
    } 
} 

Und fertig mein Controller wie folgt aus:

@Controller 
@RequestMapping("/") 
public class PhotoController { 

    @MessageMapping("/form") 
    @SendTo("/topic/greetings") 
    public Greeting validate(AddPhotosForm addPhotosForm) { 

     // added this part 
     FireGreeting r = new FireGreeting(this); 
     new Thread(r).start(); 

     return new Greeting("Hello world !"); 
    } 

    // added this method 
    @SendTo("/topic/greetings") 
    public Greeting fireGreeting() { 
     System.out.println("Fire"); 
     return new Greeting("Fire"); 
    } 
} 

Verfahren PhotoController.fireGreeting genannt wird, wie ich will, aber es ist nichts passiert auf der Client-Seite. Irgendwelche Vorschläge? Vielen Dank.

Answer 1

Ich konnte mein Problem dank @Boris der Spider lösen. Die richtige Lösung ist, so etwas zu tun:

@Controller 
@RequestMapping("/") 
public class PhotoController { 

    @Autowired 
    private SimpMessagingTemplate template; 

    @MessageMapping("/form") 
    @SendTo("/topic/greetings") 
    public Greeting validate(AddPhotosForm addPhotosForm) { 

     FireGreeting r = new FireGreeting(this); 
     new Thread(r).start(); 

     return new Greeting("Hello world !"); 
    } 

    public void fireGreeting() { 
     System.out.println("Fire"); 
     this.template.convertAndSend("/topic/greetings", new Greeting("Fire")); 
    } 
}