thinkphp6通过workerman使用websocket

安装workerman依赖

composer require topthink/think-worker

composer require topthink/think-worker=1.0.*  # 指定兼容版本‌:ml-citation{ref="1,7" data="citationList"}

config配置
config/worker.php

<?php
return [// 扩展自身需要的配置'host'                  => '0.0.0.0', // 监听地址'port'                  => 2346, // 监听端口'root'                  => '', // WEB 根目录 默认会定位public目录'app_path'              => '', // 应用目录 守护进程模式必须设置（绝对路径）'file_monitor'          => false, // 是否开启PHP文件更改监控（调试模式下自动开启）'file_monitor_interval' => 2, // 文件监控检测时间间隔（秒）'file_monitor_path'     => [], // 文件监控目录 默认监控application和config目录// 支持workerman的所有配置参数'name'                  => 'thinkphp','count'                 => 4,'daemonize'             => false,'pidFile'               => '',
];

config/gateway_worker.php

<?php
// +----------------------------------------------------------------------
// | yylAdmin 前后分离，简单轻量，免费开源，开箱即用，极简后台管理系统
// +----------------------------------------------------------------------
// | Copyright https://gitee.com/skyselang All rights reserved
// +----------------------------------------------------------------------
// | Gitee: https://gitee.com/skyselang/yylAdmin
// +----------------------------------------------------------------------
// +----------------------------------------------------------------------
// | Workerman设置 仅对 php think worker:gateway 指令有效
// +----------------------------------------------------------------------
use GatewayWorker\Lib\Gateway;return [// 扩展自身需要的配置'protocol'              => 'websocket', // 协议 支持 tcp udp unix http websocket text'host'                  => '0.0.0.0', // 监听地址'port'                  => 2348, // 监听端口'socket'                => '', // 完整监听地址'context'               => [], // socket 上下文选项'register_deploy'       => env('WORKER.register_deploy', true), // 是否需要部署register'businessWorker_deploy' => true, // 是否需要部署businessWorker'gateway_deploy'        => true, // 是否需要部署gateway'worker_class'   => 'app\common\service\workman\Events', // 自定义Workerman服务类名 支持数组定义多个服务// Register配置'registerAddress'       => env('WORKER.registerAddress', '127.0.0.1:1236'),// Gateway配置'name'                  => 'thinkphp','count'                 => 5,'lanIp'                 => env('WORKER.lanIp', '127.0.0.1'),'startPort'             => 2000,'daemonize'             => false,'pingInterval'          => 30,'pingNotResponseLimit'  => 0,'pingData'              => '{"type":"ping"}',// BusinsessWorker配置'businessWorker'        => ['name'         => 'BusinessWorker','count'        => 10,'eventHandler' => 'app\common\service\workman\Events','registerAddress' => array_unique([env('WORKER.registerAddress1', '127.0.0.1:1236'),env('WORKER.registerAddress2', '127.0.0.1:1236')]),],];

config/worker_server.php

<?php
return [// 扩展自身需要的配置'protocol'       => 'websocket', // 协议 支持 tcp udp unix http websocket text'host'           => '0.0.0.0', // 监听地址'port'           => 2345, // 监听端口'socket'         => '', // 完整监听地址'context'        => [], // socket 上下文选项
//    'worker_class'   => 'app\common\service\workman\Worker', // 自定义Workerman服务类名 支持数组定义多个服务// 支持workerman的所有配置参数'name'           => 'thinkphp','count'          => 4,'daemonize'      => false,'pidFile'        => '',// 支持事件回调// onWorkerStart'onWorkerStart'  => function ($worker) {},// onWorkerReload'onWorkerReload' => function ($worker) {},// onConnect'onConnect'      => function ($connection) {$connection->send('onConnect success: uid = ' . json_encode($connection->uid));},// onMessage'onMessage'      => function ($connection, $data) {$connection->send('onMessage success data = ' . json_encode($data));},// onClose'onClose'        => function ($connection) {},// onError'onError'        => function ($connection, $code, $msg) {echo "error [ $code ] $msg\n";},
];

前端链接示例

const socket = new WebSocket('ws://127.0.0.1:2346');
socket.onopen = () => console.log('连接成功‌:ml-citation{ref="6" data="citationList"}');
socket.onmessage = e => console.log('收到:', e.data);
// 发送数据示例
socket.send(JSON.stringify({ type: 'chat', msg: 'Hello' }))‌:ml-citation{ref="6,8" data="citationList"};

启动服务

php think worker start -d  # 后台运行‌:ml-citation{ref="5,8" data="citationList"}

开启 php think worker:gateway
停止 php think worker:gateway stop

查看状态
php think worker:gateway status

也可以通过宝塔守护进程启动