多Laravel项目共享单队列异常：文件存储与权限分配问题求助

场景说明 #

• 同一服务器部署3个完全相同的Laravel项目：Project A、Project B、Project C
• 配置独立的队列与任务数据库：Laravel Queue Database
• 仅在Project A中运行队列进程，执行命令：php artisan queue:work
• Project B、C的任务可提交至Project A的队列执行，但出现以下异常：

1. 无论任务归属B或C，文件上传/添加操作均将文件存储至Project A的存储目录
2. 使用spatie roles组件通过任务分配权限时，系统提示“权限不存在”，因任务默认读取Project A的数据库

问题1：文件存储目录错误的解决方案 #

原因 #

队列进程运行在Project A环境中，Storage facade默认加载Project A的存储配置，导致所有任务的存储操作均指向A的目录。

解决步骤 #

1. 修改AppendLogToFile任务代码

在任务中接收对应项目的存储根路径，执行时使用自定义磁盘配置：

class AppendLogToFile implements ShouldQueue
{
    use Dispatchable, InteractsWithQueue, Queueable, SerializesModels;

    private $activity;
    private $storageRoot; // 新增：存储对应项目的根路径

    public function __construct($activity, $storageRoot)
    {
        $this->activity = $activity;
        $this->storageRoot = $storageRoot;
    }

    public function handle()
    {
        $date = $this->activity['date'];
        $company_id = $this->activity['Company_id'];
        $path = '/activities/' . $company_id . '/';
        
        // 根据传入的根路径构建自定义存储磁盘
        $disk = \Illuminate\Support\Facades\Storage::build([
            'driver' => 'local',
            'root' => $this->storageRoot,
        ]);

        $logs = json_decode($disk->get($path . $date . '.json'), true) ?? [];
        $logs[] = (object) $this->activity;
        $disk->put($path . $date . '.json', json_encode($logs));
    }
}

2. 分发任务时传入存储根路径

在Project B/C中调用任务时，传入自身项目的存储根目录：

// Project B/C中分发任务示例
AppendLogToFile::dispatch($activity, storage_path('app'));

问题2：Spatie Roles权限检查数据库错误的解决方案 #

原因 #

队列进程运行在Project A环境中，Role模型默认使用A的数据库连接；原任务中DB::setDefaultConnection(config('DB_CONNECTION'))的写法错误，config('DB_CONNECTION')获取的是当前进程（Project A）的配置，而非任务归属项目的配置。

解决步骤 #

1. 修改GivingPermissionJob任务代码

改为传递角色ID而非模型实例（避免序列化问题），同时接收对应项目的数据库连接名称：

namespace App\Jobs;

use Illuminate\Bus\Queueable;
use Illuminate\Contracts\Queue\ShouldQueue;
use Illuminate\Foundation\Bus\Dispatchable;
use Illuminate\Queue\InteractsWithQueue;
use Illuminate\Queue\SerializesModels;
use Illuminate\Support\Facades\DB;
use Spatie\Permission\Models\Role;

class GivingPermissionJob implements ShouldQueue
{
    use Dispatchable, InteractsWithQueue, Queueable, SerializesModels;

    private $roleId; // 存储角色ID替代模型实例
    private $permissionID;
    private $dbConnection; // 新增：对应项目的数据库连接名称

    public $tries = 50;

    public function __construct($roleId, $permissionID, $dbConnection)
    {
        $this->roleId = $roleId;
        $this->permissionID = $permissionID;
        $this->dbConnection = $dbConnection;
        $this->onQueue('high');
    }

    public function handle()
    {
        // 切换到对应项目的数据库连接
        DB::setDefaultConnection($this->dbConnection);
        // 强制Role模型使用指定连接查询
        $role = Role::on($this->dbConnection)->find($this->roleId);
        
        if ($role) {
            $role->givePermissionTo($this->permissionID);
        }
    }
}

2. 分发任务时传入数据库连接名称

在Project B/C中调用任务时，传入自身项目的数据库连接名称：

// Project B/C中分发任务示例，env('DB_CONNECTION')为当前项目的默认数据库连接
GivingPermissionJob::dispatch($role->id, $permissionID, env('DB_CONNECTION'));

3. 补充配置说明

确保每个项目的config/database.php中，默认的mysql连接指向自身业务数据库，queue连接指向共享的队列数据库（保持现有配置即可）。

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