Я пытаюсь использовать Spring 4 Websocket и Angular 7 через библиотеку @stomp/stompjs и SockJS, однако он продолжает возвращать 404 не найдено, и в результате соединение с веб-сокетом закрывается.
Мой код конфигурации в Spring:
import org.springframework.context.annotation.Configuration;
import org.springframework.messaging.simp.config.MessageBrokerRegistry;
import org.springframework.scheduling.annotation.EnableScheduling;
import org.springframework.web.socket.config.annotation.AbstractWebSocketMessageBrokerConfigurer;
import org.springframework.web.socket.config.annotation.EnableWebSocketMessageBroker;
import org.springframework.web.socket.config.annotation.StompEndpointRegistry;
@Configuration
@EnableWebSocketMessageBroker
public class SocketConfig extends AbstractWebSocketMessageBrokerConfigurer {
@Override
public void registerStompEndpoints(StompEndpointRegistry registry) {
registry.addEndpoint("/batch-socket").withSockJS();
}
@Override
public void configureMessageBroker(MessageBrokerRegistry registry) {
registry.enableSimpleBroker("/socketio/");
}
}
SocketHandlerService.java для отправки шаблона сообщения
@Service
public class SocketHandlerService extends AbsLogger<SocketHandlerService> implements ApplicationListener<BrokerAvailabilityEvent> {
private final MessageSendingOperations<String> messagingTemplate;
@Autowired
public SocketHandlerService(MessageSendingOperations<String> messagingTemplate) {
this.messagingTemplate = messagingTemplate;
}
public SocketDetails sendRestMessage() {
...some code...
this.messagingTemplate.convertAndSend("/socketio/batchupdate", data);
...some code...
}
}
Angular socket.service.ts для обработки веб-сокетов на стороне клиента
init() {
let connectionUrl = this.baseUrl + "batch-socket";
return new Promise((resolve, reject) => {
let config = new StompConfig();
config.heartbeatOutgoing = 5000;
config.heartbeatIncoming = 5000;
config.webSocketFactory = function () {
return new SockJS(connectionUrl, null, { transports: ['websocket' , 'xhr-streaming','xhr-polling' ] });
}
config.debug = function (str) {
console.log("@socketDebug: " + str)
}
this.client = new Client();
this.client.configure(config);
enableLogs && console.log(this.client);
console.log("@socketSvc: starting connection...");
const _this = this;
this.client.onConnect = function (frame) {
console.log("@socketSvc: connection established.");
console.log(frame);
_this.state = new BehaviorSubject<any>(SocketClientState.ATTEMPTING);
_this.state.next(SocketClientState.CONNECTED);
resolve(frame.headers['user-name']);
}
this.client.onWebSocketClose = function (msg){
console.log("@socketSvc: connection closed.");
console.log(msg);
}
this.client.activate();
});
}
Я проверил, что URL-адреса конечных точек совпадают, и что домен для сервера и клиента, который используется, также одинаков. Однако при развертывании появляется следующий вывод консоли:
POST https://exampleWebsite.com/Portal/batch-socket/718/ky4ln33y/xhr_send?t=1576031555275 404 (Not Found)
main.7459b10fe35bab2c58d4.js:179295
@socketDebug: Connection closed to https://exampleWebsite.com/Portal/batch-socket
main.7459b10fe35bab2c58d4.js:179310
@socketSvc: connection closed. main.7459b10fe35bab2c58d4.js:179311
i {type: "close", bubbles: false, cancelable: false, timeStamp: 1576031555344, wasClean: false, …}bubbles: falsecancelable: falsecode: 1006reason: "Sending error: Error: http status 404"timeStamp: 1576031555344type: "close" wasClean: false__proto__: r
main.7459b10fe35bab2c58d4.js:179295
@socketDebug: STOMP: scheduling reconnection in 5000ms
Я также просмотрел инструменты разработчика для веб-браузера, чтобы проверить сеть: вкладка сети а>
Могу ли я узнать, в чем проблема для создания тесного соединения? Иногда требуется несколько попыток, прежде чем веб-сокет будет успешно установлен. В других случаях для успешного соединения требуется целая вечность.