首先配置 laravel 的 redis 广播驱动并设置 queue_connection=redis，接着创建实现 shouldbroadcast 接口的事件类 usernotificationevent，通过 laravel-echo-server 建立 websocket 服务，前端使用 laravel echo 订阅私有频道监听事件，最后启动 queue:work 消费任务以实现实时通知推送。
如果您在开发 Laravel 应用时需要向用户推送实时通知，但默认的轮询机制效率低下且延迟较高，可以通过集成 WebSocket 来实现高效的消息广播。Laravel 提供了广播系统与前端事件监听的完整支持，结合 WebSocket 服务可以实现实时通信。
本文运行环境：MacBook Pro，macOS Sonoma
一、配置 Laravel 广播驱动
Laravel 支持多种广播驱动，其中 Redis 配合广播队列是常用方案，可将事件推送到消息通道。需要先设置广播驱动为 Redis，并确保队列服务正常运行。
1、打开 .env 文件，修改广播驱动和队列连接：
BROADCAST_DRIVER=redis
QUEUE_CONNECTION=redis
2、在 config/broadcasting.php 中确认 Redis 连接配置正确，通常使用默认 redis 连接即可。
3、确保已安装 predis/predis 或 phpredis 扩展，用于 PHP 与 Redis 通信。
二、创建广播事件类
广播事件是触发通知的核心，每个需要推送的消息都应封装成一个实现了 ShouldBroadcast 接口的事件类，以便自动发布到指定频道。
1、使用 Artisan 命令生成事件类：
php artisan make:event UserNotificationEvent
2、编辑生成的 app/Events/UserNotificationEvent.php 文件，引入 ShouldBroadcast 接口并定义广播频道：
use Illuminate\Broadcasting\Channel;
use Illuminate\Broadcasting\InteractsWithSockets;
use Illuminate\Broadcasting\PresenceChannel;
use Illuminate\Broadcasting\PrivateChannel;
use Illuminate\Contracts\Broadcasting\ShouldBroadcast;
use Illuminate\Foundation\Events\Dispatchable;
use Illuminate\Queue\SerializesModels;
class UserNotificationEvent implements ShouldBroadcast
{
use Dispatchable, InteractsWithSockets, SerializesModels;
public $message;
public function __construct($message)
{
$this->message = $message;
}
public function broadcastOn()
{
return new PrivateChannel('user.' . auth()->id());
}
}
三、启动 Laravel Echo Server
Laravel Echo Server 是一个 Node.js 实现的服务，用于接收 Laravel 发出的广播事件并转发给客户端 WebSocket 连接。它作为 Laravel 与前端之间的桥梁。
1、全局安装 laravel-echo-server：
npm install -g laravel-echo-server
2、在项目根目录初始化配置：
laravel-echo-server init
按照提示选择是否启用对称加密、端口、Redis 等选项。
3、启动服务器：
laravel-echo-server start
此时服务会监听 6001 端口（默认），等待来自 Laravel 的广播和客户端的连接。
四、前端接入 Laravel Echo 与 WebSocket
前端需要通过 Laravel Echo 库订阅频道并监听事件，从而接收实时通知。Echo 封装了对 Pusher 和 Socket.io 的调用，简化了 WebSocket 使用流程。
1、安装依赖包：
npm install --save laravel-echo pusher-js
2、在 JavaScript 入口文件中配置 Echo 实例：
import Echo from "laravel-echo"
window.Pusher = require('pusher-js');
window.Echo = new Echo({
broadcaster: 'socket.io',
host: 'http://localhost:6001'
});
3、监听私有频道上的通知事件：
window.Echo.private(`user.${userId}`)
.listen('UserNotificationEvent', (e) => {
console.log(e.message);
});
五、使用 Redis 与 Queue 处理广播队列
当事件被触发后，Laravel 会将其推入队列由 Redis 传递给广播服务。必须运行队列工作进程来消费这些任务，否则事件不会真正广播出去。
1、确保 queue driver 已设为 redis，在 .env 中检查：
QUEUE_CONNECTION=redis
2、启动队列监听器：
php artisan queue:work
该命令将持续监听队列中的任务，包括广播事件的分发。
3、若需处理失败任务，可执行：
php artisan queue:failed-table
php artisan migrate
