$ ./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 完整代码如下
<?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支持的其他命令
重启