首页
学习
活动
专区
工具
TVP
发布
精选内容/技术社群/优惠产品,尽在小程序
立即前往

基于 Redis 实现 Laravel 广播功能(下):在私有频道和存在频道发布和接收消息

在私有频道广播事件消息 在上面的示例广播事件 UserSignedUp 中,我们通过 Channel 定义了一个公共频道广播,即所有客户端都可以接收到这个事件消息: public function broadcastOn...$this->groupId 频道的客户端,在客户端(在 resources/views/websocket.blade.php 中模拟),我们可以通过 Echo.private 方法接收上面这个私有频道广播的消息...,需要注释掉 config/database.php 中 redis.options.prefix 里面定义的 laravel_database_ 前缀,因为 Laravel Echo 目前没有提供这个前缀设置...在存在频道广播事件消息 存在频道是建立私有频道基础之上的,因此需要也需要认证和授权,所谓存在频道其实指的是订阅了特定私有频道的所有在线连接,还是以微信/QQ群为例,通过存在频道我们可以统计某个群(私有频道...,可以在分发事件返回实例上调用 toOthers 方法告知系统将这个事件消息广播给排除当前用户的所有其他在线用户。

3.2K30
  • 您找到你想要的搜索结果了吗?
    是的
    没有找到

    基于 Redis 实现 Laravel 广播功能(中):引入 Laravel Echo 接收广播消息

    通过 Sail 编排 Laravel Echo Server 在项目根目录的 docker 目录下(我已经通过 sail artisan sail:publish 发布了 Sail 的容器编排文件,所有会有这个目录...laravel-echo 然后在 resources/js/bootstrap.js 中取消 Laravel Echo 相关代码前面的注释,并将 Pusher 客户端实现调整为 Socket.io...,这样一来,我们就可以使用 Laravel 广播系统提供的所有功能了,包括事件广播的推送和接收、私有频道、存在频道等。...验证 Laravel 事件广播消息推送 在访问 /broadcast 路由前,还需要在 resources/views/websocket.blade.php 的 标签中添加获取 CSRF...表示客户端断开连接,之所以出现下面这个 joined-left-joined 日志,是因为我刷新过 /broadcast 页面: 在浏览器中也可以在开发者工具中看到熟悉 Socket.io Websocket

    3.8K10

    基于 Redis 发布订阅 + Socket.io 实现事件消息广播功能

    Redis 发布的消息,再将其广播到所有与之建立连接的 Websocket 客户端(基于 Socket.io 提供的 API 方法); 在 Websocket 客户端(基于 Socket.io 实现)...频道(laravel_database_ 是 Laravel Redis 数据库的默认前缀),一旦 Redis 服务端在这个频道发送了消息(比如执行了 redis:publish 命令),就能通过 redis.on...你可以通过如下命令启动这个 Websocket 服务器: sail node websocket.js 学院君这里使用了 Laravel Sail 作为本地开发环境,对应其他环境,在相应环境中通过...还是以 Sail 为例,我们需要将应用容器中的 3000 端口暴露出来,才可以被客户端访问,在 .env 中新增一个 WEBSOCKET_PORT 配置: WEBSOCKET_PORT=3000 然后在...这篇教程偏底层基本原理,下篇教程,学院君将结合事件广播 + Redis 消息队列 + Laravel Echo Server + Laravel Echo 更系统更全面地介绍 Laravel 广播组件的所有高阶功能使用

    4.6K20

    php-laravel Redis 广播

    前言在很多现代 Web 应用中,WebSockets被用于实现实时更新的用户接口。当一些数据在服务器上被更新,通常一条消息通过 Websocket 连接被发送给客户端处理。...这为我们提供了一个更强大的、更有效的选择来持续拉取应用的更新。为实现的这样的应用,Laravel 中 通过 Websocket 连接广播事件使开发变得简单。...广播 Laravel 事件允许你在服务端和客户端 JavaScript 框架之间共享同一事件名本 文档 仅使用了 redis的广播驱动 简介laravel 的广播系统和队列系统类似,需要两个进程协作,一个是...具体的流程是页面加载时,网页 js 程序 Laravel Echo 与 Socket.IO 服务器建立连接, laravel 发起通过驱动发布广播,Socket.IO 服务器接受广播内容,对连接的客户端网页推送信息...端可以轻松订阅频道并收听Laravel广播的事件通过 npm 包管理器安装 Echo npm install npm install laravel-echo-server初始化 laravel-echo-server

    13610

    【Laravel系列7.8】广播系统

    今天的内容就是简单的搭起广播系统的环境即可,源码不多说了,因为广播系统实际上是使用了我们之前学习过的队列和事件来实现的。...广播相关的配置在 config/broadcasting.php 中。...在这个方法中,返回一个 Channel 实例,它就是我们要指定广播的频道。在这里我们直接给了一个频道名称为 messages 。...另外,在这个事件类中,我们定义了一个公共属性用于接收构造函数传来的参数,在广播事件中,公共属性是可以广播到前端去的。 接下来,我们定义一个路由用于触发广播事件。...在具体的页面中,我们直接去调用它的 channel() 方法,给一个指定的频道名称,然后监听这个频道中的具体事件,也就是我们在 Laravel 中定义的事件类名。

    2.3K20

    基于 Pusher 驱动的 Laravel 事件广播(上)

    ; }); 作者在MAMP PRO环境中,Apache端口是8888,在浏览器中输入http://laravelpusher.app:8888/bridge路由,正确返回This is a Laravel...pusher:'default' => env('BROADCAST_DRIVER', 'pusher'),如果不是可以在.env文件中添加BROADCAST_DRIVER=pusher。...同时,还需要在broadcastOn()函数中写入任意字符的广播频道: class PusherEvent extends Event implements ShouldBroadcast {...作者在个人环境中,输入http://laravelpusher.app:8888/bridge,在storage/logs/laravel.log中会出现类似如下的调试信息,可以先清空下laravel.log...这里订阅Laravel Pusher Bridge里写的test-channel频道,绑定test-event事件,打印text属性的数据,我们知道上文中我们写入了数据为['text' => 'I Love

    3K31

    Laravel 广播系统工作原理

    如果您遇到在 Laravel 中需要实现当服务器处理完成某项工作后向客户端发送消息这类的功能,那么您需要使用到 Laravel 的广播系统。...,将接收这个频道的消息; 最后,客户端还会注册其所订阅的频道的监听事件; 当服务端完成指定功能后,我们以指定频道名称和事件名称的信息通知到 WebSocket 服务器; 最终,WebSocket 服务器将这个指定事件已广播的形式推送到所有注册这个频道监听的客户端...下一节,我们将讲解客户端类库的安装。 客户端 Pusher 和 Laravel Echo 类库的安装配置 在广播系统中,客户端接口负责连接 WebSocket 服务器、订阅指定频道和监听事件等功能。...接下来还在 NewMessageNotification 类中创建了一个 broadcastOn 方法,在该方法中定义了广播事件的频道名称,因为只有登录的用户才能接收消息,所以这里创建了 PrivateChannel...{USER_ID} 私有频道。 如果您在客户端程序使用了 Laravel Echo 组件处理订阅服务。那在客户端代码中仅需设置频道路由即可,而无需关心用户认证处理细节。

    9.2K20

    Laravel学习教程之广播模块详解

    广播是指发送方发送一条消息,订阅频道的各个接收方都能及时收到消息;比如 A同学写了一篇文章,这时候 B同学在文章底下评论了,A同学在页面上是不用刷新就能收到提示有文章被评论了,这个本质上就是A同学收到了广播消息...,这个广播消息是由B同学评论这个动作触发了发送广播消息; 在整个广播行为中,有一个重要的概念叫频道channel,频道的类型有 公共频道public 私有频道private 存在频道presence 移动端订阅了公共频道...public,会直接提示成功;私有频道private和存在频道presence在进行订阅的过程中,会向服务器端发送权限验证,看是不是有权限可以订阅该频道;私有频道private和存在频道presence...-开头),则会发出权限检查请求;对应的后端需要定义私有频道和存在频道的权限; 频道权限定义 频道的权限定义是在routes/channels.php里;此处笔者为first-channel频道定义权限回调函数...(); Redis驱动 配置 .env文件修改或添加一行:BROADCAST_DRIVER=redis; 广播 原理是同样在后端部署一个Socket.IO服务器,Laravel框架会发布消息到Socket.IO

    1.5K50

    Laravel 6.11 版本发布,优化了 Redis 多频道广播逻辑

    Laravel 官方开发组本周发布了 Laravel 6.11.0 版本,新版本在 Eloquent 模型查询时新增 firstWhere 方法,优化了基于 Redis 的多频道广播,以及一些现有版本的问题修复...优化 Redis 多频道广播 在 Laravel 应用中,一次发送事件到多个频道很常见,目前,我们的做法是通过多个发布命令发送完全一样的负载数据到指定 Redis 服务器,这将导致不必要的数据传输,从而带来通信及性能损耗...所以,最新版本的 Laravel 优化了这个问题,在 RedisBroadcaster 中添加一段 Lua 脚本,允许一次广播数据到多个频道: 2、更新日志 接下来,我们来大致看一下此次版本更新的详细日志...:makeFaker() 中的未定义属性 修复 Str::afterLast() 方法 修复 PHP 7.3 插入浮点类型到 MySQL 数据库问题 修复通过自定义中间表属性名刷新模型问题 代码调整 在...Blade 模板中移除所有缩进 在 MailFake::assertNothingSent() 和 MailFake::assertNothingQueued() 中新增可邮寄名称到断言消息 在 assertDatabaseHas

    1.4K10

    基于 Redis 实现 Laravel 广播功能(上):广播事件分发和底层源码探究

    生态提供的广播组件和前端技术栈来搭建一个生产环境可用的、更加系统的实时消息系统。...,事件负荷数据通过属性形式设置,并且在 broadcastOn 方法中定义了事件消息将被推送到的频道,以及通过 broadcastQueue 属性指定了事件消息如果被推送到队列的话对应的队列名称。...接口,以及如果事件类中定义了 broadcastWhen 方法,条件是否为 true(没有定义的话默认返回为 true),这两个条件同时满足才会广播,对应的实现源码位于 shouldBroadcast...如果在 Websocket 服务器中通过 Redis 订阅了 test-channel 这个频道,就可以接收到这个消息,然后将其广播给所有建立连接的 Websocket 客户端了。...所以啊,广播事件的处理是 Laravel 框架事件监听和消息队列的集大成者,了解它的底层实现,也就等于搞懂了所有这几个组件的实现原理。

    3.5K20

    基于 Pusher 驱动的 Laravel 事件广播(下)

    说明:本部分主要基于三个示例来说明Pusher服务的使用。 基础 Channels:频道用来辨识程序内数据的场景或上下文,并与数据库中的数据有映射关系。...就像是听广播的频道一样,不同频道接收不同电台。 Event:如果频道是用来辨识数据的,那事件就是对该数据的操作。...new-notification' event $pusher->trigger('notifications', 'new-notification', $notifyText); } } 我的环境输入路由...在项目根目录: php artisan make:controller ActivityController 在ActivityController.php中添加: public $pusher, $user...好,现在自己与自己开始聊天,打开两个页面,作者的环境里路由为http://laravelpusher.app:8888/chat(这里输入你自己的路由就行): 总结:本部分主要以三个小示例来说明Laravel

    2.8K31

    【MQ03】发布订阅模式

    当有新的消息出现在队列中,就会像广播一样让所有订阅者都获得这条消息。 这种功能的应用场景是?假设我们有一个电商系统。当客户下单之后,是不是要马上通知商家、并且客户自己也会收到相应的订单确认信息。...; $channel->close(); $connection->close(); 不同的地方已经在注释中说明了。...这两段代码唯一的差别其实就是在回调函数中的 echo 内容不同。 好了,现在我们有了一个发布者和两个订阅者。接下来就可以开始测试了。...redis-cli 中也是有相应的命令行的,之前我们在 Redis 系统中都学过。...也就是说,一条消息数据,只对当时已经订阅的客户端会发送数据,就像广播一样,如果你现在打开了收音机,正在听某个频道,那么你就能听到这个频道里面正在播出的内容。

    56210

    利用PHPStorm如何开发Laravel应用详解

    前言 相信有很多PHP程序员使用 [laravel] 创建他们的应用程序。[laravel] 是一个免费开源的PHP web应用程序框架。...blade 是Laravel的模板语言, 对艺术家友好,这个Laravel程序员的命令行工具, 可以在PhpStorm中工作....[译注]自助方式 因为我们是在项目中使用, 所以我们在项目中添加这个功能, 在 composer.json 中添加 require-dev 分支 laravel 4. , 这里的版本应该填写 1...."b/【关于环境方面,我觉得DOCKER是非常合适和快速部署的一个方式】/arryvdh/laravel-ide-helper": "2.*" // ... }, 然后使用命令 composer update...,这个插件还可以给项目中的model添加phpDoc,直接显示字段名,便于阅读,用法 php artisan ide-helper:models User 需要修改composer.json,在 require-dev

    1.8K20

    JSON Web Token(JWT)教程:一个基于Laravel和AngularJS的例子

    在我们可以看到使用token认证的所有优点之前,我们必须看看过去认证的方式。 基于服务器的身份验证 通常为Session和cookie。 ?...) 在本教程中,我将演示如何使用两个流行的Web技术实现JSON Web Token的基本身份验证:Laravel 5用于后端代码,AngularJS用于前端单页面应用程序(SPA)示例。...有关此过程的任何问题,请参阅官方Laravel文档。 在我们创建了基本的Laravel 5应用程序之后,我们需要设置我们的Homestead.yaml,它将为我们的本地环境配置文件夹映射和域配置。...它将被放置在我们的config/jwt.php文件中。然而,在生产环境中,我们不想在配置文件中使用我们的密码或API密钥。...在生产环境中,当然,我们会缩小并组合所有的脚本文件(js文件)和样式表(css文件),以提高性能。 我已经使用Bootstrap创建了一个导航栏,它将根据用户的登录状态更改相应链接的可见性。

    30.6K10

    Redis 6.0 新特性篇:Client Side Cache 是嘛玩意?

    查询Redis 使用客户端缓存,应用程序将获取的热门的数据存储在应用程序中,无需再次通过网络访问 Redis。 应该缓存什么 我们不应该缓存不断变化的键。 我们不该缓存很少请求的键。...在这个模式下,服务端会给客户端广播所有 key 的失效情况,如果 key 被频繁修改,服务端会发送大量的失效广播消息,这就会消耗大量的网络带宽资源。...所以,在实际应用中,我们设置让客户端注册只跟踪指定前缀的 key,当注册跟踪的 key 前缀匹配被修改,服务端就会把失效消息广播给所有关注这个 key前缀的客户端。...我们在实际应用时,会给同一业务下的 key 设置相同的业务名前缀,所以,我们就可以非常方便地使用广播模式。...在重定向模式下,想要获得失效消息通知的客户端,就需要执行订阅命令 SUBSCRIBE,专门订阅用于发送失效消息的频道 _redis_:invalidate。

    67530

    Redis 6.0 新特性篇:Client Side Cache 是嘛玩意?

    查询Redis 使用客户端缓存,应用程序将获取的热门的数据存储在应用程序中,无需再次通过网络访问 Redis。 应该缓存什么 我们不应该缓存不断变化的键。 我们不该缓存很少请求的键。...在这个模式下,服务端会给客户端广播所有 key 的失效情况,如果 key 被频繁修改,服务端会发送大量的失效广播消息,这就会消耗大量的网络带宽资源。...所以,在实际应用中,我们设置让客户端注册只跟踪指定前缀的 key,当注册跟踪的 key 前缀匹配被修改,服务端就会把失效消息广播给所有关注这个 key前缀的客户端。...我们在实际应用时,会给同一业务下的 key 设置相同的业务名前缀,所以,我们就可以非常方便地使用广播模式。...在重定向模式下,想要获得失效消息通知的客户端,就需要执行订阅命令 SUBSCRIBE,专门订阅用于发送失效消息的频道 _redis_:invalidate。

    98130
    领券