Yii2结合Workerman的websocket示例详解

02080

前言

关于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 connectionn";
   };
   // 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 closedn";
   };
}

添加启动模块

/**   * 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' => 'appcommandsWorkermanWebSocketController',   '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 完整代码如下

<?php
/**   * WorkmanWebSocket 服务相关   */
namespace appcommands;
use WorkermanWorker;
use yiiconsoleController;
use yiihelpersConsole;
/**   *   * 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 connectionn";    };      // 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 closedn";    };   }     /**    * 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 -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:WorkermanEventsSwoole  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

总结
以上就是这篇文章的全部内容了，希望本文的内容对大家的学习或者工作具有一定的参考学习价值。

© 版权声明
本文刊载的所有内容，包括文字、图片、音频、视频、软件、程序、以及网页版式设计等部门来源于互联网，版权均归原作者所有！本网站提供的内容服务于个人学习、研究或欣赏，以及其他非商业性或非盈利性用途，但同时应遵守著作权法及其他相关法律的规定，不得侵犯本网站及相关权利人的合法权利。
联系信息：邮箱aoxolcom@163.com或见网站底部。
THE END
PHP
# 服务器# 函数# PHP# go# socket
喜欢就支持一下吧
点赞0 分享
南宫世家的头像-华尔子博
官宣文案大合集，超级温柔干净甜甜的句子-华尔子博
官宣文案大合集，超级温柔干净甜甜的句子
官宣文案大合集，超级温柔干净甜甜的句子
3年前 1243
怼人的话不带脏字超狠短句，一句话能气死人的文案语录-华尔子博
怼人的话不带脏字超狠短句，一句话能气死人的文案语录
怼人的话不带脏字超狠短句，一句话能气死人的文案语录
3年前 1105
超强、超详细Redis数据库入门教程-华尔子博
超强、超详细Redis数据库入门教程
超强、超详细Redis数据库入门教程
3年前 771
iphone的safari浏览器中实现全屏浏览的方法-华尔子博
iphone的safari浏览器中实现全屏浏览的方法
iphone的safari浏览器中实现全屏浏览的方法
3年前 697
真心话比较狠的问题，真心话劲爆污的你敢说吗?-华尔子博
真心话比较狠的问题，真心话劲爆污的你敢说吗?
真心话比较狠的问题，真心话劲爆污的你敢说吗?
3年前 607
php使用QueryList轻松采集js动态渲染页面方法-华尔子博
php使用QueryList轻松采集js动态渲染页面方法
php使用QueryList轻松采集js动态渲染页面方法
3年前 475
相关推荐
评论 抢沙发

请登录后发表评论

默认头像
默认文件系统默认数据库鳄鱼的故事高防服务器高防CDN高负载的WEB应用高级的虚拟化管理高级数据压缩高级ETL工具高效编写Python代码高效的HTTP服务高效PHP开发工具高性能的缓存高性能的CGI协议高性能WEB服务器高并发Web应用驱动程序更新香饽饽首选DNS服务器面向对象程序设计非静态成员函数