Yii2结合Workerman的websocket示例详解

数据库  /  管理员 发布于 7年前   246

前言

本文主要给大家介绍了关于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、前端调用

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 完整代码如下

 */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

总结

以上就是这篇文章的全部内容了，希望本文的内容对大家的学习或者工作具有一定的参考学习价值，如果有疑问大家可以留言交流，谢谢大家的支持。

您可能感兴趣的文章:

• 从零开始学YII2框架（一）通过Composer安装Yii2框架
• 从零开始学YII2框架（五）快速生成代码工具 Gii 的使用
• 从零开始学YII2框架（六）高级应用程序模板
• 从零开始学YII2框架（二）通过 Composer 安装扩展插件
• 从零开始学YII2框架（三）扩展插件yii2-gird
• 从零开始学YII2框架（四）扩展插件yii2-kartikgii