Yii2结合Workerman的websocket示例详解

开发技术作者： 2024-08-19 10:55:01

这篇文章主要给大家介绍了关于Yii2结合Workerman的websocket的相关资料，文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值，需要的朋友们下面来一起学习学习吧

前言

本文主要给大家介绍了关于Yii2结合Workerman的websocket的相关内容，两者都是好东西，我就想着能不能结合起来，这样Yii2出现瓶颈的时候有些业务就可以平滑地迁移到Workerman中。下面话不多说了，来随着小编来一起看看详细的介绍吧

步骤如下

1、安装workerman

2、启动workerman

创建commands/WorkermanWebSocketController.PHP文件

创建actionIndex()函数，用来启动，代码如下

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(); } }

添加初始化模块

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";
};
}

添加启动模块

initWorker(); // 重置参数以匹配Worker global $argv; $argv[0] = $argv[1]; $argv[1] = 'start'; if ($this->daemon) { $argv[2] = '-d'; }

// Run worker
Worker::runAll();
}

添加停止模块

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();
}

添加重载模块

initWorker(); // 重置参数以匹配Worker global $argv; $argv[0] = $argv[1]; $argv[1] = 'reload'; if ($this->gracefully) { $argv[2] = '-g'; }

// Run worker
Worker::runAll();
}

添加状态模块

initWorker(); // 重置参数以匹配Worker global $argv; $argv[0] = $argv[1]; $argv[1] = 'status'; if ($this->daemon) { $argv[2] = '-d'; }

// Run worker
Worker::runAll();
}

添加链接数模块

initWorker(); // 重置参数以匹配Worker global $argv; $argv[0] = $argv[1]; $argv[1] = 'connections';

// Run worker
Worker::runAll();
}

3、前端调用

4、config参数配置

修改console.PHP并添加如下代码

[ 'workerman-web-socket' => [ 'class' => 'app\commands\WorkermanWebSocketController','config' => [ 'ip' => '127.0.0.1','port' => '2346','daemonize' => true,],

5、Nginx配置

为什么会用 Nginx，我们正常部署上线是不可能直接使用ip的，这个户存在安全隐患，最好是绑定一个域名

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

然后将第3步的代码加入自己做的视图中，如果没有问题的话，websocket启动后就能正常通讯了。

6、启动workerman websocket

如果没有问题的话会得到类似如下的结果

7、其他

commands/WorkermanWebSocketController.PHP 完整代码如下

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支持的其他命令

重启

重载

状态

连接数

我这里暂时连接的，所以没有连接的信息

停止