如何解决如何使用 RxJS WebSocketSubject 重试/重新连接到 Websocket 服务器
我为 RxJS WebSocketSubject 自动重新连接找到了各种解决方案,但对我来说没有任何效果。
在我的 RxJS 6.5 / Angular 代码中有一个 connectToWebsocket()
函数,它在启动时执行一次,包含:
const openObserver: NextObserver<Event> = {
next: () => console.debug('[Websocket] Connected')
};
const closeObserver: NextObserver<CloseEvent> = {
next: () => console.debug('[Websocket] Disconnected')
};
// Connect to WebSocket Server
this.websocketConnection= new WebSocketSubject({
url: "ws://localhost:4000",deserializer: e => e.data,openObserver,closeObserver
});
创建主题后,我订阅了它:
this.websocketConnection.subscribe((msg) => {
this.data = msg;
},(err) => {
console.log("Error on on connection",err);
},() => {
console.log("Connection closed");
});
所以现在,如果最初或连接时,连接在任何情况下都会关闭。如何重新连接到 websocket 服务器?我需要编写自己的重连策略还是 RxJS 中已经有了?
提前致谢!
版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 dio@foxmail.com 举报,一经查实,本站将立刻删除。