AJAX - 同时运行两个请求,但其中一个以一定的间隔重复运行
AJAX - run two requests at same time, but one of them repeatedly with some interval
我想实现以下功能:第一个 AJAX 请求将数据导入到 MS SQL 数据库。数据库中有一个表,其中包含有关导入的一些数据(总记录、继续记录、开始时间等(。表中的此数据在导入过程中会不断更新。
例如,第二个 AJAX 请求应每 5 秒从表中获取更新的数据,并以某种通知的形式将其显示在页面上。
我面临的问题如下:第一个请求开始,执行它需要几分钟。同时,第二个请求以 5 秒的间隔调用,但在第一个请求完成之前不会执行所有请求,它们都已排队并具有"挂起"状态。我不知道这是怎么回事。看起来我无法在第一个 TTFB 期间启动第二个 AJAX 请求。
我也尝试使用jQuery.when((和jQuery.then((,但我不明白如何在jQuery.when((中进行带有间隔的AJAX调用。有什么方法可以实现我的目标功能吗?
这是我的代码,单击导入按钮时调用 RunImport 函数:
var resultCheck, resultRun, intervalId = 0;
$(document).ready(function () {
CheckActiveImports();
});
function CheckActiveImports() {
var jqXHR = $.ajax({
url: "exhaust.aspx/GetRunningImports",
async:true,
type: "GET",
contentType: "application/json; charset=utf-8",
dataType: "json",
beforeSend: function(){
$('#output').html("Checking for running imports...");
},
success: OnCheckSuccess,
failure: function (result) {
resultCheck = "Failure: " + result.responseText;
},
error: function (result) {
resultCheck = "Error: " + result.responseText;
},
complete: function () {
$('#output').html(resultCheck);
}
});
return jqXHR;
}
function OnCheckSuccess(result)
{
var data = result.d; //JSON.parse(result).d;
if (data.length) {
var res = "";
for (var x in data) {
var format = 'Job running: ' + data[x].JobType + '. ' + data[x].Counter + ' of ' + data[x].Total + ' records processed<br /> '
Speed: ' + data[x].Speed + ' records per minute. '
Estimated time of completion: ' + data[x].EstTime + '.';
res += format;
}
resultCheck = res;
}
else {
resultCheck = 'Currently there are no jobs running.';
}
}
function RunImport()
{
intervalId = window.setInterval(CheckActiveImports, 5000);
RunImportAjax();
}
function RunImportDeferred() {
var RunImportXHR = RunImportAjax(),
CheckImportXHR = CheckActiveImports();
$.when(RunImportXHR, CheckImportXHR).then(function () {
$('#output').html(resultCheck);
$('#output2').html(resultRun);
});
}
function RunImportAjax() {
var jqXHR = $.ajax({
url: "exhaust.aspx/RunImport",
async:true,
type: "POST",
contentType: "application/json; charset=utf-8",
dataType: "json",
beforeSend: function () {
$('#output2').html("Running import...");
},
success: function (result) {
window.clearInterval(intervalId);
var data = result.d;
if (data.length) {
var res = "";
for (var x in data) {
var format = 'Job finished: ' + data[x].JobType + '. ' + data[x].Counter + ' records processed.<br />';
res += format;
}
resultRun = res;
}
},
failure: function (result) {
resultRun = "Failure: " + result.responseText;
},
error: function (result) {
resultRun = "Error: " + result.responseText;
},
complete: function () {
$('#output2').html(resultRun);
}
});
return jqXHR;
}
这可以通过"处置器模式"来完成,其中"资源"(window.setInterval()
(在启动导入时建立,并在导入的承诺结算时处理。
对外部变量的需求消失了,对RunImportDeferred()
的需求也消失了。 RunImportAjax()
可以重命名为 RunImport()
或类似名称。 CheckActiveImports()
和OnCheckSuccess()
可以保持原样。
function RunImport() {
$('#output2').html("Running import...");
var intervalId = window.setInterval(CheckActiveImports, 5000); // establish a progress observer
return $.ajax({
url: 'exhaust.aspx/RunImport',
async:true,
type: 'POST',
contentType: 'application/json; charset=utf-8',
dataType: 'json'
}).then(function (result) {
var data = result.d,
res;
if (data.length) {
res = jQuery.map(data, function(item) {
return 'Job finished: ' + item.JobType + '. ' + item.Counter + ' records processed.';
}).join('<br />');
} else {
res = '';
}
$('#output2').html(res);
return result; // in case RunImport's caller is interested.
}, function(error) {
$('#output2').html(error.message);
}).always(function() {
window.clearInterval(intervalId); // dispose of the progress observer
});
}
如果服务器有能力为导入和进度请求提供服务,那么这应该可以工作。
进度观察者可以写得更好,不涉及window.setInterval()
但这可能是一个单独的问题。
编辑:没有 setInterval(( 的周期观察器
没有setInterval()
的周期观察器相当简单,停止它可以比原始clearInterval()
更好,也可以(可选地(中止任何挂起的ajax。
在下面的方法中,:
CheckActiveImports()
(和OnCheckSuccess()
(的详细行为是通过传递几个参数来控制的。-
CheckActiveImports()
返回一个塞子函数,该函数在RunImport()
中用作处置器。
在调用方中,您可以调用返回的处理器函数,如下所示:
-
dispose()
:停止进一步的 ajax 调用。 -
dispose(true)
:中止挂起的 ajax 调用并停止进行进一步的 ajax 调用。
你可能想要后者。
function CheckActiveImports($container, interval, initMessage, finalMessage) {
$container.html(initMessage || '');
var jqXHR = null,
timeoutRef = setTimeout(check, interval),
_recurse_ = true;
function check() {
jqXHR = $.ajax({
url: "exhaust.aspx/GetRunningImports",
async: true,
type: "GET",
contentType: "application/json; charset=utf-8",
dataType: "json",
success: OnCheckSuccess.bind(null, $container),
error: function (result) {
$container.text("Error: " + result.responseText);
},
complete: function() {
if(_recurse_) {
timeoutRef = setTimeout(check, interval); // recursive call
}
}
});
}
return function(abort) {
if(abort && jqXHR) jqXHR.abort();
clearTimeout(timeoutRef);
_recurse_ = false;
$container.text(finalMessage || '');
};
}
function OnCheckSuccess($container, result) {
var data = result.d, //JSON.parse(result).d
res;
if(data.length) {
res = jQuery.map(data, function(item) {
return 'Job running: ' + item.JobType + '. ' + item.Counter + ' of ' + item.Total + ' records processed<br /> '
Speed: ' + item.Speed + ' records per minute. '
Estimated time of completion: ' + item.EstTime + '.';
}).join('<br/>');
} else {
res = 'Currently there are no jobs running.';
}
$container.text(res);
}
function RunImport() {
var $container = $('#output2').html("Running import...");
var dispose = CheckActiveImports($('#output'), 5000, 'Checking for running imports...', ''); // start the progress observer
return $.ajax({
url: 'exhaust.aspx/RunImport',
async:true,
type: 'POST',
contentType: 'application/json; charset=utf-8',
dataType: 'json'
}).then(function (result) {
var data = result.d,
res;
if (data.length) {
res = jQuery.map(data, function(item) {
return 'Job finished: ' + item.JobType + '. ' + item.Counter + ' records processed.';
}).join('<br />');
} else {
res = '';
}
$container.html(res);
return result; // in case RunImport's caller is interested.
}, function(error) {
$container.html(error.message);
}).always(function() {
dispose(true); // dispose of the progress observer and abort any pending ajax.
});
}
- 为什么window.open不打开一个以变量形式给出的链接
- 从Chrome扩展名中的popup.html文件在background.js文件中运行一个函数
- 运行一个特定<脚本>(Dreamweaver)
- 在触发x-editable之前运行一个函数
- 从Spring应用程序运行PhantomJS以获取网页缩略图
- 如何获取一个以零开头的数字的位数
- 运行脚本以禁用脚本
- 如何运行一个又一个脚本
- 运行一个JavaScript黄瓜水豚它停止了
- 在每个函数之后运行一个函数
- 如何运行一个调用某个函数的函数首先完成它,然后再调用下一个函数.正在创建回调函数
- Node.js:如何在服务器初始化时运行一个特殊的函数
- 如何运行一个 JavaScript 函数 X 秒
- 在命令运行时以Grunt显示输出
- 如何在javascript函数中运行一个接一个的gullow函数
- 从gullow任务运行一个npm脚本
- Nodejs:在节点服务器启动时运行一个js文件
- 如何在Javascript中以过程化的方式运行一个又一个语句
- AJAX - 同时运行两个请求,但其中一个以一定的间隔重复运行
- 运行脚本以打开另一个脚本文件