首页 > 上网技巧 > 电脑小技巧 > Yii2结合Workerman的websocket示例详解

Yii2结合Workerman的websocket示例详解

时间:2018-11-04 11:21 作者:QQ地带 我要评论

步骤如下
 
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 ; # 这里改为自己的域名 access_log /xxx.workerman.access.log; # 换成自己服务器的nginx日志路径 error_log /xxx.workerman.error.log; # 换成自己服务器的nginx日志路径 location / { proxy_pass :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
 
如果没有问题的话会得到类似如下的结果

标签: workerman
顶一下
(0)
0%
踩一下
(0)
0%

Google提供的广告