Laravel中使⽤swoole项⽬实战开发案例⼀（建⽴swoole和前
端通信）life
1 开发需要环境
⼯欲善其事，必先利其器。在正式开发之前我们检查好需要安装的拓展，不要开发中发现这些问题，打断思路影响我们的开发效率。
安装 swoole 拓展包
安装 redis 拓展包
安装 laravel5.5 版本以上
如果你还不会⽤swoole就out了
我的官⽅。获取更多的swoole学习资料以及视频源码笔记。
2 Laravel ⽣成命令⾏
1. php artisan make:command SwooleDemo
class SwooleDemo extends Command
{
protected $signature = 'swoole:demo';
protected $description = '这是关于swoole的⼀个测试demo';
public function __construct()
{
parent::__construct();
}
public function handle()
{
$this->line("hello world");
}
}
我们分别运⾏ php artisan 指令和 php artisan swoole:demo 会看到关于这个命令的说明，和输出 hello world。()
3 命令⾏逻辑代码
编写⼀个最基础的 swoole 命令⾏逻辑代码
<?php
namespace App\Console\Commands;
use Illuminate\Console\Command;
use Illuminate\Support\Facades\Redis;
class SwooleDemo extends Command
{
// 命令名称
protected $signature = 'swoole:demo';
// 命令说明
protected $description = '这是关于swoole websocket的⼀个测试demo';
// swoole websocket服务
private static $server = null;
public function __construct()前端websocket怎么用
{
parent::__construct();
}
// ⼊⼝
public function handle()
{
$this->redis = Redis::connection('websocket');
$server = self::getWebSocketServer();
$server->on('open',[$this,'onOpen']);
$server->on('message', [$this, 'onMessage']);
$server->on('close', [$this, 'onClose']);
$server->on('request', [$this, 'onRequest']);
$this->line("swoole服务启动成功 ...");
$server->start();
}
/
/ 获取服务
public static function getWebSocketServer()
{
if (!(self::$server instanceof \swoole_websocket_server)) {
self::setWebSocketServer();
}
return self::$server;
}
// 服务处始设置
protected static  function setWebSocketServer():void
{
self::$server  = new \swoole_websocket_server("0.0.0.0", 9502);        self::$server->set([
'worker_num' => 1,
'heartbeat_check_interval' => 60,    // 60秒检测⼀次
'heartbeat_idle_time' => 121,        // 121秒没活动的
]);
}
// 打开swoole websocket服务回调代码
public function onOpen($server, $request)
{
if ($this->checkAccess($server, $request)) {\
self::$server->push($request->fd,"打开swoole服务成功！");\        }
}
// 给swoole websocket 发送消息回调代码
public function onMessage($server, $frame)
{
}
// http请求swoole websocket 回调代码
public function onRequest($request,$response)
{
}
// websocket 关闭回调代码
public function onClose($serv,$fd)
{
$this->line("客户端 {$fd} 关闭");
}
// 校验客户端连接的合法性,⽆效的连接不允许连接
public function checkAccess($server, $request):bool
{
$bRes = true;
if (!isset($request->get) || !isset($request->get['token'])) {
self::$server->close($request->fd);
self::$server->close($request->fd);
$this->line("接⼝验证字段不全");
$bRes = false;
} else if ($request->get['token'] !== "123456") {
$this->line("接⼝验证错误");
$bRes = false;
}
return $bRes;
}
// 启动websocket服务
public function start()
{
self::$server->start();
}
}
编写 websoket js 代码
<!DOCTYPE html>
<html lang="en">
<head>
<meta charset="UTF-8">
<title>swoole测试</title>
<meta name=viewport content="width=device-width,initial-scale=1,maximum-scale=1,user-scalable=no"> </head>
<body>
<h1>这是⼀个测试</h1>
</body>
<script>
var ws;//websocket实例
var lockReconnect = false;//避免重复连接
var wsUrl = 'ws://{{$_SERVER["HTTP_HOST"]}}:9502?page=home&token=123456';
function initEventHandle() {
reconnect(wsUrl);
};
reconnect(wsUrl);
};
//⼼跳检测重置
};
//如果获取到消息，⼼跳检测重置
//拿到任何消息都说明当前连接是正常的
var data = JSON.parse(event.data);
}
}
createWebSocket(wsUrl);
/**
* 创建链接
* @param url
*/
function createWebSocket(url) {
try {
ws = new WebSocket(url);
initEventHandle();
} catch (e) {
reconnect(url);
}
}
}
function reconnect(url) {
if(lockReconnect) return;
lockReconnect = true;
//没连接上会⼀直重连，设置延迟避免请求过多
setTimeout(function () {
createWebSocket(url);
lockReconnect = false;
}, 2000);
}
//⼼跳检测
var heartCheck = {
timeout: 60000,//60秒
timeoutObj: null,
serverTimeoutObj: null,
reset: function(){
clearTimeout(this.timeoutObj);
clearTimeout(this.serverTimeoutObj);
return this;
},
start: function(){
var self = this;
this.timeoutObj = setTimeout(function(){
//这⾥发送⼀个⼼跳，后端收到后，返回⼀个⼼跳消息，
//onmessage拿到返回的⼼跳就说明连接正常
ws.send("heartbeat");
self.serverTimeoutObj = setTimeout(function(){//如果超过⼀定时间还没重置，说明后端主动断开了
ws.close();//如果onclose会执⾏reconnect，我们执⾏ws.close()就⾏了.如果直接执⾏reconnect 会触发onclose导致重连两次                }, self.timeout);
}, this.timeout);
},
header:function(url) {
window.location.href=url
}
}
</script>
</html>
访问前端页⾯ (显⽰如下说明前后端链接成功)
希望以上内容能帮助到⼤家，加⼊我的官⽅。获取更多的swoole学习资料以及视频源码笔记。

版权声明：本站内容均来自互联网，仅供演示用，请勿用于商业和其他非法用途。如果侵犯了您的权益请与我们联系QQ:729038198，我们将在24小时内删除。