laravel广播系统怎么结合WebSocket实现实时通知_laravel广播与WebSocket实时通知实现

首先配置 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 与前端之间的桥梁。

Linfo.ai

Linfo AI 是一款AI驱动的 Chrome 扩展程序，可以将网页文章、行业报告、YouTube 视频和 PDF 文档转换为结构化摘要。

151

查看详情

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

以上就是laravel广播系统怎么结合WebSocket实现实时通知_laravel广播与WebSocket实时通知实现的详细内容，更多请关注php中文网其它相关文章！