1

我有一个 AJAX 密集型应用程序，需要快速或同时发送多个 AJAX 请求。以下代码只是一个简单的包装器，用于发送我在整个应用程序中使用的 AJAX POST 调用。有 2 个警告：

1) 我希望能够在发出请求之前测试用户的互联网连接，以便在他们的连接断开时通知他们。

2）如果他们的连接断开并且他们继续使用该应用程序，这会产生更多的 AJAX 调用，我想将这些调用排队并在连接恢复后一一发送。

连接性检查和排队工作，但是当用户重新联机时，只有他们的一些请求被发送到服务器，并且它们似乎被发送到他们原来的顺序之外。我错过了什么？为什么没有发送所有请求，为什么它们没有按顺序发送？

在任何人注意到之前，我已经看到了一些涉及 jQuery 的关于这个主题的其他解决方案。我不反对使用这些，我只是想了解为什么此代码不起作用。提前致谢。

window.connectionState = true
window.xhrQueue = []
window.pingInterval

function xhrPost(url, packet, before, after) {
  if (!url || typeof(url) !== "string") {
    console.log("invalid url supplied in xhr call.")
    return false
  }

  var mainRequest = function() {
    var xhr= new XMLHttpRequest()

    if (typeof(after) === "function") {
      xhr.onreadystatechange = function(){
        if (xhr.readyState == 4) {
          after(xhr)
          return true
        }
      }
    }

    if (typeof(before) === "function") {
      before()
    }

    xhr.open("POST",url,true)
      if (packet) {
        xhr.send(JSON.stringify(packet))
      }
      else {
        xhr.send()
      }
  }

  ping(mainRequest)
}

function ping(mainRequest) {

  // Create pingXhr to test connection
  var pingXhr = new XMLHttpRequest()

  pingXhr.onreadystatechange = function(){
    // If pingXhr comes back successfully...
    if (pingXhr.readyState == 4) {
      if (pingXhr.status == 200) { 
        // If pingXhr comes back from being down, update user
        if (window.connectionState !== true) {
          setTimeout(function() { alert("And we're back! Your connection seems to be working now. Keep editing.") }, 1)
        }
        // If there are requests waiting, send them in order, then remove them
        if (window.xhrQueue.length > 0) {
          for (var i in window.xhrQueue) {
            ping(window.xhrQueue[i])
            window.xhrQueue.splice(i, 1)
            clearInterval(window.pingInterval)
          }
        }
        // Otherwise, just make the singular request
        else {
          mainRequest()
        }
        // Reset xhrQueue since stuff is successful, change connection to true, and unset onbeforeunload message
        window.xhrQueue = []
        window.connectionState = true
      }
      // If there was a problem with the request
      else {
        // Notify the user their internet is down
        if (window.connectionState === true) {
          setTimeout(function() { alert("It seems you have momentarily lost internet connectivity.") }, 1)
        }
        // If there are no requests in the xhrQueue, create the timeout. Otherwise, just add to the queue
        if (window.xhrQueue.length === 0) {
          window.pingInterval = setInterval(function(){ ping() }, 3000)
        }
        // Add the request to the xhrQueue to be processed in order
        if (typeof(mainRequest) === "function") {
          window.xhrQueue.push(mainRequest)
        }
        window.connectionState = false
      }
    }
  }
  pingXhr.open("GET","/some/url/here",true)
  pingXhr.send()
}
4

2 回答 2

1

这将是因为您一次将它们全部关闭，有些会比其他人需要更长的时间才能返回，因此它们的处理程序将首先运行。

我建议您一次发送一个，使用回调发送下一个

于 2012-06-26T23:46:42.740 回答
1

看起来您正在使用 push() 将条目放在队列中，然后在循环中使用 splice() 来删除它们。这不太可能正常工作 - 它会跳过其中的一些/大部分，因为拼接会在您迭代它们时修改数组中的索引。

如果您将循环更改为始终关闭第一个元素，它会更好地工作。

编辑添加：您可能也不想在这里执行 for-in 循环。在迭代对象时修改对象的键通常不是一个好主意。

就像是：

while (window.xhrQueue.length > 0) {
    ping(window.xhrQueue[0]);
    window.xhrQueue.splice(0, 1);
}

或者，您可以让 onreadystatechange 处理程序从队列中获取下一个条目并发送该请求，而不是尝试同时运行所有排队的请求。

于 2012-06-26T23:48:18.407 回答