第Yii2結(jié)合Workerman的websocket示例詳解前言

本文主要給大家介紹了關(guān)于Yii2結(jié)合Workerman的websocket的相關(guān)內(nèi)容，兩者都是好東西，我就想著能不能結(jié)合起來，這樣Yii2出現(xiàn)瓶頸的時(shí)候有些業(yè)務(wù)就可以平滑地遷移到Workerman中。下面話不多說了，來隨著小編來一起看看詳細(xì)的介紹吧

步驟如下

1、安裝workerman

composerrequireworkerman/workerman

2、啟動(dòng)workerman

創(chuàng)建commands/WorkermanWebSocketController.php文件

創(chuàng)建actionIndex()函數(shù)，用來啟動(dòng)，代碼如下

publicfunctionactionIndex()

if('start'==$this-send){

try{

$this-start($this-daemon);

}catch(\Exception$e){

$this-stderr($e-getMessage()."\n",Console::FG_RED);

}elseif('stop'==$this-send){

$this-stop();

}elseif('restart'==$this-send){

$this-restart();

}elseif('reload'==$this-send){

$this-reload();

}elseif('status'==$this-send){

$this-status();

}elseif('connections'==$this-send){

$this-connections();

}

添加初始化模塊

publicfunctioninitWorker()

$ip=isset($this-config['ip'])$this-config['ip']:$this-

$port=isset($this-config['port'])$this-config['port']:$this-port;

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

//4processes

$wsWorker-count=4;

//Emittedwhennewconnectioncome

$wsWorker-onConnect=function($connection){

echo"Newconnection\n";

//Emittedwhendatareceived

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

//Sendhello$data

$connection-send('hello'.$data);

//Emittedwhenconnectionclosed

$wsWorker-onClose=function($connection){

echo"Connectionclosed\n";

}

添加啟動(dòng)模塊

*workmanwebsocketstart

publicfunctionstart()

$this-initWorker();

//重置參數(shù)以匹配Worker

global$argv;

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

$argv[1]='start';

if($this-daemon){

$argv[2]='-d';

//Runworker

Worker::runAll();

}

添加停止模塊

*workmanwebsocketstop

publicfunctionstop()

$this-initWorker();

//重置參數(shù)以匹配Worker

global$argv;

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

$argv[1]='stop';

if($this-gracefully){

$argv[2]='-g';

//Runworker

Worker::runAll();

}

添加重啟模塊

*workmanwebsocketrestart

publicfunctionrestart()

$this-initWorker();

//重置參數(shù)以匹配Worker

global$argv;

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

$argv[1]='restart';

if($this-daemon){

$argv[2]='-d';

if($this-gracefully){

$argv[2]='-g';

//Runworker

Worker::runAll();

}

添加重載模塊

*workmanwebsocketreload

publicfunctionreload()

$this-initWorker();

//重置參數(shù)以匹配Worker

global$argv;

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

$argv[1]='reload';

if($this-gracefully){

$argv[2]='-g';

//Runworker

Worker::runAll();

}

添加狀態(tài)模塊

*workmanwebsocketstatus

publicfunctionstatus()

$this-initWorker();

//重置參數(shù)以匹配Worker

global$argv;

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

$argv[1]='status';

if($this-daemon){

$argv[2]='-d';

//Runworker

Worker::runAll();

}

添加鏈接數(shù)模塊

*workmanwebsocketconnections

publicfunctionconnections()

$this-initWorker();

//重置參數(shù)以匹配Worker

global$argv;

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

$argv[1]='connections';

//Runworker

Worker::runAll();

}

3、前端調(diào)用

script

//CreateWebSocketconnection.

constws=newWebSocket('ws://{{app.request.hostName}}:2347/');//這里是獲取的網(wǎng)站的域名，測試的時(shí)候可以改為自己的本地的ip地址

//Connectionopened

ws.addEventListener('open',function(event){

ws.send('HelloServer!');

//Listenformessages

ws.addEventListener('message',function(event){

console.log('Messagefromserver',event.data);

setTimeout(function(){

ws.send('ssssss');

},10000);

/script

4、config參數(shù)配置

修改console.php并添加如下代碼

'controllerMap'=[

'workerman-web-socket'=[

'class'='app\commands\WorkermanWebSocketController',

'config'=[

'ip'='',

'port'='2346',

'daemonize'=true,

],

5、nginx配置

為什么會(huì)用nginx，我們正常部署上線是不可能直接使用ip的，這個(gè)戶存在安全隱患，最好是綁定一個(gè)域名

server{

charsetutf-8;

client_max_body_size128M;

listen2347;

server_name;#這里改為自己的域名

access_log/xxx.workerman.access.log;#換成自己服務(wù)器的nginx日志路徑

error_log/xxx.workerman.error.log;#換成自己服務(wù)器的nginx日志路徑

location/{

proxy_pass:2346;#代理2346也可以根據(jù)項(xiàng)目配置為自己的端口

proxy_set_headerX-Real-IP$remote_addr;

proxy_set_headerHost$host;

proxy_set_headerX-Forwarded-For$proxy_add_x_forwarded_for;

proxy_http_version1.1;

proxy_set_headerUpgrade$http_upgrade;

proxy_set_headerConnection"upgrade";

}

重新nginx

nginx-srelad或者sudonginx-sreload

然后將第3步的代碼加入自己做的視圖中，如果沒有問題的話，websocket啟動(dòng)后就能正常通訊了。

6、啟動(dòng)workermanwebsocket

//啟動(dòng)

./yiiworkerman-web-socket-sstart-d

如果沒有問題的話會(huì)得到類似如下的結(jié)果

$./yiiworkerman-web-socket-sstart-d

Workerman[workerman-web-socket]startinDAEMONmode

-----------------------WORKERMAN-----------------------------

Workermanversion:3.5.13PHPversion:7.1.16

------------------------WORKERS-------------------------------

userworkerlistenprocessesstatus

durbannonewebsocket://:23464[OK]

----------------------------------------------------------------

Input"phpworkerman-web-socketstop"tostop.Startsuccess.

7、其他

commands/WorkermanWebSocketController.php完整代碼如下

*WorkmanWebSocket服務(wù)相關(guān)

namespaceapp\commands;

useWorkerman\Worker;

useyii\console\Controller;

useyii\helpers\Console;

*WorkermanWebSocket

*@authordurban.zhangdurban.zhang@

classWorkermanWebSocketControllerextendsController

public$send;

public$daemon;

public$gracefully;

//這里不需要設(shè)置，會(huì)讀取配置文件中的配置

public$config=[];

private$ip='';

private$port='2346';

publicfunctionoptions($actionID)

return['send','daemon','gracefully'];

publicfunctionoptionAliases()

return[

's'='send',

'd'='daemon',

'g'='gracefully',

publicfunctionactionIndex()

if('start'==$this-send){

try{

$this-start($this-daemon);

}catch(\Exception$e){

$this-stderr($e-getMessage()."\n",Console::FG_RED);

}elseif('stop'==$this-send){

$this-stop();

}elseif('restart'==$this-send){

$this-restart();

}elseif('reload'==$this-send){

$this-reload();

}elseif('status'==$this-send){

$this-status();

}elseif('connections'==$this-send){

$this-connections();

publicfunctioninitWorker()

$ip=isset($this-config['ip'])$this-config['ip']:$this-

$port=isset($this-config['port'])$this-config['port']:$this-port;

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

//4processes

$wsWorker-count=4;

//Emittedwhennewconnectioncome

$wsWorker-onConnect=function($connection){

echo"Newconnection\n";

//Emittedwhendatareceived

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

//Sendhello$data

$connection-send('ddddhello'.$data);

//Emittedwhenconnectionclosed

$wsWorker-onClose=function($connection){

echo"Connectionclosed\n";

*workmanwebsocketstart

publicfunctionstart()

$this-initWorker();

//重置參數(shù)以匹配Worker

global$argv;

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

$argv[1]='start';

if($this-daemon){

$argv[2]='-d';

//Runworker

Worker::runAll();

*workmanwebsocketrestart

publicfunctionrestart()

$this-initWorker();

//重置參數(shù)以匹配Worker

global$argv;

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

$argv[1]='restart';

if($this-daemon){

$argv[2]='-d';

if($this-gracefully){

$argv[2]='-g';

//Runworker

Worker::runAll();

*workmanwebsocketstop

publicfunctionstop()

$this-initWorker();

//重置參數(shù)以匹配Worker

global$argv;

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

$argv[1]='stop';

if($this-gracefully){

$argv[2]='-g';

//Runworker

Worker::runAll();

*workmanwebsocketreload

publicfunctionreload()

$this-initWorker();

//重置參數(shù)以匹配Worker

global$argv;

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

$argv[1]='reload';

if($this-gracefully){

$argv[2]='-g';

//Runworker

Worker::runAll();

*workmanwebsocketstatus

publicfunctionstatus()

$this-initWorker();

//重置參數(shù)以匹配Worker

global$argv;

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

$argv[1]='status';

if($this-daemon){

$argv[2]='-d';

//Runworker

Worker::runAll();

*workmanwebsocketconnections

publicfunctionconnections()

$this-initWorker();

//重置參數(shù)以匹配Worker

global$argv;

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

$argv[1]='connections';

//Runworker

Worker::runAll();

}

workermanwebsocket支持的其他命令

重啟

$./yiiworkerman-web-socket-srestart-d

Workerman[workerman-web-socket]restart

Workerman[workerman-web-socket]isstopping...

Workerman[workerman-web-socket]stopsuccess

-----------------------WORKERMAN-----------------------------

Workermanversion:3.5.13PHPversion:7.1.16

------------------------WORKERS-------------------------------

userworkerlistenprocessesstatus

durbannonewebsocket://:23464[OK]

----------------------------------------------------------------

Input"phpworkerman-web-socketstop"tostop.Startsuccess.

重載

$./yiiworkerman-web-socket-sreload

Workerman[workerman-web-socket]reload

狀態(tài)

$./yiiworkerman-web-socket-sstatus-g

Workerman[workerman-web-socket]status

----------------------------------------------GLOBALSTATUS----------------------------------------------------

Workermanversion:3.5.13PHPversion:7.1.16

starttime:2025-09-1011:22:15run0days0hours

loadaverage:1.79,2,2event-loop:\Workerman\Events\Swoole

1workers4processes

worker_nameexit_statusexit_count

none012

----------------------------------------------PROCESSSTATUS---------------------------------------------------

pidmemorylis