AJAX - 同时运行两个请求,但其中一个以一定的间隔重复运行

AJAX - run two requests at same time, but one of them repeatedly with some interval

本文关键字:运行 一个以 请求 两个 AJAX      更新时间:2023-09-26

我想实现以下功能:第一个 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.
    });
}