Laravel+socket.io实现websocket_优一品
优一品
登录
注册
Toggle navigation
优一品
首页
二维码生成
Base64编/解码
Unicode/中文互转
时间转换
图片转base64编码
生成字符串/密钥
更多工具
正则匹配
提取微信文章图片
urlencode
html转义字符
热门文章
MySQL for update应用
如何在Linux上增加swap空间
Linux环境实现git多用户管理
MySQL大数据导出导入注意事项
MySQL分表及分区技术
nginx负载均衡实现
Nginx实现负载均衡-概念部分
MySQL主从库实现
Laravel+socket.io实现websocket
使用Supervisor守护Laravel Queue进程
首页
开发技术
Laravel+socket.io实现websocket
Laravel+socket.io实现websocket
2020-01-11 17:07:48
websocket 相信很多人都知道，但是由于目前参与的公司项目用的不多，所以也就落下了。现在来补补课,本文主要是基于Laravel的事件广播、redis的订阅功能、nodejs/socket.io实现websocket的。1、给Laravel安装predis;composer require pusher/pusher-php-server(由于此次使用的是redis，可以不安装)composer require predis/predis 2、查看config/database.php：'redis' => [ 'cluster' => false, 'default' => [ 'host' => env('REDIS_HOST', 'localhost'), 'password' => env('REDIS_PASSWORD', null), 'port' => env('REDIS_PORT', 6379), 'database' => 0, ], ]我们需要将redis的相关参数写到.env文件3、新建事件及监听器事件代码如下（记得要实现ShouldBroadcast接口哦）：<?phpnamespace App\Events;use App\Events\Event;use Illuminate\Queue\SerializesModels;use Illuminate\Contracts\Broadcasting\ShouldBroadcast;class WechatLoginedEvent extends Event implements ShouldBroadcast{ use SerializesModels; public $token; protected $channel; /** * Create a new event instance. * * @param string $token * @param string $channel * @return void */ public function __construct($token, $channel) { $this->token = $token; $this->channel = $channel; } /** * Get the channels the event should be broadcast on. * * @return array */ public function broadcastOn() { return [$this->channel]; } /** * Get the name the event should be broadcast on. * * @return string */ public function broadcastAs() { return 'wechat.login'; } /* public function onQueue() { return 'wechat_login_broadcast'; } */}监听器代码如下（这里实现了ShouldQueue，意味着将会使用到Laravel的队列）：<?phpnamespace App\Listeners;use Illuminate\Http\Request;use Auth;use App\Events\WechatLoginedEvent;use Illuminate\Contracts\Queue\ShouldQueue;use Illuminate\Queue\InteractsWithQueue;class WechatLoginEventListener implements ShouldQueue{ use InteractsWithQueue; protected $request; /** * Create the event listener. * * @return void */ public function __construct(Request $request) { $this->request = $request; } /** * 创建日记 * @param $event */ public function login($event){ info("event -------- ".$event->token); //return false; } /** * Handle the event. * * @param $event * @return void */ public function subscribe($events) { $events->listen( WechatLoginedEvent::class, 'App\Listeners\WechatLoginEventListener@login' ); }}创建好事件及监听器之后，我们需要将EventServiceProvider注册事件订阅者：protected $subscribe = [ //事件订阅者 WechatLoginEventListener::class, ];4、查看config/broadcasting.php：'default' => env('BROADCAST_DRIVER', 'pusher'),默认的事件广播驱动是pusher,所以我们需要在.env文件增加BROADCAST_DRIVER=redis。至此，Laravel部分已经准备完毕，当然我们也可以先使用log的方式，然后执行看是否可以成功以确保前面的内容没有问题；5、新建node项目// server.jsvar app = require('http').createServer(handler);var io = require('socket.io')(app);var Redis = require('ioredis');var redis = new Redis({ port: 6379, // Redis port host: '127.0.0.1', // Redis host password:null, db: 0,});app.listen(6001, function () { console.log('Server is running!') ;});function handler(req, res) { res.writeHead(200); res.end('');}io.on('connection', function (socket) { socket.on('message', function (message) { console.log(message) }) socket.on('disconnect', function () { console.log('user disconnect') })});redis.psubscribe('*', function (err, count) {});redis.on('pmessage', function (subscrbed, channel, message) { console.log("redis msg"); console.log(message); message = JSON.parse(message); console.log(channel); var obj = { channel : channel, message:message }; io.emit("message",JSON.stringify(obj));});执行该服务：node server.js6、页面端主要代码如下：<script type="text/javascript" src="/js/socket.io.js"></script><script type="text/javascript">$(function(){var socket = io.connect('ws://localhost:6001'); socket.on('message', function (data) { console.log("server:"+data); alert("收到通知"); });});</script>7、由于我们实现ShouldQueue,所以还需要监听queue队列 php artisan queue:listen接下来就看执行效果了，在需要执行的地方插入代码：event(new WechatLoginedEvent("content", "channel_1"));这里有一个很酷炫的方式：php artisan tinker 进入tinker，接着执行event(new App\Events\WechatLoginedEvent("content", "channel_1"));
上一篇：使用Supervisor守护Laravel Queue进程
下一篇：MySQL主从库实现
相关文章
MySQL for update应用
如何在Linux上增加swap空间
Linux环境实现git多用户管理
MySQL大数据导出导入注意事项
MySQL分表及分区技术
nginx负载均衡实现
Nginx实现负载均衡-概念部分
MySQL主从库实现
使用Supervisor守护Laravel Queue进程
阿里云CentOS安装php环境（lnmp）
Copyright@2019-2020 闽ICP备17029101号-2
POWERED BY 夏日朝阳