Yii2如何实现后台异步大文件导出 避免阻塞用户操作

你找到的旧教程核心思路（前端发起任务、后台异步执行长耗时操作、完成后存储结果供用户下载+消息通知）完全可用于Yii2环境，你的代码出现问题是因为存在逻辑错误，并非思路本身不可行。

• 前端按钮绑定的ajax方法没有阻止表单默认提交行为，点击按钮时浏览器优先触发原生表单同步POST请求，ajax请求根本没正常发送到后端
• 你把耗时10分钟的导出逻辑放在了isAjax判断之前，就算ajax请求正常到达，PHP也会先执行完导出逻辑才会返回，本质还是阻塞请求，完全没实现异步效果
• 原逻辑把长任务放在web请求进程内执行，本身就受PHP超时、fpm进程数限制，就算请求正常响应，也很容易出现执行中断、服务阻塞的问题

不要用前端ajax等待长任务返回，整套逻辑分三层实现：

1. 基础存储与任务隔离层 #

• 建export_task表，字段包含：主键id、关联用户id、导出参数、生成文件存储路径、任务状态（待执行/执行中/已完成/失败）、创建时间、完成时间
• 用Yii2队列组件实现任务与web请求隔离，可根据服务器环境选择文件/Redis作为队列驱动，长耗时导出逻辑全部放到队列任务中执行，完全不占用web请求进程

2. 前端视图代码调整 #

去掉按钮的onclick绑定，改用JS拦截表单默认提交行为，代码参考：

<!-- runtask.php 视图代码 -->
<?php $form = ActiveForm::begin([
    'action' => ['runtask'],
    'id' => 'runTask-form',
    'method' => 'post',
]);?>

<label for="par">导出参数</label>
<input type="text" name="par" id="par">
<button type="submit" class="btn btn-primary" id="submit-button">提交导出</button>
<?php ActiveForm::end();?>

<!-- 任务状态提示区 -->
<div id="task-status"></div>
<!-- 导出文件下载区 -->
<div id="download-list">
<?php
// 拉取当前用户最近的已完成导出任务
$lt = Longtask::find()->where(['username' => Yii::$app->user->identity->username])->orderBy(['id' => SORT_DESC])->one();
if ($lt && $lt->cont) {
    echo "导出结果：";
    echo Html::a(Html::encode($lt->filename), ['longtask/download', 'id' => $lt->id]);
}
?>
</div>

<?php
// 注册前端交互JS
$js = <<<JS
$('#runTask-form').on('beforeSubmit', function(e) {
    e.preventDefault();
    var form = $(this);
    // 提交任务创建请求，不等待导出执行完成
    $.ajax({
        url: form.attr('action'),
        type: 'POST',
        data: form.serialize(),
        dataType: 'json',
        success: function(res) {
            if (res.code === 0) {
                $('#task-status').html('<div class="alert alert-info">导出任务已提交，正在后台执行，完成后会通知您，您可以继续浏览其他页面</div>');
                // 轮询检查任务状态，不需要高频请求
                checkTaskStatus(res.task_id);
            } else {
                $('#task-status').html('<div class="alert alert-danger">任务提交失败：'+res.msg+'</div>');
            }
        }
    });
    return false; // 阻止表单默认同步提交
});

// 定时轮询任务状态
function checkTaskStatus(taskId) {
    setTimeout(function() {
        $.get('check-task-status', {id: taskId}, function(res) {
            if (res.status === 'done') {
                $('#task-status').html('<div class="alert alert-success">导出完成，点击下方链接下载</div>');
                $('#download-list').html(res.download_link);
            } else if (res.status === 'failed') {
                $('#task-status').html('<div class="alert alert-danger">导出失败，请重试</div>');
            } else {
                // 任务仍在执行，继续轮询
                checkTaskStatus(taskId);
            }
        });
    }, 30000); // 30秒查询一次即可，避免给服务器增加额外压力
}
JS;
$this->registerJs($js);
?>

3. 控制器与任务逻辑调整 #

控制器只负责任务创建、状态查询、文件下载，不承载长耗时导出逻辑：

// 提交导出任务入口
public function actionRuntask()
{
    Yii::$app->response->format = \yii\web\Response::FORMAT_JSON;
    $par = Yii::$app->request->post('par');
    if (!$par) {
        return ['code' => 1, 'msg' => '参数不能为空'];
    }

    // 创建任务记录，初始状态为待执行
    $lt = new Longtask();
    $lt->cleanMy(); // 清理当前用户历史无效任务
    $lt->filename = "FILE_$par.xlsx";
    $lt->task = Yii::$app->request->url;
    $lt->username = Yii::$app->user->identity->username;
    $lt->status = 0; // 0待执行 1执行中 2已完成 3失败
    $lt->save();

    // 把导出任务推送到队列，由后台进程执行，当前请求立刻返回
    Yii::$app->queue->push(new ExportJob([
        'task_id' => $lt->id,
        'par' => $par,
    ]));

    return ['code' => 0, 'task_id' => $lt->id];
}

// 任务状态查询接口
public function actionCheckTaskStatus($id)
{
    Yii::$app->response->format = \yii\web\Response::FORMAT_JSON;
    $task = Longtask::findOne(['id' => $id, 'username' => Yii::$app->user->identity->username]);
    if (!$task) {
        return ['status' => 'failed'];
    }
    if ($task->status == 2) {
        $downloadLink = Html::a(Html::encode($task->filename), ['longtask/download', 'id' => $task->id]);
        return ['status' => 'done', 'download_link' => $downloadLink];
    } elseif ($task->status == 3) {
        return ['status' => 'failed'];
    } else {
        return ['status' => 'running'];
    }
}

队列中执行的ExportJob需要注意：

• 100万行数据导出不要一次性把所有数据加载到内存，用分块查询每次读取1000-2000行写入文件
• 优先选择支持流式写入的Excel生成库，控制内存占用在几十MB级别，避免内存溢出
• 文件生成完成后更新任务状态为已完成，可通过站内信、邮件给用户发送导出完成通知

内容的提问来源于stack exchange，提问作者alberto.bissacco