Laravel/Lumen 中使用 Echo + Socket.IO-Client 实现网页即时通讯广播

2024-04-15 11:52
文章标签 网页 广播 实现 使用 即时通讯 io client socket lumen laravel echo

本文主要是介绍Laravel/Lumen 中使用 Echo + Socket.IO-Client 实现网页即时通讯广播，希望对大家解决编程问题提供一定的参考价值，需要的开发者们随着小编来一起学习吧！

此处以 Lumen 9 框架为例说明如何调试通过 Echo 服务端以及客户端

如果你是 Laravel/Lumen 10.47+ 用户，可以先了解官方的 Laravel Reverb。注意 Laravel Reverb 仅支持 Laravel/Lumen 10.47+ 以及 PHP 8.2+

Laravel Reverb 参考官网：https://laravel.com/docs/10.x/reverb

截止 2024 年 4 月 13 日，当前仍然为 Beta 版，包信息：https://packagist.org/packages/laravel/reverb

安装

Redis

composer require illuminate/redis，如果安装失败需要根据当前框架版本指定所需 Redis 版本，例如：composer require illuminate/redis "^9.0"

Broadcasting

同 Redis，composer require illuminate/broadcasting "^9.0"

laravel-echo-server

通过 yarn 或 npm 全局安装 laravel-echo-server，如：yarn global add laravel-echo-server

注意：需要把路径 C:\Users\用户名\AppData\Local\Yarn\bin 加入环境变量 Path 中

在 macOS 中如果未修改过 /etc/paths 文件，你可能需要把 /usr/local/bin 加入到环境变量 Path 中
关于 /etc/paths 文件，可以参考这篇文章：https://maxsky.blog.csdn.net/article/details/53930406
注意 .bash_profile 文件现在变成了 .zshrc

此时运行 laravel-echo-server --version 即可看到版本号

配置

Redis 配置

在 bootstrap/app.php 中确保 $app->register(App\Providers\AppServiceProvider::class); 非注释 状态

然后打开 app/Providers/AppServiceProvider.php 文件，在 register 方法中添加如下内容：

use Illuminate\Redis\RedisServiceProvider;// ...
public function register(): void {$this->app->register(RedisServiceProvider::class);
}

Broadcast 配置

同 Redis 需要在 AppServiceProvider 中新增 Provider，现在看起来就像这样：

use Illuminate\Broadcasting\BroadcastServiceProvider;
use Illuminate\Redis\RedisServiceProvider;// ...
public function register(): void {$this->app->register(BroadcastServiceProvider::class);$this->app->register(RedisServiceProvider::class);
}

Lumen 框架用户需要在 bootstrap/app.php 中的 $app->configure() 下新增一条 $app->configure('broadcasting');，使配置文件生效

然后在 $app->register(App\Providers\AppServiceProvider::class); 下新增：

// 稍后创建该 Provider
$app->register(App\Providers\BroadcastServiceProvider::class);

最后复制 vendor/laravel/lumen-framework/config/broadcasting.php 文件至 config 目录下

记得配置 Redis 驱动，随后在项目根目录的 .env 文件中新增

BROADCAST_DRIVER=redis

Broadcast 使用 Redis 的 default 连接配置，所以在 Redis 中的 db 号是 REDIS_DB，默认为 0

配置 Facade

打开 bootstrap/app.php 文件，确保 $app->withFacades(); 为 非注释 状态，将该句修改为如下内容：

// ...
// 注意下方两句需在最后的 $app->configure() 方法之后$app->withFacades(true, array_flip(config('app.aliases')));$app->withEloquent();
// ...

打开 config 目录下存在 app.php，在最下方新增 aliases 部分，看起来就像：

return ['name' => env('APP_NAME', 'Lumen'),// ...'key' => env('APP_KEY'),'cipher' => 'AES-256-CBC','aliases' => ['App'       => Illuminate\Support\Facades\App::class,'Broadcast' => Illuminate\Support\Facades\Broadcast::class,'Eloquent'  => Illuminate\Database\Eloquent\Model::class,'File'      => Illuminate\Support\Facades\File::class,'Hash'      => Illuminate\Support\Facades\Hash::class,'Http'      => Illuminate\Support\Facades\Http::class,'View'      => Illuminate\Support\Facades\View::class,]
];

