Laravel 5.4：如何实现带条件触发的延迟通知？

当然可以实现！你的需求核心是延迟执行+条件触发，而sleep()和Laravel原生delay()的问题在于它们都是「固定延迟后强制执行」，没法在延迟过程中根据消息的阅读状态动态调整。下面给你两种落地性强的实现思路：

方案一：Laravel队列任务+数据库状态检查 #

这是最容易上手的方案，利用Laravel的延迟队列特性，结合消息的阅读状态字段来判断是否发送通知。

步骤1：给消息表添加状态字段 #

首先确保你的消息模型（比如Message）有两个关键字段：

• is_read：布尔类型，默认false，标记消息是否被阅读
• sent_at：时间类型，记录消息发送的时间

可以通过迁移添加：

php artisan make:migration add_read_fields_to_messages_table

迁移文件代码：

public function up()
{
    Schema::table('messages', function (Blueprint $table) {
        $table->boolean('is_read')->default(false);
        $table->timestamp('sent_at')->useCurrent();
    });
}

步骤2：创建延迟队列任务 #

生成一个专门处理通知发送的任务：

php artisan make:job SendMessageReadNotification

在任务类中，我们会在延迟5秒后检查消息状态，符合条件才发送通知：

namespace App\Jobs;

use App\Models\Message;
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\Notification;
use App\Notifications\MessageWasReadNotification; // 你的通知类

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

    protected $message;

    // 注入消息模型实例
    public function __construct(Message $message)
    {
        $this->message = $message;
    }

    public function handle()
    {
        // 核心判断：消息已读，且阅读发生在发送后的5秒内
        if ($this->message->is_read && now()->diffInSeconds($this->message->sent_at) <= 5) {
            // 给消息发送者发送通知（这里根据你的业务调整接收对象）
            Notification::send($this->message->sender, new MessageWasReadNotification($this->message));
        }
    }
}

步骤3：发送消息时调度延迟任务 #

当用户发送消息时，保存消息并调度延迟5秒的任务：

// 保存消息到数据库
$message = Message::create([
    'content' => $request->content,
    'sender_id' => auth()->id(),
    'receiver_id' => $request->receiver_id,
]);

// 延迟5秒执行通知任务
SendMessageReadNotification::dispatch($message)->delay(now()->addSeconds(5));

步骤4：处理消息阅读逻辑 #

当接收者打开消息标记为已读时，更新is_read状态：

// 假设这是标记已读的接口逻辑
$message = Message::findOrFail($request->message_id);
$message->update(['is_read' => true]);

方案二：Redis延迟键+队列（更高效的取消机制） #

如果希望在消息被阅读后直接取消延迟任务（避免队列里的无效任务），可以结合Redis的键过期特性：

1. 发送消息时，在Redis中设置一个键，过期时间5秒：

$redisKey = "message:read:{$message->id}";
Redis::set($redisKey, 'false');
Redis::expire($redisKey, 5);

2. 当消息被阅读时，更新Redis键的值为true，并移除过期时间：

Redis::set($redisKey, 'true');
Redis::persist($redisKey);

3. 创建队列任务，延迟5秒后检查Redis键的值：

public function handle()
{
    $redisKey = "message:read:{$this->message->id}";
    if (Redis::get($redisKey) === 'true') {
        // 发送通知逻辑
        Notification::send($this->message->sender, new MessageWasReadNotification($this->message));
    }
    // 清理Redis键
    Redis::del($redisKey);
}

这个方案的好处是，如果消息在5秒内被阅读，我们可以提前标记状态，任务执行时直接判断，甚至可以通过Redis的过期回调来触发任务（不过需要额外配置Redis的notify-keyspace-events）。

关键注意事项 #

• 确保你的Laravel队列驱动不是sync（同步驱动会阻塞请求），推荐使用redis或database驱动，需要提前配置好队列监听：php artisan queue:work
• 消息阅读状态的更新要保证实时性，避免出现延迟更新导致判断错误
• 如果是分布式环境，要确保Redis或数据库的状态是全局一致的

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