Я использую Spring 5: как мне обнаружить SUBSCRIBE сообщения от клиента Stomp?
Насколько я понимаю, @SubscribeMapping должен вызывать мой метод контроллера всякий раз, когда клиент подписывается на тему, но этого не происходит.
Вот мой контроллер сервера:
@Controller
public class MessageController {
// ...
@MessageMapping("/chat/{mId}")
@SendTo("/topic/messages")
public OutputMessage send(Message message, @DestinationVariable("mId") String mid, MessageHeaders headers, MessageHeaderAccessor accessor) throws Exception {
// ...
}
@SuppressWarnings("unused")
@SubscribeMapping({ "/", "/chat", "/topic/messages", "/messages", "/*" })
public void listen(Message message, MessageHeaders headers, MessageHeaderAccessor accessor) throws Exception {
int i = 0;
System.out.println("subscribed");
}
}
Конфигурация сервера:
@Configuration
@ComponentScan(basePackages= { "websockets" })
@EnableWebSocketMessageBroker
public class WebSocketConfig implements WebSocketMessageBrokerConfigurer {
@Override
public void configureMessageBroker(MessageBrokerRegistry config) {
config.enableSimpleBroker("/topic");
config.setApplicationDestinationPrefixes("/app");
}
@Override
public void registerStompEndpoints(StompEndpointRegistry registry) {
registry.addEndpoint("/chat");
registry.addEndpoint("/chat").withSockJS();
}
@Override
public void configureWebSocketTransport(WebSocketTransportRegistration registry) {
WebSocketMessageBrokerConfigurer.super.configureWebSocketTransport(registry);
}
}
И клиент javascript:
<!DOCTYPE html>
<html>
<head>
<meta charset="UTF-8" />
<title>Chat WebSocket</title>
<script src="sockjs.js"></script>
<script src="stomp.js"></script>
<script type="text/javascript">
// ...
function connect() {
var sock = new SockJS('/<webapp-context>/chat');
stompClient = Stomp.over(sock);
stompClient.connect({}, function(frame) {
setConnected(true);
console.log('Connected: ' + frame);
stompClient.subscribe('/topic/messages', function(messageOutput) {
showMessageOutput(JSON.parse(messageOutput.body));
});
stompClient.subscribe('/topic/messages/13', function(messageOutput) {
showMessageOutput(JSON.parse(messageOutput.body));
});
});
}
// ...
</script>
</head>
<body onload="/*disconnect()*/">
<!-- ... -->
</body>
</html>
Код был адаптирован из Intro для WebSockets с Spring .
Как указано в в этом ответе и в документах , я могу просто использовать перехватчик, но как тогда работает @SubscribeMapping?