Bahar

Question

kullanarak Websocket üzerinden istemciye mesaj gönderme Websocket ile Spring kullanmayı deneyin. Araştırmamı this tutorial ile başlattım. O inşaat büyük

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); 
     }); 
    }); 
} 

, benim denetleyicisi şu sınıfta benim sürecini yapabiliyorum: Benim yan istemcisi olarak

Ben sunucusuna bağlantıyı başlatmak için böyle bir şey var

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

    @MessageMapping("/form") 
    @SendTo("/topic/greetings") 
    public Greeting validate(AddPhotosForm addPhotosForm) { 
     return new Greeting("Hello world !"); 
    } 
} 

Şimdi yapmak istediğim, istemciye "/ topic/greeting" mesajını dinleyen bir ileti gönderen bir iş parçacığı içeriyor. Bu gibi benim Runnable sınıf yazdı:

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(); 
      } 
     } 
    } 
} 

Ve böyle benim denetleyici tamamladı: istediğim ama hiçbir şey istemci tarafında olduğu gibi yöntem PhotoController.fireGreeting denir

@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"); 
    } 
} 

. Herhangi bir öneriniz var mı? Teşekkür ederim.

Answer 1

Sorunumuzu @Boris the Spider sayesinde çözebildim.

@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")); 
    } 
}