注意低版本的 Lumen 框架中可能不存在 Http 等 Facade

新增 BroadcastServiceProvider

在 app/Providers 下新增 BroadcastServiceProvider.php 文件

<?phpnamespace App\Providers;use Broadcast;
use Illuminate\Support\ServiceProvider;class BroadcastServiceProvider extends ServiceProvider {/*** Bootstrap any application services.** @return void*/public function boot(): void {// 频道授权回调，闭包中的第一个参数为已认证用户身份模型// 用户认证相关内容下方有简述，具体可参考（注意文档为 9.x 版本）：https://learnku.com/docs/laravel/9.x/authentication/12239// ---// channel 第一个参数为频道名称，此处以私有频道举例所以关联了一个 ID。该 ID 与闭包函数中的 $user_id 为绑定关系Broadcast::channel('test.{user_id}', function ($user, int $user_id) {return $user->id === $user_id;});$this->app['router']->group(['middleware' => []], function (/** @noinspection PhpUnusedParameterInspection */ $router) {require_once base_path('routes/channels.php');});}
}
用户认证简述

此处仅针对 Lumen 框架举例说明，且用户认证方式为 Token（如 JWT）

用户模型（Model）中需实现 Authorizable、Authenticatable 并引入 Authenticatable 和 Authorizable 两个 trait：

use Illuminate\Auth\Authenticatable;
use Illuminate\Contracts\Auth\Access\Authorizable as AuthorizableContract;
use Illuminate\Contracts\Auth\Authenticatable as AuthenticatableContract;
use Laravel\Lumen\Auth\Authorizable;class User extends Model implements AuthenticatableContract, AuthorizableContract {use Authenticatable, Authorizable;protected $table = 'user_table';protected $guarded = [];protected $hidden = ['password',];
}

随后修改 app/Providers/AuthServiceProvider.php，在 boot 方法中实现自己的 Token 认证逻辑即可：

/*** Boot the authentication services for the application.** @return void*/
public function boot(): void {$this->app['auth']->viaRequest('api', function (Request $request) {// 如果是自定义的 Header，通过 $request->header('Custom-Header') 获取即可$token = $request->bearerToken();if ($token) {// TODO: 自定义验证逻辑if ($verified) {return User::find('Verified User Identity'); // 如 user_no、user_id 等，此处返回用户模型}}return null;});
}

laravel-echo-server 初始化

在项目根目录运行 laravel-echo-server init，得到如下提示（参考问号后的内容）：

Do you want to run this server in development mode? Yes
Which port would you like to serve from? 6001
Which database would you like to use to store presence channel members? redis
Enter the host of your Laravel authentication server. http://localhost
Will you be serving on http or https? http                  
Do you want to generate a client ID/Key for HTTP API? No   
Do you want to setup cross domain access to the API? No
What do you want this config to be saved as? laravel-echo-server.jsonConfiguration file saved. Run laravel-echo-server start to run server.

laravel-echo-server.json 文件详细说明及配置见：

  1. 配置选项
  2. 数据库配置
  3. Redis 可选项
  4. Socket.IO 可选项

此处我们只需要确保 authHost 对应上我们项目地址，其它配置保持默认即可。authHost 可以是 IP+端口的形式，如：http://127.0.0.1:8888

发送广播

编写相关文件

首先在 routes 下新建 channels.php 文件，内容如下：

<?php// 稍后创建该控制器
use App\Http\Controllers\Broadcast\BroadcastAuthController;/** @var Laravel\Lumen\Routing\Router $router */
$router->addRoute(['GET', 'POST'], 'broadcasting/auth', BroadcastAuthController::class . '@authenticate');// 该路由用于模拟推送通知
$router->get('test_push', function () {Broadcast::event((new App\Events\ExampleBroadcastEvent(22, '你好啊')));
});

接着在 app/Http/Controllers 下新建 Broadcast 目录，然后在里面新建 BroadcastAuthController 控制器，内容如下：

<?phpnamespace App\Http\Controllers\Broadcast;use Illuminate\Http\Request;
use Illuminate\Support\Facades\Broadcast;
use Laravel\Lumen\Routing\Controller;class BroadcastAuthController extends Controller {public function authenticate(Request $request) {if ($request->hasSession()) {$request->session()->reflash();}// 注意这里我参照框架提供的用户认证实现授权，如果你有自己的一套认证代码可不使用return Broadcast::auth($request);}
}

最后创建 ExampleBroadcastEvent，生产者部分就完成了。进入 app/Events，新建 ExampleBroadcastEvent.php，内容如下：

<?phpnamespace App\Events;use Illuminate\Broadcasting\PrivateChannel;
use Illuminate\Contracts\Broadcasting\ShouldBroadcast;class ExampleBroadcastEvent extends Event implements ShouldBroadcast {/** @var string broadcast queue name */public string $queue = 'broadcast'; // 指定队列名，默认为 defaultprivate int    $user_id;private string $message;/*** Create a new event instance.** @return void*/public function __construct(?int $user_id = null, string $message = 'Hello') {$this->user_id = $user_id;$this->message = $message;}/*** Set the channel to be broadcast.** @return array*/public function broadcastOn(): array {// 此处使用私人频道，此处的频道名必须和频道授权回调中一致return [new PrivateChannel("test.$this->user_id")];}/*** Use this method to set the broadcast name, the current class name is used by default.*/public function broadcastAs(): string {// 广播名称，也可以叫做事件名称，此处为指定一个别名。如果不指定该方法，默认广播名为 App\Events\ExampleBroadcastEventreturn 'ExampleNotice';}/*** Set the broadcast payload.** @return array*/public function broadcastWith(): array {// 需通过 Socket 传输到 Web 端的数据return ['data' => ['user_id' => $this->user_id,'message' => $this->message]];}
}

测试

前面我们在 channels.php 中编写了一个路由 /test_push，此时我们可以请求该路由瞧瞧广播是否已进入 Redis 队列

即访问：http://127.0.0.1:8080/test_push（注意根据你实际监听端口和路径情况测试）

请求一次即可，然后使用 RDM 等工具查看是否已有数据：
广播队列

消费广播

配置服务端

项目根目录创建 laravel-echo-server.json 文件（注意 authHost 监听端口和 authEndpoint 路由路径）：

{"authHost": "http://127.0.0.1:8080","authEndpoint": "/broadcasting/auth","clients": [],"database": "redis","databaseConfig": {"redis": {"host": "127.0.0.1","port": 6379,"password": null,"keyPrefix": ""},"sqlite": {"databasePath": "/database/laravel-echo-server.sqlite"},"publishPresence": true},"devMode": true,"host": null,"port": "6001","protocol": "http","socketio": {"allowEIO3": true,"cors": {"origin": "*","credentials": true}},"secureOptions": 67108864,"sslCertPath": "","sslKeyPath": "","sslCertChainPath": "","sslPassphrase": "","subscribers": {"http": true,"redis": true},"apiOriginAllow": {"allowCors": true,"allowOrigin": "*"}
}

运行服务端

项目根目录运行：

laravel-echo-server start

得到如下提示即为正确：

L A R A V E L  E C H O  S E R V E Rversion 1.6.3                      ⚠ Starting server in DEV mode...   ✔  Running at localhost on port 6001
✔  Channels are ready.          
✔  Listening for http events... 
✔  Listening for redis events...Server ready!

准备客户端

参考：https://github.com/maxsky/Laravel-Echo-Client-Demo

该 Demo 需要编辑 js/app.js 文件，根据项目情况生成 Token，可写死在 auth.headers 中或使用 bearerToken

因为我们这里使用了私人频道，所以 channel() 方法应该修改为 private()

Channel_Name 需修改为 test. 加上 Token 所对应的用户 ID，如 test.22

ExampleEvent 需修改为 ExampleNotice。如果你删掉了 ExampleBroadcastEvent 中的 broadcastAs() 方法，此处应当输入 ExampleBroadcastEvent 并移除上分 namespace 配置项或将 null 修改为 'App.Events'

这部分代码修改后看起来就像这样：

window.Echo = new Echo({broadcaster: 'socket.io',host: 'http://127.0.0.1:6001',auth: {headers: {'User-Agent': navigator.userAgent,'Custom-Header': 'Custom Header Value',}},withCredentials: true,bearerToken: 'Your Token',namespace: null // only for used `broadcastAs` method
});window.Echo.private('test.22').listen('ExampleNotice', (res) => {console.log(res);
});

运行客户端

在上述 Demo 中，运行 yarn dev 后默认可通过 http://127.0.0.1:5173 访问客户端

注意页面没内容，我们需要按下 F12 打开开发者工具并切换到 Network/网络 选项卡进行观察

可以刷新页面，找到一条类似 ws://127.0.0.1:6001/socket.io/?EIO=3&transport=websocket&sid=XXXXX 的链接，选中后点击右侧的 Messages/消息 选项卡等待即可

运行队列

在项目根目录下运行：

php artisan queue:work

如果出现处理提示说明消费成功。当然，因为我们在 ExampleBroadcastEvent.php 文件中修改了队列名所以此处不会出现任何执行信息

我们需在该命令中添加参数 --queue=队列名，所以 Ctrl+C 终止运行后试试这句：php artisan queue:work --queue=broadcast

如果没有任何问题，应该会看到类似下面的提示：

2023-05-01 05:00:01 App\Events\ExampleBroadcastEvent ........ RUNNING
2023-05-01 05:00:01 App\Events\ExampleBroadcastEvent .... 7.80ms DONE

转过头再看看 laravel-echo-server 那边，除了会出现之前刷新时的 joined channel: test 外，应该会有下方提示：

Channel: private-test.22
Event: ExampleNotice
Channel: private-test.22
Event: ExampleNotice

如果一切顺利，回到浏览器，查看刚刚的 Messages/消息 中，是否出现了 ExampleBroadcastEvent 中 broadcastWith() 返回的内容

最后

  • Web 端 socket.io-client 客户端必须使用 ^2.0 版本，不可使用 ^3.0 或 ^4.0（Client Demo 中已说明），除非 laravel-echo-server 中依赖的 socket.io 服务版本变更。所以 laravel-echo-server.json 配置中 socketio.allowEIO3 选项是无效的。具体兼容说明见：https://socket.io/docs/v4/troubleshooting-connection-issues#the-client-is-not-compatible-with-the-version-of-the-server
  • 部分配置项可写在项目根目录的 .env 环境文件中，支持的环境变量见：envVariables

流程总结

  1. 启动 WebSocket 服务端，在项目根目录运行 laravel-echo-server start；
  2. 编写广播事件，参考 ExampleBroadcastEvent；
  3. 通过 Broadcast::event() 方法生产消息并存储于 Redis 中等待队列消费，例如：Broadcast::event((new App\Events\ExampleBroadcastEvent(22, 'Hello')))；
  4. 启动 Web 网页并连接到服务端，连接端口为 laravel-echo-server.json 中的 port 配置项；
  5. 使用命令启动队列监听以执行消费，根据示例文件应当在项目根目录运行 php artisan queue:work --queue=broadcast
  6. 队列提示消费 DONE 完成后，事件中 broadcastWith 方法的返回值将被传送至 Web 端，至此流程结束

频道授权需仔细参考框架文档用户认证以及授权频道部分

这篇关于Laravel/Lumen 中使用 Echo + Socket.IO-Client 实现网页即时通讯广播的文章就介绍到这儿，希望我们推荐的文章对编程师们有所帮助！


http://www.chinasem.cn/article/905743。

相关文章

Kali Linux安装实现教程(亲测有效)

Kali Linux安装实现教程(亲测有效)

《KaliLinux安装实现教程(亲测有效)》：本文主要介绍KaliLinux安装实现教程(亲测有效),具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地方,望不吝赐教... 目录一、下载二、安装总结一、下载1、点http://www.chinasem.cn击链接 Get Kali | Kal
阅读更多...
C#使用MQTTnet实现服务端与客户端的通讯的示例

C#使用MQTTnet实现服务端与客户端的通讯的示例

《C#使用MQTTnet实现服务端与客户端的通讯的示例》本文主要介绍了C#使用MQTTnet实现服务端与客户端的通讯的示例,包括协议特性、连接管理、QoS机制和安全策略,具有一定的参考价值,感兴趣的可... 目录一、MQTT 协议简介二、MQTT 协议核心特性三、MQTTNET 库的核心功能四、服务端（BR
阅读更多...
使用@Cacheable注解Redis时Redis宕机或其他原因连不上继续调用原方法的解决方案

使用@Cacheable注解Redis时Redis宕机或其他原因连不上继续调用原方法的解决方案

《使用@Cacheable注解Redis时Redis宕机或其他原因连不上继续调用原方法的解决方案》在SpringBoot应用中,我们经常使用​​@Cacheable​​注解来缓存数据,以提高应用的性能... 目录@Cacheable注解Redis时，Redis宕机或其他原因连不上，继续调用原方法的解决方案1
阅读更多...
SpringCloud整合MQ实现消息总线服务方式

SpringCloud整合MQ实现消息总线服务方式

《SpringCloud整合MQ实现消息总线服务方式》：本文主要介绍SpringCloud整合MQ实现消息总线服务方式,具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地方,望不吝赐... 目录一、背景介绍二、方案实践三、升级版总结一、背景介绍每当修改配置文件内容，如果需要客户端也同步更新，
阅读更多...
Dubbo之SPI机制的实现原理和优势分析

Dubbo之SPI机制的实现原理和优势分析

《Dubbo之SPI机制的实现原理和优势分析》：本文主要介绍Dubbo之SPI机制的实现原理和优势,具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地方,望不吝赐教... 目录Dubbo中SPI机制的实现原理和优势JDK 中的 SPI 机制解析Dubbo 中的 SPI 机制解析总结Dubbo中
阅读更多...
java中XML的使用全过程

java中XML的使用全过程

《java中XML的使用全过程》：本文主要介绍java中XML的使用全过程,具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地方,望不吝赐教... 目录什么是XML特点XML作用XML的编写语法基本语法特殊字符编写约束XML的书写格式DTD文档schema文档解析XML的方法​​DOM解析XM
阅读更多...
使用Java实现Navicat密码的加密与解密的代码解析

使用Java实现Navicat密码的加密与解密的代码解析

《使用Java实现Navicat密码的加密与解密的代码解析》：本文主要介绍使用Java实现Navicat密码的加密与解密,通过本文,我们了解了如何利用Java语言实现对Navicat保存的数据库密... 目录一、背景介绍二、环境准备三、代码解析四、核心代码展示五、总结在日常开发过程中，我们有时需要处理各种软
阅读更多...
Java 压缩包解压实现代码

Java 压缩包解压实现代码

《Java压缩包解压实现代码》Java标准库（JavaSE）提供了对ZIP格式的原生支持,通过java.util.zip包中的类来实现压缩和解压功能,本文将重点介绍如何使用Java来解压ZIP或RA... 目录一、解压压缩包1.zip解压代码实现:2.rar解压代码实现：3.调用解压方法：二、注意事项三、总
阅读更多...
NGINX 配置内网访问的实现步骤

NGINX 配置内网访问的实现步骤

《NGINX配置内网访问的实现步骤》本文主要介绍了NGINX配置内网访问的实现步骤,Nginx的geo模块限制域名访问权限,仅允许内网/办公室IP访问,具有一定的参考价值,感兴趣的可以了解一下... 目录需求1. geo 模块配置2. 访问控制判断3. 错误页面配置4. 一个完整的配置参考文档需求我们有一
阅读更多...
Linux实现简易版Shell的代码详解

Linux实现简易版Shell的代码详解

《Linux实现简易版Shell的代码详解》本篇文章,我们将一起踏上一段有趣的旅程,仿照CentOS–Bash的工作流程,实现一个功能虽然简单,但足以让你深刻理解Shell工作原理的迷你Sh... 目录一、程序流程分析二、代码实现1. 打印命令行提示符2. 获取用户输入的命令行3. 命令行解析4. 执行命令
阅读更多...

Copyright China编程 23002807@qq.com

沪ICP备2023033072号-2