前提是你服務器必須安裝了Swoole擴展，沒有安裝請移步官網：https://wiki.swoole.com/
在安裝這個擴展之后，確保php有安裝swoole擴展 php.ini 查找 extension=swoole.so，也可以去看 phpinfo 查看是否成功安裝swoole擴展
由於每次要命令行啟動swoole服務器，關閉shell窗口就關閉了swoole服務，我們自定義一條Artisan Command
生成swoole demo:
php artisan make:command SwooleDemo
<?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()
{
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);
$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() {
ws.onclose = function() {
reconnect(wsUrl);
};
ws.onerror = function() {
reconnect(wsUrl);
};
ws.onopen = function() {
//心跳檢測重置
heartCheck.reset().start();
};
ws.onmessage = function(event) {
//如果獲取到消息，心跳檢測重置
//拿到任何消息都說明當前連接是正常的
var data = JSON.parse(event.data);
heartCheck.reset().start();
}
}
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>
運行中出現的問題：
出錯原因是因為LNMP 禁用了部分存在危險的PHP函數，我們要修改php.ini配置文件：找到 disable_functions 一行 去除 putenv
重載php配置，再次啟動swoole-http服務就歐了