環境：centOS7.9、php8.3、thinkphp8.0\think-swoole4.1
我用的官方think-swoole插件
第一步：根據官方文檔，需要安裝此擴展插件
composer require topthink/think-swoole第二步：在根目錄下config文件夾下編輯swoole.php配置文件
'http'=> ['enable' => true,'host' => '0.0.0.0', // 任意ip都可以訪問http服務;'port' => 8080, // 寶塔和阿里云、騰訊云的安全組需要開放此端口;'worker_num' => swoole_cpu_num(),'options' => ['daemonize' => true], // 守護進程運行],'websocket' => ['enable' => true, // 默認為false, 一定要開啟'route' => false, // 最大的坑，在做測試時,一定要關閉,否則調試不出結果;'handler' => \think\swoole\websocket\Handler::class,'ping_interval' => 25000,'ping_timeout' => 60000,'room' => ['type' => 'table','table' => ['room_rows' => 8192,'room_size' => 2048,'client_rows' => 4096,'client_size' => 2048,],'redis' => ['host' => '127.0.0.1','port' => 6379,'max_active' => 3,'max_wait_time' => 5,],],'listen' => ['event' => \app\index\listener\WebsocketTest::class,//事件監聽'close' => 'app\index\listener\WsClose',//關閉事件],'subscribe' => [],],第三步：我的框架是多應用模式，我創建了index應用；
// WebsocketTest.php; 路徑: app\index\listener
namespace app\index\listener;
use think\Container;
use think\swoole\Websocket;class WebsocketTest
{public $websocket = null;public function __construct(Container $container){$this->websocket = $container->make(Websocket::class);}/*** 事件監聽處理* @param $event*/public function handle($event){echo '接收到事件,' . $event->type . '---' . $event->data;echo '--------';var_dump($event);$func = $event->type;$this->$func($event);}/*** 測試類型* @param $event*/public function test($event){$msg = json_encode($event->data,256);$this->websocket->emit('callback', $msg);}
}第四步：websocket關閉事件
namespace app\index\listener;class WsClose
{/*** 事件監聽處理** @return mixed*/public function handle($event){//echo '已經斷開了';}
}第五步：前端index.html
<html>
<head>
<title>websocket</title>
</head><body>
<h1>websocket功能</h1><input id="msg" type="text"/>
<button onclick="send()">發送</button><script>var ws = new WebSocket("ws://你的ip:8080");ws.onopen = function (){console.log("連接成功");var sendObj = {};sendObj.type = 'connect';sendObj.data = 'connect success';console.log('msg',JSON.stringify(sendObj));ws.send(JSON.stringify(sendObj));}ws.onclose = function () {console.log("連接失敗")}ws.onmessage = function (evt) {console.log("數據已接收",evt);}function send(){console.log('運行到這里了');var msg = document.getElementById('msg').value;var sendObj = {};sendObj.type = 'mtest';sendObj.data = msg;console.log('msg',JSON.stringify(sendObj));ws.send(JSON.stringify(sendObj));}
</script>
</body>
</html>
