当前位置: 首页 > news >正文

在 Laravel 12 中实现 WebSocket 通信

在 Laravel 12 中实现 WebSocket 通信主要有两种主流方案:‌官方推荐的 Laravel Reverb‌ 和 ‌第三方库(如 Soketi/Pusher 或 Workerman/Swoole)‌。以下是详细实现步骤:

一、官方方案:Laravel Reverb(推荐)

Laravel Reverb 是 Laravel 官方推出的高性能 WebSocket 服务,完全集成到框架中,适合标准实时场景(如聊天、通知)。

1. 安装 Laravel Reverb

composer require laravel/reverb
php artisan reverb:install

2. 配置环境变量(.env)

BROADCAST_DRIVER=reverb   # 设置广播驱动为 Reverb
REVERB_SERVER_HOST=0.0.0.0  # 监听地址
REVERB_SERVER_PORT=8080     # 监听端口
REVERB_APP_ID=your_app_id   # 应用唯一标识
REVERB_APP_KEY=your_app_key # 与前端 Echo 配置一致
REVERB_APP_SECRET=your_app_secret # 安全密钥

3. 启动 Reverb 服务

php artisan reverb:start
# 生产环境建议使用守护进程模式
php artisan reverb:start --daemon

4. 创建广播事件

php artisan make:event NewMessage

编辑 app/Events/NewMessage.php:

<?php
namespace App\Events;
use Illuminate\Broadcasting\Channel;
use Illuminate\Contracts\Broadcasting\ShouldBroadcast;class NewMessage implements ShouldBroadcast {public $message;public function __construct($message) {$this->message = $message;}public function broadcastOn() {// 广播到频道 "chat"return new Channel('chat');}
}

5. 前端订阅(Laravel Echo)

安装 Laravel Echo 和 WebSocket 客户端:

npm install --save laravel-echo pusher-js

配置 resources/js/bootstrap.js:

import Echo from 'laravel-echo';
window.Pusher = require('pusher-js');window.Echo = new Echo({broadcaster: 'reverb',key: process.env.MIX_REVERB_APP_KEY,wsHost: window.location.hostname,wsPort: process.env.MIX_REVERB_PORT || 8080,forceTLS: false, // 本地开发禁用 HTTPSenabledTransports: ['ws', 'wss'],
});

订阅频道并监听事件:

// 订阅公共频道
Echo.channel('chat').listen('NewMessage', (data) => {console.log('收到消息:', data.message);});// 订阅私有频道(需要认证)
Echo.private('chat.${userId}').listen('NewMessage', (data) => { /* ... */ });

6. 触发广播事件

use App\Events\NewMessage;// 在控制器或任何地方触发事件
event(new NewMessage('Hello, WebSocket!'));

二、备选方案:Soketi(轻量级 Pusher 替代)

如果你需要更轻量级的解决方案,可以使用 Soketi(兼容 Pusher 协议)。

1. 安装 Soketi

npm install -g @soketi/soketi
soketi start --config=soketi.json

2. 配置 Laravel

修改 .env:

BROADCAST_DRIVER=pusher
PUSHER_APP_ID=your_app_id
PUSHER_APP_KEY=your_app_key
PUSHER_APP_SECRET=your_app_secret
PUSHER_HOST=127.0.0.1
PUSHER_PORT=6001
PUSHER_SCHEME=http  # 生产环境改为 https

3. 前端 Echo 配置

window.Echo = new Echo({broadcaster: 'pusher',key: process.env.MIX_PUSHER_APP_KEY,wsHost: process.env.MIX_PUSHER_HOST || window.location.hostname,wsPort: process.env.MIX_PUSHER_PORT || 6001,forceTLS: false,enabledTransports: ['ws', 'wss'],
});

三、高级场景:私有频道与认证

1. 频道认证路由

在 routes/channels.php 中定义私有频道授权:

Broadcast::channel('chat.{userId}', function ($user, $userId) {return $user->id === (int) $userId; // 验证用户权限
});

2. 前端订阅私有频道

Echo.private('chat.' + userId).listen('NewMessage', (data) => { /* ... */ });

四、生产环境部署

HTTPS 配置‌:

必须使用 SSL 证书加密 WebSocket(wss://)。
修改前端 Echo 配置中的 forceTLS: true。

window.Echo = new Echo({// ...forceTLS: true,disableStats: true, // 禁用统计
});

Supervisor 守护进程‌(Reverb):

[program:reverb]
command=php /path/to/artisan reverb:start --daemon
autostart=true
autorestart=true
stderr_logfile=/var/log/reverb.err.log
stdout_logfile=/var/log/reverb.out.log

五、常见问题排查

连接失败‌:

检查防火墙是否开放端口(8080/6001)。
确认服务正在运行:php artisan reverb:status。
查看日志:tail -f storage/logs/laravel.log。

跨域问题‌:
在 config/cors.php 中允许 WebSocket 域名:

'paths' => ['api/*', 'broadcasting/*'],
'allowed_origins' => ['https://your-domain.com'],

六、性能优化

Reverb 集群‌:多节点部署时使用 Redis 共享连接状态。
Swoole/Workerman‌:如需更高性能(10万+并发),可集成 Swoole:

composer require swooletw/laravel-swoole
php artisan swoole:http start

以上方案覆盖了从开发到生产的完整流程。对于大多数项目,‌Laravel Reverb‌ 是最简单直接的方案;若需要更高灵活性或兼容 Pusher 生态,则选择 ‌Soketi‌。

http://www.xdnf.cn/news/299935.html

相关文章:

  • pyqt写一个TCP(UDP)检测工具
  • 【Python】一键提取视频音频并生成MP3的完整指南 by `MoviePy`
  • 基于Jetson Nano与PyTorch的无人机实时目标跟踪系统搭建指南
  • 20250506异形拼图块(圆形、三角、正方,椭圆/半圆)的中2班幼儿偏好性测试(HTML)
  • 【ArcGISPro】属性规则--属性联动
  • 记一次ffmpeg延迟问题排查
  • 个人码支付免签系统三网免挂支付宝微信QQ钱包即时到账收款二维码聚合支付源码
  • 使用 OpenSSL 吊销 Kubernetes(k8s)的 kubeconfig 里的用户证书
  • uv全功能更新:统一管理Python项目、工具、脚本和环境的终极解决方案
  • 嵌入式学习--江协51单片机day1
  • GCC编译器安装详细说明(举例arm-2013q3)
  • pywinauto通过图片定位怎么更加精准的识别图片?
  • 抖音代播领航者——品融电商(PINKROON)的运营实力与服务解析
  • 使用 AddressSanitizer 检测堆越界错误
  • 【CPU占用率查看】
  • 创建简易个人关系图谱(Neo4j )
  • 【落羽的落羽 C++】list及其模拟实现
  • On the Biology of a Large Language Model——论文学习笔记——拒答和越狱
  • 华为私有协议Hybrid
  • 5月6日日记
  • QtGUI模块功能详细说明,图像处理(三)
  • 目标检测(Object Detection)研究方向常用数据集简单介绍
  • 【Bootstrap V4系列】学习入门教程之 组件-卡片(Card)高级用法
  • 数据初步了解
  • 论文速读:《CoM:从多模态人类视频中学习机器人操作,助力视觉语言模型推理与执行》
  • 电池热管理CFD解决方案,为新能源汽车筑安全防线
  • TikTok 矩阵账号运营实操细节:打造爆款矩阵
  • SpringBoot整合Kafka、Flink实现流式处理
  • 三种信号本振
  • Redis 7.0中5种新特性及实战应用