Невозможно отправить сообщение в веб-сокет из другого сервиса
Я следовал этому уроку для настройки веб-сокетов в моем веб-приложении, и ниже приведен результирующий код. Теперь я подумал, если я напишу в тему из другого класса (LocationManagerImpl.java) в моем приложении я смогу отправить сообщение всем клиентам, подписавшимся на эту тему. Но, похоже, клиент не получает сообщение. Если я отлаживаю, а также проверяю журналы, я получаю указания, что мое сообщение было записано в тему, но оно не читается клиентом. Я не могу понять, что я делаю здесь неправильно. Пожалуйста помоги.
HelloController.java
@Controller
public class HelloController {
@MessageMapping("/hello")
@SendTo("/topic/greetings")
public HelloResponse hello(HelloRequest request) throws Exception {
Thread.sleep(3000);
HelloResponse response = new HelloResponse();
response.setContent(request.getContent() + " ... appending response");
return response;
}
}
WebSocketConfiguration.java
@Configuration
@EnableWebSocketMessageBroker
public class WebSocketConfiguration extends AbstractWebSocketMessageBrokerConfigurer {
@Override
public void configureMessageBroker(MessageBrokerRegistry config) {
config.enableSimpleBroker("/topic");
config.setApplicationDestinationPrefixes("/app");
}
@Override
public void registerStompEndpoints(StompEndpointRegistry registry) {
registry.addEndpoint("/hello").withSockJS();
}
}
hello.js
var stompClient = null;
function setConnected(connected) {
document.getElementById('connect').disabled = connected;
document.getElementById('disconnect').disabled = !connected;
document.getElementById('conversationDiv').style.visibility = connected ? 'visible' : 'hidden';
document.getElementById('response').innerHTML = '';
}
function connect() {
var socket = new SockJS('/aegis/hello');
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);
});
});
}
function disconnect() {
if (stompClient != null) {
stompClient.disconnect();
}
setConnected(false);
console.log("Disconnected");
}
function sendName() {
var name = document.getElementById('name').value;
stompClient.send("/app/hello", {}, JSON.stringify({ 'content': name }));
}
function showGreeting(message) {
var response = document.getElementById('response');
var p = document.createElement('p');
p.style.wordWrap = 'break-word';
p.appendChild(document.createTextNode(message));
response.appendChild(p);
}
sample.jsp
<%@ include file="/common/taglibs.jsp"%>
<head>
<title><fmt:message key="sample.title"/></title>
<meta name="menu" content="SampleMenu"/>
<script src="//code.jquery.com/jquery-2.1.3.min.js"></script>
<script src="//cdn.jsdelivr.net/sockjs/0.3.4/sockjs.min.js"></script>
<script src="scripts/stomp.js"></script>
<script src="scripts/hello.js"></script>
<script>
$(document).ready(function(){
disconnect();
});
</script>
</head>
<noscript><h2 style="color: #ff0000">Seems your browser doesn't support Javascript! Websocket relies on Javascript being enabled. Please enable
Javascript and reload this page!</h2></noscript>
<div>
<div>
<button id="connect" onclick="connect();">Connect</button>
<button id="disconnect" disabled="disabled" onclick="disconnect();">Disconnect</button>
</div>
<div id="conversationDiv">
<label>What is your name?</label><input type="text" id="name" />
<button id="sendName" onclick="sendName();">Send</button>
<p id="response"></p>
</div>
</div>
LocationManagerImpl.java
@Service("locationManager")
public class LocationManagerImpl extends GenericManagerImpl<TripTrack,Long> implements LocationManager {
@Autowired
private SimpMessageSendingOperations messagingTemplate;
@Override
public Response locations(JsonRequest loc) {
//... some code here
// Send to UI
messagingTemplate.convertAndSend("/topic/greetings", "{\"content\": \"hello\"}");
//... some more code here
}
}