Yii2结合Workerman的websocket示例详解
作者:Gowhich 时间:2023-11-17 04:48:40
前言
本文主要给大家介绍了关于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、前端调用
<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' => '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 -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 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支持的其他命令
重启
$ ./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:\Workerman\Events\Swoole
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
来源:https://www.gowhich.com/blog/921
标签:yii2,workerman,websocket
![](/images/zang.png)
![](/images/jiucuo.png)
猜你喜欢
ASP中转换unicode编码为gb2312函数
2007-10-22 17:46:00
Python爬虫HTPP请求方法有哪些
2023-07-25 16:55:06
按钮表状态还是表动作?
2009-03-23 18:21:00
![](https://img.aspxhome.com/file/UploadPic/20093/23/1-300x272-42s.jpg)
js中prototype用法详细介绍
2024-05-25 15:18:26
python中gevent库的用法详情
2022-10-17 11:14:43
![](https://img.aspxhome.com/file/2023/6/111956_0s.png)
SQL Server下几个危险的扩展存储过程
2024-01-18 06:49:25
Javascript中级语法快速入手
2024-04-26 17:11:02
php打包压缩文件之ZipArchive方法用法分析
2024-05-11 09:46:05
CentOS6.4上使用yum安装mysql
2024-01-18 10:07:09
![](https://img.aspxhome.com/file/2023/8/115278_0s.png)
Centos部署django服务nginx+uwsgi的方法
2022-03-18 07:47:26
在Django model中设置多个字段联合唯一约束的实例
2021-02-09 22:04:59
Python实现TCP协议下的端口映射功能的脚本程序示例
2021-07-26 13:59:01
![](https://img.aspxhome.com/file/2023/2/93712_0s.png)
vue3 reactive函数用法实战教程
2023-07-02 16:37:36
![](https://img.aspxhome.com/file/2023/1/139741_0s.png)
MySQL 字符串模式匹配 扩展正则表达式模式匹配
2024-01-20 14:47:41
js中string转int把String类型转化成int类型
2024-05-03 15:30:11
Python网络请求模块urllib与requests使用介绍
2021-07-21 12:23:38
QML使用Python的函数过程解析
2021-12-10 19:20:31
js实现的牛顿摆效果
2024-04-29 13:25:45
MYSQL Binlog恢复误删数据库详解
2024-01-27 06:17:30
![](https://img.aspxhome.com/file/2023/5/129945_0s.png)
python去重,一个由dict组成的list的去重示例
2023-09-26 03:54:44