我正在使用 'rxjs-websockets' 与 websockets 连接。但经过一定时间(约 2 分钟)
连接被关闭。如何保持连接直到手动关闭。
这是我使用的代码片段
constructor(private socketService: WebSocketService) {}
this.socketService.connect('/endpoint');
this.socketSubscription = this.socketService.messages
.subscribe(result => {
// perform operation
});
这是 WebSocketService
import {Injectable} from '@angular/core';
import {QueueingSubject} from 'queueing-subject';
import {Observable} from 'rxjs/Observable';
import websocketConnect from 'rxjs-websockets';
import 'rxjs/add/operator/share';
import 'rxjs/add/operator/retryWhen';
import 'rxjs/add/operator/delay';
@Injectable()
export class WebSocketService {
private inputStream: QueueingSubject<string>;
public messages: Observable<string>;
constructor() {
}
public connect(socketUrl) {
this.messages = websocketConnect(
socketUrl,
this.inputStream = new QueueingSubject<string>()
).messages.retryWhen(errors => errors.delay(1000))
.map(message => JSON.parse(message))
.share();
}
public send(message: string): void {
this.inputStream.next(message);
}
}
最佳答案
Websockets 通常在一些消息交换的帮助下保持连接很长一段时间。
在我们的例子中,我们可以将其称为“ping => pong”,客户端发送消息“ping”,服务器可能会以消息“pong”作为响应。
您可以按如下方式每 30 秒发送一次 ping。
setInterval(() => {
this.socketService.send('ping');
}, 30000);
当您将 WebSocketService 收到的每条消息都转换为 JSON 时,您必须进行这些更改
避免 JSON 解析错误。
export class WebSocketService {
.
.
.
public connect(socketUrl) {
this.messages = websocketConnect(
socketUrl,
this.inputStream = new QueueingSubject<string>()
).messages.retryWhen(errors => errors.delay(1000))
//parse messages except pong to avoid JSON parsing error
.map(message => message === 'pong' ? message : JSON.parse(message))
.share();
}
.
.
.
}
关于websocket - 如何防止websocket在angular5中的特定时间后关闭?,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/49293540/