Laravel如何从控制器向运行中队列传值以实现阻塞式外部程序交互

你选择用队列Job异步运行阻塞外部程序的方案是完全合理的。
阻塞类程序如果直接在控制器生命周期内执行，会导致请求长时间挂起，大概率触发服务器或者PHP的请求超时限制，无法返回验证码填写视图。将阻塞逻辑下沉到异步队列后，控制器可以快速响应返回视图，完全匹配你的业务流程要求。

Laravel原生队列没有提供向运行中Job推送消息的能力，你可以通过下面两种可落地的方案实现需求：

方案1：共享存储轮询（推荐，实现成本最低） #

核心逻辑是用Redis/数据库作为中间共享存储，Job启动后轮询存储中对应唯一标识的验证码值，控制器收到用户提交的验证码后写入存储即可：

• 第一次表单提交时生成全局唯一的核验ID（用UUID即可），存入Session同时传给队列Job
• Job启动阻塞外部程序后，按固定间隔轮询共享存储中对应核验ID的验证码，拿到验证码后传递给外部程序完成验证
• 第二次用户提交验证码时，控制器直接将验证码和对应核验ID写入共享存储，设置短过期时间即可

示例代码参考：

// 第一次提交的控制器逻辑
$verifyId = Str::uuid()->toString();
session(['current_verify_id' => $verifyId]);
// 触发队列Job
RunExternalSmsJob::dispatch($verifyId);
return view('sms-verify');

// 队列Job内部逻辑
public function handle()
{
    // 用proc_open打开外部程序的双向输入输出管道
    $desc = [
        0 => ['pipe', 'r'], // 外部程序的标准输入，用来传验证码
        1 => ['pipe', 'w'], // 外部程序的标准输出，用来读验证结果
        2 => ['pipe', 'w']
    ];
    $proc = proc_open('/path/to/your/external/sms/program', $desc, $pipes);

    if (is_resource($proc)) {
        // 最多等待5分钟超时
        $expireAt = now()->addMinutes(5);
        while (now()->lessThan($expireAt)) {
            // 轮询缓存中的验证码
            $smsCode = Cache::get("sms_code_{$this->verifyId}");
            if ($smsCode) {
                // 将验证码写入外部程序的标准输入
                fwrite($pipes[0], $smsCode . PHP_EOL);
                fclose($pipes[0]);
                // 读取验证结果存入缓存，后续控制器可以查询结果
                $verifyResult = trim(stream_get_contents($pipes[1]));
                Cache::put("sms_result_{$this->verifyId}", $verifyResult, 60);
                break;
            }
            // 每0.5秒轮询一次，降低性能消耗
            usleep(500000);
        }
        // 关闭进程和管道
        fclose($pipes[1]);
        fclose($pipes[2]);
        proc_close($proc);
    }
}

// 第二次提交验证码的控制器逻辑
$verifyId = session('current_verify_id');
Cache::put("sms_code_{$verifyId}", $request->input('sms_code'), 120);
// 可以轮询sms_result对应的缓存值获取验证结果

方案2：套接字通信（低延迟，适合高并发场景） #

如果轮询的延迟不符合你的要求，可以在队列Job启动时监听一个临时Unix套接字或者随机TCP端口，将套接字地址和核验ID绑定存入共享存储，控制器收到验证码后直接向对应套接字发送数据即可，不需要轮询。

• 必须给队列Job设置超时时间，避免用户长时间不提交验证码导致进程一直挂起占用资源
• 不要用Symfony Process的wait()方法阻塞等待外部程序返回，要手动控制输入输出管道的读写
• 共享存储的key要加唯一前缀避免冲突，设置合理的过期时间自动清理无效数据

内容的提问来源于stack exchange，提问作者Julien