前言
本文主要给大家介绍了关于Yii2结合Workerman的websocket的相关内容，两者都是好东西，我就想着能不能结合起来，这样Yii2出现瓶颈的时候有些业务就可以平滑地迁移到Workerman中。下面话不多说了，来随着小编来一起看看详细的介绍吧
步骤如下 1、安装workerman
composer require workerman/workerman 复制代码 2、启动workerman
创建commands/WorkermanWebSocketController.php文件
创建actionIndex()函数，用来启动，代码如下
public function actionIndex() { if ('start' == $this->send) { try { $this->start($this->daemon); } catch (\Exception $e) { $this->stderr($e->getMessage() . "\n", Console::FG_RED); } } else if ('stop' == $this->send) { $this->stop(); } else if ('restart' == $this->send) { $this->restart(); } else if ('reload' == $this->send) { $this->reload(); } else if ('status' == $this->send) { $this->status(); } else if ('connections' == $this->send) { $this->connections(); } } 复制代码 添加初始化模块
public function initWorker() { $ip = isset($this->config['ip']) ? $this->config['ip'] : $this->ip; $port = isset($this->config['port']) ? $this->config['port'] : $this->port; $wsWorker = new Worker("websocket://{$ip}:{$port}"); // 4 processes $wsWorker->count = 4; // Emitted when new connection come $wsWorker->onConnect = function ($connection) { echo "New connection\n"; }; // Emitted when data received $wsWorker->onMessage = function ($connection, $data) { // Send hello $data $connection->send('hello ' . $data); }; // Emitted when connection closed $wsWorker->onClose = function ($connection) { echo "Connection closed\n"; }; } 复制代码 添加启动模块
/** * workman websocket start */ public function start() { $this->initWorker(); // 重置参数以匹配Worker global $argv; $argv[0] = $argv[1]; $argv[1] = 'start'; if ($this->daemon) { $argv[2] = '-d'; } // Run worker Worker::runAll(); } 复制代码 添加停止模块
/** * workman websocket stop */ public function stop() { $this->initWorker(); // 重置参数以匹配Worker global $argv; $argv[0] = $argv[1]; $argv[1] = 'stop'; if ($this->gracefully) { $argv[2] = '-g'; } // Run worker Worker::runAll(); } 复制代码 添加重启模块
/** * workman websocket restart */ public function restart() { $this->initWorker(); // 重置参数以匹配Worker global $argv; $argv[0] = $argv[1]; $argv[1] = 'restart'; if ($this->daemon) { $argv[2] = '-d'; } if ($this->gracefully) { $argv[2] = '-g'; } // Run worker Worker::runAll(); } 复制代码 添加重载模块
/** * workman websocket reload */ public function reload() { $this->initWorker(); // 重置参数以匹配Worker global $argv; $argv[0] = $argv[1]; $argv[1] = 'reload'; if ($this->gracefully) { $argv[2] = '-g'; } // Run worker Worker::runAll(); } 复制代码 添加状态模块
/** * workman websocket status */ public function status() { $this->initWorker(); // 重置参数以匹配Worker global $argv; $argv[0] = $argv[1]; $argv[1] = 'status'; if ($this->daemon) { $argv[2] = '-d'; } // Run worker Worker::runAll(); } 复制代码 添加链接数模块
/** * workman websocket connections */ public function connections() { $this->initWorker(); // 重置参数以匹配Worker global $argv; $argv[0] = $argv[1]; $argv[1] = 'connections'; // Run worker Worker::runAll(); } 复制代码 3、前端调用
<script> // Create WebSocket connection. const ws = new WebSocket('ws://{{ app.request.hostName }}:2347/'); // 这里是获取的网站的域名，测试的时候可以改为自己的本地的ip地址 // Connection opened ws.addEventListener('open', function (event) { ws.send('Hello Server!'); }); // Listen for messages ws.addEventListener('message', function (event) { console.log('Message from server ', event.data); }); setTimeout(function() { ws.send('ssssss'); }, 10000); </script> 复制代码 4、config参数配置
修改console.php并添加如下代码
'controllerMap' => [ 'workerman-web-socket' => [ 'class' => 'app\commands\WorkermanWebSocketController', 'config' => [ 'ip' => '127.0.0.1', 'port' => '2346', 'daemonize' => true, ], ], ], 复制代码 5、nginx配置
为什么会用 nginx， 我们正常部署上线是不可能直接使用ip的，这个户存在安全隐患，最好是绑定一个域名
server { charset utf-8; client_max_body_size 128M; listen 2347; server_name www.gowhich.com; # 这里改为自己的域名 access_log /xxx.workerman.access.log; # 换成自己服务器的nginx日志路径 error_log /xxx.workerman.error.log; # 换成自己服务器的nginx日志路径 location / { proxy_pass http://127.0.0.1:2346; # 代理2346 也可以根据项目配置为自己的端口 proxy_set_header X-Real-IP $remote_addr; proxy_set_header Host $host; proxy_set_header X-Forwarded-For $proxy_add_x_forwarded_for; proxy_http_version 1.1; proxy_set_header Upgrade $http_upgrade; proxy_set_header Connection "upgrade"; } } 复制代码 重新nginx
nginx -s relad 或者 sudo nginx -s reload 复制代码 然后将第3步的代码加入自己做的视图中，如果没有问题的话，websocket启动后就能正常通讯了。
6、启动workerman websocket
// 启动 ./yii workerman-web-socket -s start -d 复制代码 如果没有问题的话会得到类似如下的结果
$ ./yii workerman-web-socket -s start -d Workerman[workerman-web-socket] start in DAEMON mode ----------------------- WORKERMAN ----------------------------- Workerman version:3.5.13 PHP version:7.1.16 ------------------------ WORKERS ------------------------------- user worker listen processes status durban none websocket://127.0.0.1:2346 4 [OK] ---------------------------------------------------------------- Input "php workerman-web-socket stop" to stop. Start success. 复制代码 7、其他
commands/WorkermanWebSocketController.php 完整代码如下
workerman websocket支持的其他命令
重启
$ ./yii workerman-web-socket -s restart -d Workerman[workerman-web-socket] restart Workerman[workerman-web-socket] is stopping ... Workerman[workerman-web-socket] stop success ----------------------- WORKERMAN ----------------------------- Workerman version:3.5.13 PHP version:7.1.16 ------------------------ WORKERS ------------------------------- user worker listen processes status durban none websocket://127.0.0.1:2346 4 [OK] ---------------------------------------------------------------- Input "php workerman-web-socket stop" to stop. Start success. 复制代码 重载
$ ./yii workerman-web-socket -s reload Workerman[workerman-web-socket] reload 复制代码 状态
$ ./yii workerman-web-socket -s status -g Workerman[workerman-web-socket] status ----------------------------------------------GLOBAL STATUS---------------------------------------------------- Workerman version:3.5.13 PHP version:7.1.16 start time:2018-09-10 11:22:15 run 0 days 0 hours load average: 1.79, 2, 2 event-loop:\Workerman\Events\Swoole 1 workers 4 processes worker_name exit_status exit_count none 0 12 ----------------------------------------------PROCESS STATUS--------------------------------------------------- pid memory listening worker_name connections send_fail timers total_request qps status 8283 4M websocket://127.0.0.1:2346 none 0 0 0 0 0 [idle] 8284 4M websocket://127.0.0.1:2346 none 0 0 0 0 0 [idle] 8285 4M websocket://127.0.0.1:2346 none 0 0 0 0 0 [idle] 8286 4M websocket://127.0.0.1:2346 none 0 0 0 0 0 [idle] ----------------------------------------------PROCESS STATUS--------------------------------------------------- Summary 16M - - 0 0 0 0 0 [Summary] 复制代码 连接数
./yii workerman-web-socket -s connections Workerman[workerman-web-socket] connections --------------------------------------------------------------------- WORKERMAN CONNECTION STATUS -------------------------------------------------------------------------------- PID Worker CID Trans Protocol ipv4 ipv6 Recv-Q Send-Q Bytes-R Bytes-W Status Local Address Foreign Address 复制代码 我这里暂时连接的，所以没有连接的信息
停止
$ ./yii workerman-web-socket -s stop Workerman[workerman-web-socket] stop Workerman[workerman-web-socket] is stopping ... Workerman[workerman-web-socket] stop success 复制代码 总结
以上就是这篇文章的全部内容了，希望本文的内容对大家的学习或者工作具有一定的参考学习价值，如果有疑问大家可以留言交流，谢谢大家对晓枫资讯的支持。
免责声明：如果侵犯了您的权益，请联系站长，我们会及时删除侵权内容，谢谢合作！
发表于 2023-2-13 00:32:57