一区二区三区在线-一区二区三区亚洲视频-一区二区三区亚洲-一区二区三区午夜-一区二区三区四区在线视频-一区二区三区四区在线免费观看

服務器之家：專注于服務器技術及軟件下載分享
分類導航

PHP教程|ASP.NET教程|Java教程|ASP教程|編程技術|正則表達式|C/C++|IOS|C#|Swift|Android|VB|R語言|JavaScript|易語言|vb.net|

服務器之家 - 編程語言 - PHP教程 - Yii2結合Workerman的websocket示例詳解

Yii2結合Workerman的websocket示例詳解

2019-09-07 15:46Gowhich PHP教程

這篇文章主要給大家介紹了關于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 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 <[email protected]>
 */

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

總結

以上就是這篇文章的全部內容了，希望本文的內容對大家的學習或者工作具有一定的參考學習價值，如果有疑問大家可以留言交流，謝謝大家對服務器之家的支持。

延伸 · 閱讀

精彩推薦
主站蜘蛛池模板： 91在线视频播放 | 舔大逼| 美女靠逼动漫 | 春光乍泄在线 | 女bbbxxx毛片视频 | 晓雪老师我要进你里面好爽 | 俄罗斯大白屁股 | 国产在线99 | 男人在线影院 | 亚洲老头与老太hd | 国产喂奶300部 | 日本嫩小xxxxhd| 亚洲高清在线精品一区 | 国产精品久久久久久久久免费观看 | 国产91精品在线观看 | 亚洲 制服 欧美 中文字幕 | 久久精品国产欧美日韩99热 | 99热精品在线播放 | 欧美一级乱妇老太婆特黄 | 欧美va在线观看 | 成人精品第一区二区三区 | 日本黄色高清视频网站 | 舔比小说 | 精品国产成人a区在线观看 精品国产91久久久久久久 | 无颜之月5集全免费看无删除 | www亚洲视频| 亚洲码在线观看 | 99热精品69堂国产 | 高清毛片aaaaaaaaa片 | 男女做性视频 | 日本公与妇中文在线 | 免费观看www视频 | 日韩在线第一区 | 日韩欧美高清 | 日韩伦理在线看 | 亚洲日本久久一区二区va | 91制片厂制作传媒破解版免费 | 日本道色综合久久影院 | 亚洲精品久久中文字幕 | 视频网站入口在线看 | 日韩永久在线观看免费视频 |