Laravel：队列事件监听器查询数据库时出现记录未找到问题

嘿，这个问题我之前在项目里也踩过坑，大概率是事务提交时机 + 队列异步执行的冲突导致的，咱们来拆解原因和解决办法：

你注册用户的逻辑大概率是包裹在数据库事务里的（比如用DB::transaction()包裹创建用户及关联操作），而Beanstalkd队列是异步执行的——当你在事务内部触发UserRegistered事件时，队列Worker可能会在事务还没提交就开始执行监听器的数据库查询，这时候数据库里还没有这条用户记录，自然就抛出「记录未找到」的错误。

另外，你的事件里只传递了user_id，没有关联模型实例，也会让Laravel没法自动处理模型加载的时机问题。

1. 确保事件在事务提交后触发 #

这是最稳妥的方案，把事件触发的代码移到事务块外面，保证用户记录已经持久化到数据库：

// 事务内部处理用户创建及关联操作
DB::transaction(function () use (&$user) {
    $user = User::create([
        'name' => request('name'),
        'email' => request('email'),
        // 其他字段
    ]);
    // 其他需要在事务中执行的逻辑，比如创建用户默认角色等
});

// 事务提交后再触发事件
event(new UserRegistered($user->id));

2. 改用传递模型实例（配合SerializesModels特性） #

Laravel的SerializesModels trait本来就是用来优化模型实例序列化的——它会只存储模型ID，在队列任务执行时重新查询模型。你可以直接把User实例传入事件，而不是单独传ID，这样Laravel会帮你处理模型加载的逻辑：

修改事件类 #

class UserRegistered { 
    use Dispatchable, InteractsWithSockets, SerializesModels; 
    private $user; 

    /** 
     * Create a new event instance. 
     * 
     * @param User $user 
     */ 
    public function __construct(User $user) { 
        $this->user = $user; 
    } 

    /** 
     * @return User 
     */ 
    public function getUser() { 
        return $this->user; 
    } 
}

触发事件时传递实例 #

// 同样要保证在事务提交后触发
event(new UserRegistered($user));

监听器中使用模型 #

class UserRegisteredListener {
    public function handle(UserRegistered $event) {
        // 这里Laravel会自动重新查询模型，确保记录存在
        $user = $event->getUser();
        // 后续业务逻辑
    }
}

3. 给队列任务添加延迟（临时应急方案） #

如果暂时没法调整事务逻辑，可以给监听器的队列任务设置延迟，让事务有足够时间提交：

class UserRegisteredListener {
    // 设置延迟5秒执行
    public $delay = 5;

    public function handle(UserRegistered $event) {
        $user = User::findOrFail($event->getUserId());
        // 后续逻辑
    }
}

⚠️ 注意：这个方案不够可靠，因为事务提交的时间不确定，延迟设置太短还是会出问题，太长又会影响用户体验，所以只建议作为临时过渡方案。

• 重启队列Worker：有时候旧的Worker进程没加载最新代码，会导致逻辑不生效，执行php artisan queue:restart重启所有Worker。
• 检查事务是否回滚：如果注册逻辑中事务内部抛出了异常，会导致事务回滚，用户ID虽然生成了，但记录没写入数据库，监听器自然查不到。

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