如何等待 WebSocket 的 readyState 更改

IT技术 javascript websocket polling
2021-03-06 21:09:42

我正在尝试实现一个带有轮询回退的 WebSocket。如果 WebSocket 连接成功,则readyState变为 1,如果失败,readyState则为 3,我应该开始轮询。

我试过这样的事情:

var socket = new WebSocket(url);
socket.onmessage = onmsg;
while (socket.readyState == 0)
{
}
if (socket.readyState != 1)
{
    // fall back to polling
    setInterval(poll, interval);
}

我期待socket.readyState异步更新,并允许我立即阅读。但是,当我运行它时,我的浏览器死机了(我在放弃之前让它打开了大约半分钟)。

我想也许有一个onreadyStateChanged事件,但我没有在 MDN 参考中看到一个。

我应该如何实施?显然,空循环不起作用,并且没有事件。

6个回答

这很简单,而且效果很好……您可以添加有关最大时间的条件或尝试次数以使其更健壮……

function sendMessage(msg){
    // Wait until the state of the socket is not ready and send the message when it is...
    waitForSocketConnection(ws, function(){
        console.log("message sent!!!");
        ws.send(msg);
    });
}

// Make the function wait until the connection is made...
function waitForSocketConnection(socket, callback){
    setTimeout(
        function () {
            if (socket.readyState === 1) {
                console.log("Connection is made")
                if (callback != null){
                    callback();
                }
            } else {
                console.log("wait for connection...")
                waitForSocketConnection(socket, callback);
            }

        }, 5); // wait 5 milisecond for the connection...
}
我觉得奇怪的是 websockets 是一种推送技术的想法,但将 readyState 作为同步的、非推送调用。
2021-04-26 21:09:42
可能只是我遗漏了一些东西,但是当我运行您的代码时,我收到一个错误消息,告诉我“回调不是函数”。为什么回调函数在 if(callback != null){ callback(); }
2021-04-28 21:09:42
根据Axel 的回答,适当的解决方案是使用事件处理程序
2021-05-06 21:09:42

这里有更详细的解释。首先,检查特定的浏览器 API,因为并非所有浏览器都使用最新的 RFC。您可以咨询

您不想运行循环来不断检查就绪状态,这是您不需要的额外开销。更好的方法是了解与就绪状态更改相关的所有事件,然后将它们适当地连接起来。它们如下:

onclose当 WebSocket 连接的 readyState 更改为 CLOSED 时要调用的事件侦听器。侦听器接收名为“close”的 CloseEvent。

onerror发生错误时要调用的事件侦听器。这是一个名为“error”的简单事件。

onmessage从服务器接收到消息时要调用的事件侦听器。侦听器接收名为“message”的 MessageEvent。

onopen当 WebSocket 连接的 readyState 更改为 OPEN 时要调用的事件侦听器;这表明连接已准备好发送和接收数据。该事件是一个名为“open”的简单事件。

JS 完全是事件驱动的,因此您只需连接所有这些事件并检查就绪状态,这样您就可以相应地从 WS 切换到轮询。

我建议您查看 Mozilla 参考,它比 RFC 文档更容易阅读,并且可以很好地概述 API 及其工作原理(链接)。

如果失败并轮询直到成功重新连接的回调被触发,请不要忘记为重试做回调。

读到这里,一切都说得通,除了所有on事件都没有公开关闭和连接。只有 onopen、onclose 和 error 事件。我不想在关闭状态下向 ws 发送消息。
2021-04-25 21:09:42
“你可以咨询”...?(我知道它很旧)
2021-04-26 21:09:42
2021-04-30 21:09:42

我根本没有使用池化。相反,我使用排队。首先我创建新的发送函数和一个队列:

var msgs = []
function send (msg) {
  if (ws.readyState !== 1) {
    msgs.push(msg)
  } else {
    ws.send(msg)
  }
}

然后我需要在第一次建立连接时读取和发送:

function my_element_click () {
  if (ws == null){
    ws = new WebSocket(websocket_url)
    ws.onopen = function () {
      while (msgs.length > 0) {
        ws.send(msgs.pop())
      }
    }
    ws.onerror = function(error) {
      // do sth on error
    }
  } 
  msg = {type: 'mymessage', data: my_element.value}
  send(JSON.stringify(msg))
}

本示例中的 WebSocket 连接仅在第一次单击时创建。通常,第二个消息开始直接发送。

查看http://dev.w3.org/html5/websockets/

搜索“事件处理程序”并找到表格。

onopen -> 打开
onmessage -> 消息
onerror -> 错误
onclose ->close

function update(e){ /*Do Something*/};
var ws = new WebSocket("ws://localhost:9999/");

ws.onmessage = update;
如果 w3 为 readyState 提供真实状态机图,我会很高兴。例如,当连接被目的地拒绝时,它也可以从 CONNECTING 变为 CLOSED。
2021-05-13 21:09:42

如果您使用async/await并且只想等到连接可用,我建议使用此功能:

async connection (socket, timeout = 10000) {
  const isOpened = () => (socket.readyState === WebSocket.OPEN)

  if (socket.readyState !== WebSocket.CONNECTING) {
    return isOpened()
  }
  else {
    const intrasleep = 100
    const ttl = timeout / intrasleep // time to loop
    let loop = 0
    while (socket.readyState === WebSocket.CONNECTING && loop < ttl) {
      await new Promise(resolve => setTimeout(resolve, intrasleep))
      loop++
    }
    return isOpened()
  }
}

用法(在async函数中):

const websocket = new WebSocket('...')
const opened = await connection(websocket)
if (opened) {
  websocket.send('hello')
}
else {
  console.log("the socket is closed OR couldn't have the socket in time, program crashed");
  return
}