Laravel+Kubernetes环境下Beanstalkd队列如何清空？

Laravel自带的php artisan queue:clear命令不支持Beanstalkd驱动，所以得用下面这些方法来清空指定队列或者所有队列：

一、清空指定队列 #

方法1：用Beanstalkd客户端脚本处理 #

先进入你的Laravel Pod：

kubectl exec -it <你的Laravel Pod名称> -- bash

如果Pod里没装Python的beanstalkc库，先安装：

pip install beanstalkc

然后创建一个简单的Python脚本（比如clear_queue.py），替换成你的Beanstalkd服务地址和目标队列名：

import beanstalkc

# 连接Beanstalkd服务，这里的host填你的Beanstalkd服务名（比如K8s里的Service名称）
conn = beanstalkc.Connection(host='beanstalkd-service', port=11300)
# 切换到要清空的队列
conn.use('messenger.hook.accept.0')
# 循环删除任务直到队列为空
while True:
    job = conn.reserve(timeout=1)
    if job is None:
        break
    job.delete()
conn.close()

执行脚本：

python clear_queue.py

方法2：自定义Laravel Artisan命令 #

在Laravel里做个自定义命令，以后清空队列更方便：

1. 生成命令文件：

php artisan make:command ClearBeanstalkdQueue

2. 打开app/Console/Commands/ClearBeanstalkdQueue.php，替换成下面的代码：

<?php

namespace App\Console\Commands;

use Illuminate\Console\Command;
use Pheanstalk\Pheanstalk;

class ClearBeanstalkdQueue extends Command
{
    protected $signature = 'queue:clear-beanstalkd {queue? : 要清空的队列名称}';
    protected $description = '清空指定的Beanstalkd队列';

    public function handle()
    {
        // 取队列名，没传的话用默认队列
        $queueName = $this->argument('queue') ?? 'default';
        // 连接Beanstalkd，用.env里的配置
        $pheanstalk = Pheanstalk::create(env('BEANSTALKD_HOST'), env('BEANSTALKD_PORT', 11300));

        // 切换到目标队列，循环删除所有任务
        $pheanstalk->useTube($queueName);
        while ($job = $pheanstalk->reserveWithTimeout(1)) {
            $pheanstalk->delete($job);
        }

        $this->info("队列 {$queueName} 已清空");
    }
}

3. 确保安装了Pheanstalk包（Laravel默认自带，没有的话执行composer require pda/pheanstalk）
4. 现在直接在Pod里执行命令清空指定队列：

php artisan queue:clear-beanstalkd messenger.hook.accept.0

二、清空所有队列 #

方法1：扩展自定义命令支持批量清空 #

修改上面的ClearBeanstalkdQueue.php，添加--all选项：

protected $signature = 'queue:clear-beanstalkd {queue? : 要清空的队列名称} {--all : 清空所有队列}';

public function handle()
{
    $pheanstalk = Pheanstalk::create(env('BEANSTALKD_HOST'), env('BEANSTALKD_PORT', 11300));

    if ($this->option('all')) {
        // 获取所有队列列表
        $allTubes = $pheanstalk->listTubes();
        foreach ($allTubes as $tube) {
            $pheanstalk->useTube($tube);
            while ($job = $pheanstalk->reserveWithTimeout(1)) {
                $pheanstalk->delete($job);
            }
            $this->info("队列 {$tube} 已清空");
        }
        $this->info("所有队列已清空");
    } else {
        $queueName = $this->argument('queue') ?? 'default';
        $pheanstalk->useTube($queueName);
        while ($job = $pheanstalk->reserveWithTimeout(1)) {
            $pheanstalk->delete($job);
        }
        $this->info("队列 {$queueName} 已清空");
    }
}

执行命令清空所有队列：

php artisan queue:clear-beanstalkd --all

方法2：用脚本批量处理 #

同样进入Pod，创建一个Python脚本（clear_all_queues.py）：

import beanstalkc

conn = beanstalkc.Connection(host='beanstalkd-service', port=11300)
# 获取所有队列
all_tubes = conn.tubes()

for tube in all_tubes:
    conn.use(tube)
    print(f"正在清空队列: {tube}")
    deleted_count = 0
    while True:
        job = conn.reserve(timeout=1)
        if job is None:
            break
        job.delete()
        deleted_count += 1
    print(f"从 {tube} 删除了 {deleted_count} 个任务")

conn.close()

执行脚本即可清空所有队列。

三、K8s环境的注意事项 #

• 执行命令时，确保Pod能访问Beanstalkd服务，直接用kubectl exec远程执行更方便，比如：

kubectl exec -it <pod-name> -- php artisan queue:clear-beanstalkd bot.run.accept.0

• 如果是多Pod部署，只需要在一个Pod里执行清空命令就行，因为Beanstalkd是共享服务。
• 清空队列前建议先暂停Worker，避免清空过程中Worker又拉走新任务：

# 把Worker Deployment缩容到0
kubectl scale deployment <你的Worker Deployment名称> --replicas=0
# 清空完成后再恢复副本数
kubectl scale deployment <你的Worker Deployment名称> --replicas=2

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