溫馨提示×
您好，登錄后才能下訂單哦！
點擊 登錄注冊 即表示同意《億速云用戶服務條款》
您好，登錄后才能下訂單哦！
websocket如何在Yii2中使用？很多新手對此不是很清楚，為了幫助大家解決這個難題，下面小編將為大家詳細講解，有這方面需求的人可以來學習下，希望你能有所收獲。
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
看完上述內容是否對您有幫助呢？如果還想對相關知識有進一步的了解或閱讀更多相關文章，請關注億速云行業資訊頻道，感謝您對億速云的支持。
免責聲明：本站發布的內容（圖片、視頻和文字）以原創、轉載和分享為主，文章觀點不代表本網站立場，如果涉及侵權請聯系站長郵箱：is@yisu.com進行舉報，并提供相關證據，一經查實，將立刻刪除涉嫌侵權內容。
