欢迎您访问程序员文章站本站旨在为大家提供分享程序员计算机编程知识!
您现在的位置是: 首页  >  IT编程

Yii2结合Workerman的websocket示例详解

程序员文章站 2023-02-16 11:27:56
前言 本文主要给大家介绍了关于yii2结合workerman的websocket的相关内容,两者都是好东西,我就想着能不能结合起来,这样yii2出现瓶颈的时候有些业务就可...

前言

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

总结

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