前言
本文主要給大家介紹了關于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 -dWorkerman[workerman-web-socket] start in DAEMON mode----------------------- WORKERMAN -----------------------------Workerman version:3.5.13 PHP version:7.1.16------------------------ WORKERS -------------------------------user worker listen processes statusdurban none websocket://127.0.0.1:2346 4 [OK] ----------------------------------------------------------------Input "php workerman-web-socket stop" to stop. Start success.
7、其他
commands/WorkermanWebSocketController.php 完整代碼如下
<?php/** * WorkmanWebSocket 服務相關 */namespace app/commands;use Workerman/Worker;use yii/console/Controller;use yii/helpers/Console;/** * * WorkermanWebSocket * * @author durban.zhang <durban.zhang@gmail.com> */class WorkermanWebSocketController extends Controller{ public $send; public $daemon; public $gracefully; // 這里不需要設置，會讀取配置文件中的配置 public $config = []; private $ip = '127.0.0.1'; private $port = '2346'; public function options($actionID) { return ['send', 'daemon', 'gracefully']; } public function optionAliases() { return [ 's' => 'send', 'd' => 'daemon', 'g' => 'gracefully', ]; } 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('dddd 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 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 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 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(); }}workerman websocket支持的其他命令
重啟
$ ./yii workerman-web-socket -s restart -dWorkerman[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 statusdurban 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 -gWorkerman[workerman-web-socket] status ----------------------------------------------GLOBAL STATUS----------------------------------------------------Workerman version:3.5.13 PHP version:7.1.16start time:2018-09-10 11:22:15 run 0 days 0 hours load average: 1.79, 2, 2 event-loop:/Workerman/Events/Swoole1 workers 4 processesworker_name exit_status exit_countnone 0 12----------------------------------------------PROCESS STATUS---------------------------------------------------pid memory listening worker_name connections send_fail timers total_request qps status8283 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 connectionsWorkerman[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
總結
以上就是這篇文章的全部內容了，希望本文的內容對大家的學習或者工作具有一定的參考學習價值，如果有疑問大家可以留言交流，謝謝大家對VeVb武林網的支持。
新聞熱點
疑難解答
圖片精選
