Yii2结合Workerman的websocket示例详解

前言

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

总结

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