Spring Web-Socket을 통해 클라이언트에 주기적으로 메시지 보내기

Question

Spring webSocket을 통해 클라이언트와 서버를 연결하려고하는데이 작업은 this link의 도움으로 수행합니다. 컨트롤러에서 매 5 초마다 "hello"를 보내고 클라이언트가 매번 인사말 상자에 추가하도록합니다. 이 컨트롤러 클래스 :

@EnableScheduling 
@Controller 
public class GreetingController { 

    @Scheduled(fixedRate = 5000) 
    @MessageMapping("/hello") 
    @SendTo("/topic/greetings") 
    public Greeting greeting() throws Exception { 
     Thread.sleep(1000); // simulated delay 
     System.out.println("scheduled"); 
     return new Greeting("Hello"); 
    } 

} 

및이 app.jsp에 연결() 함수 다음 index.jsp를로드 내가 한 번만를 연결 버튼을 누르면

function connect() { 
    var socket = new SockJS('/gs-guide-websocket'); 
    stompClient = Stomp.over(socket); 
    stompClient.connect({}, function (frame) { 
     setConnected(true); 
     console.log('Connected: ' + frame); 
     stompClient.send("/app/hello", {}, JSON.stringify({'name': "connect"})); 
     stompClient.subscribe('/topic/greetings', function (message) { 
      console.log("message"+message); 
      console.log("message"+(JSON.parse(message.body))); 

      showGreeting(JSON.parse(message.body).content); 
     }); 
    }); 
} 

인사말에 안녕하세요, 5 초마다 "안녕하세요"라는 메시지를 표시하려면 어떻게해야합니까?

Answer 1

documentation 부분을 참조하십시오. 메시지를 보내려는 방식이 완전히 잘못되었습니다. 위 클래스를 다음과 같이 수정합니다 :

@EnableScheduling 
@Controller 
public class GreetingController { 

    @Autowired 
    private SimpMessagingTemplate template; 

    @Scheduled(fixedRate = 5000) 
    public void greeting() { 
     Thread.sleep(1000); // simulated delay 
     System.out.println("scheduled"); 
     this.template.convertAndSend("/topic/greetings", "Hello"); 
    } 

}