共计 413 个字符,预计需要花费 2 分钟才能阅读完成。
websocket,如果直接写的话,各种 onmessage
onopen
处理代码写的比较恶心
另外,写个 onclose
onerror
重连,里面清理一下状态,那代码就无可避免很多上下文变量
而用 rxjs 就比较省心
const subject = webSocket('ws://localhost:8081');
subject.pipe(retry(10)
).subscribe({next: msg => console.log('message received:' + msg), // Called whenever there is a message from the server.
error: err => {console.log("err", err)
},
complete: () => console.log('complete') // Called when connection is closed (for whatever reason).
});
}
断了重连 10 次,比较省心。
正文完