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

};

}

添加启动模块

/**

public function start()

{

$this->initWorker();

// 重置参数以匹配Worke

global $argv;

$argv[0] = $argv[1];

$argv[1] = 'start';

if ($this->daemon) {

$argv[2] = '-d';

}

// Run worke

Worker::runAll();

}

添加停止模块

/**

public function stop()

{

$this->initWorker();

// 重置参数以匹配Worke

global $argv;

$argv[0] = $argv[1];

$argv[1] = 'stop';

if ($this->gracefully) {

$argv[2] = '-g';

}

// Run worke

Worker::runAll();

}

添加重启模块

/**

public function restart()

{

$this->initWorker();

// 重置参数以匹配Worke

global $argv;

$argv[0] = $argv[1];

$argv[1] = 'restart';

if ($this->daemon) {

$argv[2] = '-d';

}

if ($this->gracefully) {

$argv[2] = '-g';

}

// Run worke

Worker::runAll();

}

添加重载模块

/**

public function reload()

{

$this->initWorker();

// 重置参数以匹配Worke

global $argv;

$argv[0] = $argv[1];

$argv[1] = 'reload';

if ($this->gracefully) {

$argv[2] = '-g';

}

// Run worke

Worker::runAll();

}

添加状态模块

/**

public function status()

{

$this->initWorker();

// 重置参数以匹配Worke

global $argv;

$argv[0] = $argv[1];

$argv[1] = 'status';

if ($this->daemon) {

$argv[2] = '-d';

}

// Run worke

Worker::runAll();

}

添加链接数模块

/**

public function connections()

{

$this->initWorker();

// 重置参数以匹配Worke

global $argv;

$argv[0] = $argv[1];

$argv[1] = 'connections';

// Run worke

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

: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

Input "php workerman-web-socket stop" to stop. Start success.

7、其他

commands/WorkermanWebSocketController.php 完整代码如下

<?php

/**

namespace appcommands;

use WorkermanWorker;

use yiiconsoleController;

use yiihelpersConsole;

/**

*

class WorkermanWebSocketController extends Controlle

{

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-&gt;start($this->daemon);

} catch (Exception $e) {

$this-&gt;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-&gt;config['ip'] : $this->ip;

$port = isset($this->config['port']) ? $this-&gt;config['port'] : $this->port;

$wsWorker = new Worker("websocket://{$ip}:{$port}");

// 4 processes

$wsWorker->count = 4;

// Emitted when new connection come

$wsWorker-&gt;onConnect = function ($connection) {

echo "New connectionn";

};

// Emitted when data received

$wsWorker-&gt;onMessage = function ($connection, $data) {

// Send hello $data

$connection-&gt;send('dddd hello ' . $data);

};

// Emitted when connection closed

$wsWorker-&gt;onClose = function ($connection) {

echo "Connection closedn";

};

}

/**

public function start()

{

$this->initWorker();

// 重置参数以匹配Worke

global $argv;

$argv[0] = $argv[1];

$argv[1] = 'start';

if ($this->daemon) {

$argv[2] = '-d';

}

// Run worke

Worker::runAll();

}

/**

public function restart()

{

$this->initWorker();

// 重置参数以匹配Worke

global $argv;

$argv[0] = $argv[1];

$argv[1] = 'restart';

if ($this->daemon) {

$argv[2] = '-d';

}

if ($this->gracefully) {

$argv[2] = '-g';

}

// Run worke

Worker::runAll();

}

/**

public function stop()

{

$this->initWorker();

// 重置参数以匹配Worke

global $argv;

$argv[0] = $argv[1];

$argv[1] = 'stop';

if ($this->gracefully) {

$argv[2] = '-g';

}

// Run worke

Worker::runAll();

}

/**

public function reload()

{

$this->initWorker();

// 重置参数以匹配Worke

global $argv;

$argv[0] = $argv[1];

$argv[1] = 'reload';

if ($this->gracefully) {

$argv[2] = '-g';

}

// Run worke

Worker::runAll();

}

/**

public function status()

{

$this->initWorker();

// 重置参数以匹配Worke

global $argv;

$argv[0] = $argv[1];

$argv[1] = 'status';

if ($this->daemon) {

$argv[2] = '-d';

}

// Run worke

Worker::runAll();

}

/**

public function connections()

{

$this->initWorker();

// 重置参数以匹配Worke

global $argv;

$argv[0] = $argv[1];

$argv[1] = 'connections';

// Run worke

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

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

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